activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From YoungSoul <youngs...@inbox.com>
Subject Re: Messages 'stuck' on queue, until client restart
Date Tue, 16 Jan 2007 17:35:55 GMT


If it helps, I was tailing the console output from the client as it prints
the message IDs and eventually the messages were consumed from the queue -
albeit late and out of order.  Below is a snippet from the log file.  As you
can, we are pulling messages in order, and then jump from message id: 3235
to message id: 2313

2007-01-16 11:21:30,827 [Thread-4] SimpleMessageConsumer called with message
id: ID:pryan-1360-1168961497076-0:0:1:1:3229
2007-01-16 11:21:32,870 [Thread-5] SimpleMessageConsumer called with message
id: ID:pryan-1360-1168961497076-0:0:1:1:3230
2007-01-16 11:21:34,913 [Thread-5] SimpleMessageConsumer called with message
id: ID:pryan-1360-1168961497076-0:0:1:1:3231
2007-01-16 11:21:36,956 [Thread-5] SimpleMessageConsumer called with message
id: ID:pryan-1360-1168961497076-0:0:1:1:3232
2007-01-16 11:21:38,999 [Thread-5] SimpleMessageConsumer called with message
id: ID:pryan-1360-1168961497076-0:0:1:1:3233
2007-01-16 11:21:41,042 [Thread-5] SimpleMessageConsumer called with message
id: ID:pryan-1360-1168961497076-0:0:1:1:3234
2007-01-16 11:21:43,085 [Thread-5] SimpleMessageConsumer called with message
id: ID:pryan-1360-1168961497076-0:0:1:1:3235
2007-01-16 11:21:43,755 [Thread-1] SimpleMessageConsumer called with message
id: ID:pryan-1360-1168961497076-0:0:1:1:2313
2007-01-16 11:21:43,755 [Thread-2] SimpleMessageConsumer called with message
id: ID:pryan-1360-1168961497076-0:0:1:1:2310
2007-01-16 11:21:43,755 [Thread-3] SimpleMessageConsumer called with message
id: ID:pryan-1360-1168961497076-0:0:1:1:2312
2007-01-16 11:21:43,755 [Thread-4] SimpleMessageConsumer called with message
id: ID:pryan-1360-1168961497076-0:0:1:1:2311
2007-01-16 11:21:43,755 [Thread-5] SimpleMessageConsumer called with message
id: ID:pryan-1360-1168961497076-0:0:1:1:2314
2007-01-16 11:21:45,127 [Thread-1] SimpleMessageConsumer called with message
id: ID:pryan-1360-1168961497076-0:0:1:1:3236
2007-01-16 11:21:47,170 [Thread-2] SimpleMessageConsumer called with message
id: ID:pryan-1360-1168961497076-0:0:1:1:3237
2007-01-16 11:21:49,203 [Thread-3] SimpleMessageConsumer called with message
id: ID:pryan-1360-1168961497076-0:0:1:1:3238




YoungSoul wrote:
> 
> 
> I am not using the ResourceAdapter.  This application is basically one
> that I had written back in the day with version 3, and I now have the
> opportunity to reuse most of that application and I was trying to get it
> to work with the latest ActiveMQ.
> 
> So I know this did work in the 3.x version.
> 
> I basically followed the 'CompetingConsumer' pattern.  I developed them as
> Spring Beans and my afterPropertiesSet method looks like: ( btw: the
> connectionFactory which is a simple wrapper will make sure that the
> connection is started as part of the create.  I am also using pooled
> connections so a client app might decide to have a few connections shared
> by any number of sessions. Some minor logging and error checking removed) 
> 
>     public void afterPropertiesSet() throws Exception {
>         
>     	Connection conn = connectionFactory.createConnection();
>     	if( conn != null ) {
>             session = conn.createSession(true,
> Session.SESSION_TRANSACTED);
>             
>             Queue readQueue = session.createQueue(readQueueName);
>             messageConsumer = session.createConsumer(readQueue);
>             if( writeQueueNames != null ) {
> 	            for (Iterator iter = writeQueueNames.iterator();
> iter.hasNext();) {
> 	                String writeQueueName = (String) iter.next();
> 	                Queue writeQueue = session.createQueue(writeQueueName);
> 	                MessageProducer mp = session.createProducer(writeQueue);
> 	                mp.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
> 	                messageProducers.add(mp);
> 	                queue2MessageProducerMap.put(writeQueueName,mp);
> 	            }
>             }
>             
>             if( deadQueueName != null ) {
>                 Queue deadLetter = session.createQueue(deadQueueName);
>                 deadMessageQueue = session.createProducer(deadLetter);
>                
> deadMessageQueue.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
>             }
>             initialized = true;
>         }
>         
>     }
> 
> I did create a junit to receive messages and a sender tool ( modeled after
> your producertool ) to recreate this.  In this case, I am sending one
> message every 2 seconds from a windows client, to a Linux AMQ server, to a
> consumer running on the same windows machine.  After about 2300 messages,
> I started seeing messages left in the queue.
> 
> I would be happy to zip the entire eclipse project and make that available
> if that is helpful.  This might certainly be something in my
> implementation or configuration, so I will continue to try to reduce the
> test case to the bare minimum that I can.
> 
> Thanks again.
> 
> Pat
> 
> 
> 
> Christopher G. Stach II wrote:
>> 
>> YoungSoul wrote:
>>> 
>>> To be specific about the release I used:
>>> 
>>> I went to the following url: 
>>> http://www.activemq.org/site/activemq-410-release.html
>>> and downloaded either apache-activemq-4.1.0-incubator.zip or
>>> apache-activemq-4.1.0-incubator.tar.gz depending upon the environment I
>>> was
>>> interested in.
>>> 
>>> Thanks for your reply and help you can provide.
>>> 
>>> Pat
>>> 
>>> 
>>> 
>>> 
>>> James.Strachan wrote:
>>>> On 1/15/07, YoungSoul <youngsoul@inbox.com> wrote:
>>>>> I seem to be having problems with 'stuck' messages on a queue.
>>>>>
>>>>> I am running with the latest ActiveMQ release.
>>>> By 'latest release' are you talking about 4.1? There were some fixes
>>>> in this area in 4.1 - could you be more specific please?
>>>>
>>>> -- 
>>>>
>>>> James
>>>> -------
>>>> http://radio.weblogs.com/0112098/
>>>>
>>>>
>>> 
>> 
>> Are you using AMQ's ResourceAdapter?
>> 
>> -- 
>> Christopher G. Stach II
>> 
>> 
>> 
> 
> 

-- 
View this message in context: http://www.nabble.com/Messages-%27stuck%27-on-queue%2C-until-client-restart-tf3017349.html#a8394883
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message