Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Received-SPF: pass (herse.apache.org: domain of lists@nabble.com designates
 72.21.53.35 as permitted sender)
Message-ID: <9020869.post@talk.nabble.com>
Date: Sat, 17 Feb 2007 07:32:01 -0800 (PST)
From: cafe <rmilian@estudiantes.uci.cu>
To: dev@activemq.apache.org
Subject: =?UTF-8?Q?I_can=E2=80=99t_receive_more_than_2_messages_simulta?=
 =?UTF-8?Q?neously_with_DefaultMessageListenerContainer?=
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit


I have a listener (in the server side) who receive request for send files
(Streams):

public class RequestUpdateListener implements SessionAwareMessageListener {

        private JmsTemplate jmsTemplate;

        private String fileUpdateLocation;
       
        public void onMessage(Message request, Session session) throws
JMSException {


                ActiveMQConnectionFactory connectionFactory =
((PooledConnectionFactory) jmsTemplate
                               
.getConnectionFactory()).getConnectionFactory();

                FileInputStream fis = null;
                try {
                        fis = new FileInputStream(new
File(fileUpdateLocation));
                        StreamSender ss = new StreamSender();
                        ss.send(connectionFactory, fis,uuid);

                } catch (Exception e) {
                        e.printStackTrace();
                }
       
        }
.............

and a class:

public class StreamSender {

        public void send(ConnectionFactory connectionFactory,
FileInputStream fis, String uuid) {
               
                try {

                        connection = (ActiveMQConnection)
connectionFactory.createConnection();
                        session = connection.createSession(true,
Session.AUTO_ACKNOWLEDGE);
                        Destination destination =
session.createQueue("TransferQueue");

                        int deliveryMode = DeliveryMode.NON_PERSISTENT;
                        int priority = 1;
                        long timeToLive = 0;

                        outputStreamMQ =
connection.createOutputStream(destination, prop, deliveryMode, priority,
                                        timeToLive);

               
                        int total = 0;
                        int reads;
                        byte[] array = new byte[8 * 1024];

                        while ((reads = fis.read(array)) != -1) {
                                outputStreamMQ.write(array, 0, reads);
                        }

                        JmsUtils.commitIfNecessary(session);
......

and again the spring container:

        <bean id="updateContainer"
               
class="org.springframework.jms.listener.DefaultMessageListenerContainer">
                <property name="concurrentConsumers" value="50" />
                <property name="connectionFactory" ref="jmsFactory" />
                <property name="destination" ref="requestUpdateQueue" />
                <property name="messageListener" ref="requestUpdateListener"
/>
        </bean>


and in the client side I have a listener who receive the Stream:

public class NotificationListener implements SessionAwareMessageListener {


        public void onMessage(Message response, Session session) throws
JMSException {

                String message = "xml descriptor";
                jmsTemplate.convertAndSend(requestUpdateQueue, message, new
MessagePostProcessor() {
                        public Message postProcessMessage(Message message)
throws JMSException {
                                ....
                                return message;
                        }
                });
               
                StreamReceiver receiver = new StreamReceiver();
                receiver.setConnectionFactory(connectionFactory);
                receiver.receive();

        }

public class StreamReceiver {


        public void receive() {
                ...
                try {

                        connection = (ActiveMQConnection)
connectionFactory.createConnection();
                        session = connection.createSession(true,
Session.AUTO_ACKNOWLEDGE);
                        Destination destination =
session.createQueue("TransferQueue");
                        fisMQ = connection.createInputStream(destination,
selector);
                        fos = new FileOutputStream("...");

                        int reads;
                        int total = 0;
                        byte[] array = new byte[8 * 1024];

                        while ((reads = fisMQ.read(array)) != -1) {
                                fos.write(array, 0, reads);
                                total += reads;
                                        }
                        JmsUtils.commitIfNecessary(session);
.........

Now the problem arise when more than 2 client running in different machines
does a request simultaneously, the server (StreamSender) stop the transfer
without any exception 

what could be this? 
-- 
View this message in context: http://www.nabble.com/I-can%E2%80%99t-receive-more-than-2-messages-simultaneously-with-DefaultMessageListenerContainer-tf3245123s2354.html#a9020869
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.