[prev in list] [next in list] [prev in thread] [next in thread] 

List:       activemq-dev
Subject:    [jira] [Commented] (AMQNET-358) Why do ActiveMQ Consumers Recover
From:       "Timothy Bish (Commented) (JIRA)" <jira+amqnet () apache ! org>
Date:       2011-12-28 19:10:31
Message-ID: 663144280.49092.1325099431010.JavaMail.tomcat () hel ! zones ! apache ! org
[Download RAW message or body]


    [ https://issues.apache.org/jira/browse/AMQNET-358?page=com.atlassian.jira.plugin. \
system.issuetabpanels:comment-tabpanel&focusedCommentId=13176768#comment-13176768 ] 

Timothy Bish commented on AMQNET-358:
-------------------------------------

A SNAPSHOT build of 1.5.3 is available here: \
http://people.apache.org/~tabish/nms-1.5.0/ please try it and see if you see the same \
issue.  
> Why do ActiveMQ Consumers Recover to Pull Mode instead of Prefetch
> ------------------------------------------------------------------
> 
> Key: AMQNET-358
> URL: https://issues.apache.org/jira/browse/AMQNET-358
> Project: ActiveMQ .Net
> Issue Type: Bug
> Components: ActiveMQ
> Affects Versions: 1.5.2
> Environment: Windows Server 2008 R2 Standard
> AMQ Broker 5.4.2
> Spring.NET 1.3.2
> Apache.NMS 1.5.0
> Apache.NMS.ActiveMQ 1.5.2
> Reporter: Jonathan Parker McClure
> Assignee: Timothy Bish
> Attachments: AMQTestApp.7z, AMQTestAppNoSpring.7z
> 
> 
> I recently upgraded to NMS ActiveMQ 1.5.2 and when I restart the broker, the \
> connection and the consumers get restored, but they get restored to the "pull" \
> mode, which means the broker will not send them messages automatically. This isn't \
> how the previous version behaved. What I need is for it to recover back to the way \
> it was, which was prefetch 1000. I think I must be missing a setting for the \
> failover URL or something like that. My URL looks like this: 
> failover:(tcp://localhost:61616?consumer.prefetchSize=1266)
> I peaked at the source and it looks like the final "completion" isn't getting to \
> this area: Tracer.Debug("restored recovering consumer: " + control.ConsumerId + " \
> with: " + control.Prefetch); Here is the log output from the consumer.
> restore consumer: ID:csi-dul-516m-6334-634583598187658753-1:0:-1:1 in pull mode \
> pending recovery, overriding prefetch: 1000 restore consumer: \
> ID:csi-dul-516m-6334-634583598187658753-1:0:-1:1 restore consumer: \
> ID:csi-dul-516m-6334-634583598187658753-1:0:1:1 in pull mode pending     recovery, \
> overriding prefetch: 1000 restore consumer: \
> ID:csi-dul-516m-6334-634583598187658753-1:0:1:1 restore consumer: \
> ID:csi-dul-516m-6334-634583598187658753-1:0:2:1 in pull mode pending     recovery, \
> overriding prefetch: 1000 restore consumer: \
> ID:csi-dul-516m-6334-634583598187658753-1:0:2:1 Sending queued commands...
> Transport has resumed normal operation.
> Connection established
> Successfully reconnected to: tcp://localhost:61616/

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: \
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more \
information on JIRA, see: http://www.atlassian.com/software/jira

        


[prev in list] [next in list] [prev in thread] [next in thread]