You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by lathan <la...@tango-networks.com> on 2006/06/01 15:30:53 UTC
Durable consumer reconnect problem
In testing a network of brokers (description below) I'm having problems
getting a durable consumer to reconnect to a topic if that consumer process
is killed (kill -9) and not given a chance to clean up. In looking at the
code in TopicRegion.addConsumer it appears to be checking to make sure an
active subscription does not already exist for the given clientID. While
this does enforce the rule that you can only have one durable subscription
for a given client, it seems to preclude the ability to recover when a
durable consumer crashes. Am I missing something config-wise or is this a
bug?
Exception:
2006-05-31 16:41:53,689 [INFO,DemandForwardingBridge] --> Network
connection between vm://lab00260102#6 and
tcp://localhost/127.0.0.1:60101(lab00260101) has been established.
2006-05-31 16:41:54,450 [INFO,Service] --> Async error occurred:
javax.jms.JMSException: Durable consumer is in use for client:
NC_lab00260101_inboundlab00260102 and subscriptionName: lab00260102_prov
javax.jms.JMSException: Durable consumer is in use for client:
NC_lab00260101_inboundlab00260102 and subscriptionName: lab00260102_prov
at
org.apache.activemq.broker.region.TopicRegion.addConsumer(TopicRegion.java:80)
at
org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:296)
at
org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:73)
at
org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:77)
at
org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:73)
at
org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:86)
at
org.apache.activemq.broker.AbstractConnection.processAddConsumer(AbstractConnection.java:427)
at
org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:295)
at
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
at
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:76)
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
at
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
at
org.apache.activemq.network.DemandForwardingBridgeSupport.addSubscription(DemandForwardingBridgeSupport.java:405)
at
org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteConsumerAdvisory(DemandForwardingBridgeSupport.java:357)
@
at
org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteCommand(DemandForwardingBridgeSupport.java:307)
at
org.apache.activemq.network.DemandForwardingBridgeSupport$2.onCommand(DemandForwardingBridgeSupport.java:124)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
at java.lang.Thread.run(Thread.java:595)
2006-05-31 16:41:54,453 [WARN,DemandForwardingBridge] --> Unexpected local
command: ConnectionError {commandId = 2, responseRequired = false,
connectionId = null, exception = javax.jms.JMSException: Durable consumer is
in use for client: NC_lab00260101_inboundlab00260102 and subscriptionName:
lab00260102_prov}
My setup:
ActiveMQ 4.0
RedHat Linux 4.0
Java 1.5.0_06
Network of Brokers
- Two processes on the same machine
- Each process has a broker.
- One process represents the producer (persistent), the other the
consumer (durable consumer)
- Connection via peer transport
lathan lewis
--
View this message in context: http://www.nabble.com/Durable+consumer+reconnect+problem-t1716817.html#a4662218
Sent from the ActiveMQ - User forum at Nabble.com.
Re: Durable consumer reconnect problem
Posted by James Strachan <ja...@gmail.com>.
On 9/12/06, lathan <la...@tango-networks.com> wrote:
>
>
> James, sorry for the delay in testing but yes, the latest 4.1 Snapshot does
> appear to have fixed the problem I was having. Thanks for addressing it. Do
> you have a rough estimate on when an offical 4.1 release will be available?
Hopefully in a couple of weeks from now; the codes ready, its more a
case of ensuring the maven 2 build generates the correct artifacts
with all the correct licenses, notices & headers etc
--
James
-------
http://radio.weblogs.com/0112098/
Re: Durable consumer reconnect problem
Posted by lathan <la...@tango-networks.com>.
James, sorry for the delay in testing but yes, the latest 4.1 Snapshot does
appear to have fixed the problem I was having. Thanks for addressing it. Do
you have a rough estimate on when an offical 4.1 release will be available?
lathan
James.Strachan wrote:
>
> Could you try using the current 4.1 SNAPSHOT to see if your issue
> still exists as we applied some patches in this area
>
>
> On 6/1/06, lathan <la...@tango-networks.com> wrote:
>>
>>
>> In testing a network of brokers (description below) I'm having problems
>> getting a durable consumer to reconnect to a topic if that consumer
>> process
>> is killed (kill -9) and not given a chance to clean up. In looking at the
>> code in TopicRegion.addConsumer it appears to be checking to make sure an
>> active subscription does not already exist for the given clientID. While
>> this does enforce the rule that you can only have one durable
>> subscription
>> for a given client, it seems to preclude the ability to recover when a
>> durable consumer crashes. Am I missing something config-wise or is this a
>> bug?
>>
>> Exception:
>> 2006-05-31 16:41:53,689 [INFO,DemandForwardingBridge] --> Network
>> connection between vm://lab00260102#6 and
>> tcp://localhost/127.0.0.1:60101(lab00260101) has been established.
>> 2006-05-31 16:41:54,450 [INFO,Service] --> Async error occurred:
>> javax.jms.JMSException: Durable consumer is in use for client:
>> NC_lab00260101_inboundlab00260102 and subscriptionName: lab00260102_prov
>> javax.jms.JMSException: Durable consumer is in use for client:
>> NC_lab00260101_inboundlab00260102 and subscriptionName: lab00260102_prov
>> at
>> org.apache.activemq.broker.region.TopicRegion.addConsumer(TopicRegion.java:80)
>> at
>> org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:296)
>> at
>> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:73)
>> at
>> org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:77)
>> at
>> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:73)
>> at
>> org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:86)
>> at
>> org.apache.activemq.broker.AbstractConnection.processAddConsumer(AbstractConnection.java:427)
>> at
>> org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:295)
>> at
>> org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
>> at
>> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
>> at
>> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
>> at
>> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
>> at
>> org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:76)
>> at
>> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
>> at
>> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
>> at
>> org.apache.activemq.network.DemandForwardingBridgeSupport.addSubscription(DemandForwardingBridgeSupport.java:405)
>> at
>> org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteConsumerAdvisory(DemandForwardingBridgeSupport.java:357)
>> @
>> at
>> org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteCommand(DemandForwardingBridgeSupport.java:307)
>> at
>> org.apache.activemq.network.DemandForwardingBridgeSupport$2.onCommand(DemandForwardingBridgeSupport.java:124)
>> at
>> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
>> at
>> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
>> at
>> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
>> at
>> org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
>> at
>> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
>> at
>> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
>> at java.lang.Thread.run(Thread.java:595)
>> 2006-05-31 16:41:54,453 [WARN,DemandForwardingBridge] --> Unexpected
>> local
>> command: ConnectionError {commandId = 2, responseRequired = false,
>> connectionId = null, exception = javax.jms.JMSException: Durable consumer
>> is
>> in use for client: NC_lab00260101_inboundlab00260102 and
>> subscriptionName:
>> lab00260102_prov}
>>
>> My setup:
>> ActiveMQ 4.0
>> RedHat Linux 4.0
>> Java 1.5.0_06
>>
>> Network of Brokers
>> - Two processes on the same machine
>> - Each process has a broker.
>> - One process represents the producer (persistent), the other the
>> consumer (durable consumer)
>> - Connection via peer transport
>>
>> lathan lewis
>>
>>
>> --
>> View this message in context:
>> http://www.nabble.com/Durable+consumer+reconnect+problem-t1716817.html#a4662218
>> Sent from the ActiveMQ - User forum at Nabble.com.
>>
>>
>
>
> --
>
> James
> -------
> http://radio.weblogs.com/0112098/
>
>
--
View this message in context: http://www.nabble.com/Durable-consumer-reconnect-problem-tf1716817.html#a6265832
Sent from the ActiveMQ - User forum at Nabble.com.
Re: Durable consumer reconnect problem
Posted by Tero <te...@hotmail.com>.
James.Strachan wrote:
>
> AFAIK this should work fine against 4.2-SNAPSHOT as we recently fixed
> a bug that was causing the stomp connection to stick around on the
> broker after the stomp client had been stopped.
> --
>
> James
> -------
> http://radio.weblogs.com/0112098/
>
>
I am running into the same problem with OpenWire and .NET C# client. I tried
the latest broker snapshot and OpenWire client from SVN; did not help.
I can reboot the client box and everything, but I can no longer reconnect to
the broker. Only restarting the broker will release the connection.
--
View this message in context: http://www.nabble.com/Durable-consumer-reconnect-problem-tf1716817s2354.html#a10142784
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Durable consumer reconnect problem
Posted by James Strachan <ja...@gmail.com>.
On 2/9/07, Sandeep Chayapathi <sa...@wssource.com> wrote:
>
> Hi all,
> We too have the same problem. Using the stable AMQ 4.1 & stomp, I can
> duplicate this problem.
>
> 1. Create a durable subscriber, via stomp protocol
> 2. Publish messages to the topic
> 3. stop the subscrber
> 4. stop the producer
> 5. start the subscriber, using the same client id and "subcription" name.
>
> you will see the "Durable consumer is in use for client" exception.
>
> A workaround, is after setp #4, start producer before step #5.
>
> It would help if others confirm this and as well as the developers take a
> note of this. Thanks.
AFAIK this should work fine against 4.2-SNAPSHOT as we recently fixed
a bug that was causing the stomp connection to stick around on the
broker after the stomp client had been stopped.
--
James
-------
http://radio.weblogs.com/0112098/
Re: Durable consumer reconnect problem
Posted by Sandeep Chayapathi <sa...@wssource.com>.
Hi all,
We too have the same problem. Using the stable AMQ 4.1 & stomp, I can
duplicate this problem.
1. Create a durable subscriber, via stomp protocol
2. Publish messages to the topic
3. stop the subscrber
4. stop the producer
5. start the subscriber, using the same client id and "subcription" name.
you will see the "Durable consumer is in use for client" exception.
A workaround, is after setp #4, start producer before step #5.
It would help if others confirm this and as well as the developers take a
note of this. Thanks.
- Sandeep
James.Strachan wrote:
>
> Could you try using the current 4.1 SNAPSHOT to see if your issue
> still exists as we applied some patches in this area
>
>
> On 6/1/06, lathan <la...@tango-networks.com> wrote:
>>
>>
>> In testing a network of brokers (description below) I'm having problems
>> getting a durable consumer to reconnect to a topic if that consumer
>> process
>> is killed (kill -9) and not given a chance to clean up. In looking at the
>> code in TopicRegion.addConsumer it appears to be checking to make sure an
>> active subscription does not already exist for the given clientID. While
>> this does enforce the rule that you can only have one durable
>> subscription
>> for a given client, it seems to preclude the ability to recover when a
>> durable consumer crashes. Am I missing something config-wise or is this a
>> bug?
>>
>> Exception:
>> 2006-05-31 16:41:53,689 [INFO,DemandForwardingBridge] --> Network
>> connection between vm://lab00260102#6 and
>> tcp://localhost/127.0.0.1:60101(lab00260101) has been established.
>> 2006-05-31 16:41:54,450 [INFO,Service] --> Async error occurred:
>> javax.jms.JMSException: Durable consumer is in use for client:
>> NC_lab00260101_inboundlab00260102 and subscriptionName: lab00260102_prov
>> javax.jms.JMSException: Durable consumer is in use for client:
>> NC_lab00260101_inboundlab00260102 and subscriptionName: lab00260102_prov
>> at
>> org.apache.activemq.broker.region.TopicRegion.addConsumer(TopicRegion.java:80)
>> at
>>
>
--
View this message in context: http://www.nabble.com/Durable-consumer-reconnect-problem-tf1716817s2354.html#a8891464
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Durable consumer reconnect problem
Posted by James Strachan <ja...@gmail.com>.
Could you try using the current 4.1 SNAPSHOT to see if your issue
still exists as we applied some patches in this area
On 6/1/06, lathan <la...@tango-networks.com> wrote:
>
>
> In testing a network of brokers (description below) I'm having problems
> getting a durable consumer to reconnect to a topic if that consumer process
> is killed (kill -9) and not given a chance to clean up. In looking at the
> code in TopicRegion.addConsumer it appears to be checking to make sure an
> active subscription does not already exist for the given clientID. While
> this does enforce the rule that you can only have one durable subscription
> for a given client, it seems to preclude the ability to recover when a
> durable consumer crashes. Am I missing something config-wise or is this a
> bug?
>
> Exception:
> 2006-05-31 16:41:53,689 [INFO,DemandForwardingBridge] --> Network
> connection between vm://lab00260102#6 and
> tcp://localhost/127.0.0.1:60101(lab00260101) has been established.
> 2006-05-31 16:41:54,450 [INFO,Service] --> Async error occurred:
> javax.jms.JMSException: Durable consumer is in use for client:
> NC_lab00260101_inboundlab00260102 and subscriptionName: lab00260102_prov
> javax.jms.JMSException: Durable consumer is in use for client:
> NC_lab00260101_inboundlab00260102 and subscriptionName: lab00260102_prov
> at
> org.apache.activemq.broker.region.TopicRegion.addConsumer(TopicRegion.java:80)
> at
> org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:296)
> at
> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:73)
> at
> org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:77)
> at
> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:73)
> at
> org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:86)
> at
> org.apache.activemq.broker.AbstractConnection.processAddConsumer(AbstractConnection.java:427)
> at
> org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:295)
> at
> org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
> at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
> at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
> at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
> at
> org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:76)
> at
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
> at
> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
> at
> org.apache.activemq.network.DemandForwardingBridgeSupport.addSubscription(DemandForwardingBridgeSupport.java:405)
> at
> org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteConsumerAdvisory(DemandForwardingBridgeSupport.java:357)
> @
> at
> org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteCommand(DemandForwardingBridgeSupport.java:307)
> at
> org.apache.activemq.network.DemandForwardingBridgeSupport$2.onCommand(DemandForwardingBridgeSupport.java:124)
> at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
> at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
> at
> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
> at
> org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
> at
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
> at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
> at java.lang.Thread.run(Thread.java:595)
> 2006-05-31 16:41:54,453 [WARN,DemandForwardingBridge] --> Unexpected local
> command: ConnectionError {commandId = 2, responseRequired = false,
> connectionId = null, exception = javax.jms.JMSException: Durable consumer is
> in use for client: NC_lab00260101_inboundlab00260102 and subscriptionName:
> lab00260102_prov}
>
> My setup:
> ActiveMQ 4.0
> RedHat Linux 4.0
> Java 1.5.0_06
>
> Network of Brokers
> - Two processes on the same machine
> - Each process has a broker.
> - One process represents the producer (persistent), the other the
> consumer (durable consumer)
> - Connection via peer transport
>
> lathan lewis
>
>
> --
> View this message in context: http://www.nabble.com/Durable+consumer+reconnect+problem-t1716817.html#a4662218
> Sent from the ActiveMQ - User forum at Nabble.com.
>
>
--
James
-------
http://radio.weblogs.com/0112098/
Re: Durable consumer reconnect problem
Posted by Venkatg <ve...@yahoo.com>.
I am having the same problem. Can someboday reply to this problem.
Thanks in advance
-Venkat
lathan wrote:
>
> Thanks for the quick reply. I tried to configure the soTimeout and
> inactivity monitor as you mentioned but the behavior does not appear to
> have changed. I still get the same connection failure for an indefinite
> period of time. I create the embedded brokers via the below code snippet.
> Is this the correct way to go about it? I believe this will solve my
> problem if I can get it to work but one other potential for faster cleanup
> is using the following log/exception as the trigger to remove the client
> entry. I see this immediately whenever a remote broker disconnects:
>
> 2006-06-01 12:56:08,144 [INFO,DemandForwardingBridge] --> Network
> connection between vm://lab00260102#2 and tcp://localhost/127.0.0.1:48381
> shutdown: null
> java.io.EOFException
> at java.io.DataInputStream.readInt(DataInputStream.java:358)
> at
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:270)
> at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
> at java.lang.Thread.run(Thread.java:595)
>
> Code snippet -
> broker = new BrokerService();
> broker.setBrokerName(uniqueName);
> TransportConnector connector = broker.addConnector(new
> URI("tcp://localhost:0?wireFormat.maxInactivityDuration=10000&soTimeout=10000&trace=true&connectionTimeout=10000"));
> connector.setDiscoveryUri(new URI("multicast://224.1.2.3:6255"));
>
> broker.addNetworkConnector("multicast://224.1.2.3:6255");
>
> broker.start();
>
>
--
View this message in context: http://www.nabble.com/Durable-consumer-reconnect-problem-tf1716817.html#a6147014
Sent from the ActiveMQ - User forum at Nabble.com.
Re: Durable consumer reconnect problem
Posted by lathan <la...@tango-networks.com>.
Thanks for the quick reply. I tried to configure the soTimeout and inactivity
monitor as you mentioned but the behavior does not appear to have changed. I
still get the same connection failure for an indefinite period of time. I
create the embedded brokers via the below code snippet. Is this the correct
way to go about it? I believe this will solve my problem if I can get it to
work but one other potential for faster cleanup is using the following
log/exception as the trigger to remove the client entry. I see this
immediately whenever a remote broker disconnects:
2006-06-01 12:56:08,144 [INFO,DemandForwardingBridge] --> Network
connection between vm://lab00260102#2 and tcp://localhost/127.0.0.1:48381
shutdown: null
java.io.EOFException
at java.io.DataInputStream.readInt(DataInputStream.java:358)
at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:270)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
at java.lang.Thread.run(Thread.java:595)
Code snippet -
broker = new BrokerService();
broker.setBrokerName(uniqueName);
TransportConnector connector = broker.addConnector(new
URI("tcp://localhost:0?wireFormat.maxInactivityDuration=10000&soTimeout=10000&trace=true&connectionTimeout=10000"));
connector.setDiscoveryUri(new URI("multicast://224.1.2.3:6255"));
broker.addNetworkConnector("multicast://224.1.2.3:6255");
broker.start();
--
View this message in context: http://www.nabble.com/Durable+consumer+reconnect+problem-t1716817.html#a4666976
Sent from the ActiveMQ - User forum at Nabble.com.
Re: Durable consumer reconnect problem
Posted by James Strachan <ja...@gmail.com>.
On 6/1/06, lathan <la...@tango-networks.com> wrote:
>
>
> In testing a network of brokers (description below) I'm having problems
> getting a durable consumer to reconnect to a topic if that consumer process
> is killed (kill -9) and not given a chance to clean up. In looking at the
> code in TopicRegion.addConsumer it appears to be checking to make sure an
> active subscription does not already exist for the given clientID.
We have to enforce this to be JMS compliant.
> While
> this does enforce the rule that you can only have one durable subscription
> for a given client, it seems to preclude the ability to recover when a
> durable consumer crashes. Am I missing something config-wise or is this a
> bug?
The killed client should be detected and closed down at some point;
either by the socket timing out or the inactivity monitor detecting it
(if its enabled on the transport). Then the client will be removed
allowing the restarted client to reconnect.
Maybe the reconnection logic could be a little more smart - if a
duplicate client connects, we proactively try to ping the old client
to see if its still alive (up to some timeout) then if the client
responds, we fail the duplicate, otherwise we kill the old client
connection.
James
>
> Exception:
> 2006-05-31 16:41:53,689 [INFO,DemandForwardingBridge] --> Network
> connection between vm://lab00260102#6 and
> tcp://localhost/127.0.0.1:60101(lab00260101) has been established.
> 2006-05-31 16:41:54,450 [INFO,Service] --> Async error occurred:
> javax.jms.JMSException: Durable consumer is in use for client:
> NC_lab00260101_inboundlab00260102 and subscriptionName: lab00260102_prov
> javax.jms.JMSException: Durable consumer is in use for client:
> NC_lab00260101_inboundlab00260102 and subscriptionName: lab00260102_prov
> at
> org.apache.activemq.broker.region.TopicRegion.addConsumer(TopicRegion.java:80)
> at
> org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:296)
> at
> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:73)
> at
> org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:77)
> at
> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:73)
> at
> org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:86)
> at
> org.apache.activemq.broker.AbstractConnection.processAddConsumer(AbstractConnection.java:427)
> at
> org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:295)
> at
> org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
> at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
> at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
> at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
> at
> org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:76)
> at
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
> at
> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
> at
> org.apache.activemq.network.DemandForwardingBridgeSupport.addSubscription(DemandForwardingBridgeSupport.java:405)
> at
> org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteConsumerAdvisory(DemandForwardingBridgeSupport.java:357)
> @
> at
> org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteCommand(DemandForwardingBridgeSupport.java:307)
> at
> org.apache.activemq.network.DemandForwardingBridgeSupport$2.onCommand(DemandForwardingBridgeSupport.java:124)
> at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
> at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
> at
> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
> at
> org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
> at
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
> at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
> at java.lang.Thread.run(Thread.java:595)
> 2006-05-31 16:41:54,453 [WARN,DemandForwardingBridge] --> Unexpected local
> command: ConnectionError {commandId = 2, responseRequired = false,
> connectionId = null, exception = javax.jms.JMSException: Durable consumer is
> in use for client: NC_lab00260101_inboundlab00260102 and subscriptionName:
> lab00260102_prov}
>
> My setup:
> ActiveMQ 4.0
> RedHat Linux 4.0
> Java 1.5.0_06
>
> Network of Brokers
> - Two processes on the same machine
> - Each process has a broker.
> - One process represents the producer (persistent), the other the
> consumer (durable consumer)
> - Connection via peer transport
>
> lathan lewis
>
>
> --
> View this message in context: http://www.nabble.com/Durable+consumer+reconnect+problem-t1716817.html#a4662218
> Sent from the ActiveMQ - User forum at Nabble.com.
>
>
--
James
-------
http://radio.weblogs.com/0112098/