activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From shirish <shirishredd...@gmail.com>
Subject Network of brokers gives the following warnings asyc error occurred, client already connected, cannot add producer/consumer
Date Tue, 25 Sep 2012 11:01:48 GMT
I have two systems no1slu075  and no1slu076  running JBOSS 7.1.0 I am using
spring configuration for setting up brokers using camel, The application
also has a producer and consumer in it.
configuration of the deployed application is as follows

>From what I have read so far from mailing lists is removing duplex=true
should resolve the issue but I did not even set that property. And I am
guessing this is mostly because of the broker is not de-registering
successfully and it is trying to establish the connection again.

Is it safe to ignore the following messages and if so is there any way to
suppress those logs from being populated ?

When one of the system is disconnected or jboss is restarted in that system
and when it comes back up online it starts throwing the following warnings

This logs are from no1slu076

12:04:52,123 INFO  [org.apache.activemq.network.DiscoveryNetworkConnector]
(Notifier-MulticastDiscoveryAgent-listener:DiscoveryNetworkConnector:NC:BrokerService[no1slu076])
Establishing network connection from
vm://no1slu076?async=false&network=true to tcp://
no1slu075.intranet.global.corp.com :61616
12:04:52,337 WARN  [org.apache.activemq.broker.TransportConnection]
(StartLocalBridge: localBroker=vm://no1slu076#24) Failed to add Connection
ID:no1slu076.intranet.global.corp.com-51118-1348554802563-18:2, reason:
javax.jms.InvalidClientIDException: Broker: no1slu076 - Client:
NC_no1slu075_inbound_no1slu076 already connected from vm://no1slu076#0
12:04:52,337 WARN
 [org.apache.activemq.network.DemandForwardingBridgeSupport] (ActiveMQ
Transport: tcp://no1slu075.intranet.global.corp.com/10.40.145.75:61616)
Network connection between vm://no1slu076#24 and tcp://
no1slu075.intranet.global.corp.com/10.40.145.75:61616 shutdown due to a
remote error: javax.jms.InvalidClientIDException: Broker: no1slu075 -
Client: NC_no1slu076_outbound already connected from tcp://
10.40.145.76:51274
12:04:52,340 INFO
 [org.apache.activemq.network.DemandForwardingBridgeSupport]
(StartLocalBridge: localBroker=vm://no1slu076#24) Network connection
between vm://no1slu076#24 and tcp://
no1slu075.intranet.global.corp.com/10.40.145.75:61616 shutdown due to a
local error: javax.jms.InvalidClientIDException: Broker: no1slu076 -
Client: NC_no1slu075_inbound_no1slu076 already connected from
vm://no1slu076#0
12:04:52,395 WARN
 [org.apache.activemq.network.DemandForwardingBridgeSupport] (ActiveMQ
Transport: tcp://no1slu075.intranet.global.corp.com/10.40.145.75:61616)
Network connection between vm://no1slu076#24 and tcp://
no1slu075.intranet.global.corp.com/10.40.145.75:61616 shutdown due to a
remote error: java.lang.IllegalStateException: Cannot add a producer to a
connection that had not been registered: ID:no1slu076.
intranet.global.corp.com -51118-1348554802563-18:1
12:04:52,411 INFO
 [org.apache.activemq.network.DemandForwardingBridgeSupport] (ActiveMQ
Task-6) no1slu076 bridge to no1slu075 stopped


The logs on no1slu075 are

12:04:01,810 WARN  [org.apache.activemq.broker.TransportConnection]
(ActiveMQ Transport: tcp:///10.40.145.76:51282) Failed to add Connection
ID:no1slu076. intranet.global.corp.com -51118-1348554802563-13:1, reason:
javax.jms.InvalidClientIDException: Broker: no1slu075 - Client:
NC_no1slu076_outbound already connected from tcp://10.40.145.76:51274
12:04:01,812 WARN  [org.apache.activemq.broker.TransportConnection.Service]
(ActiveMQ Transport: tcp:///10.40.145.76:51282) Async error occurred:
javax.jms.InvalidClientIDException: Broker: no1slu075 - Client:
NC_no1slu076_outbound already connected from tcp://10.40.145.76:51274:
javax.jms.InvalidClientIDException: Broker: no1slu075 - Client:
NC_no1slu076_outbound already connected from tcp://10.40.145.76:51274
        at
org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:223)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:85)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:65)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:85)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:85)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:91)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:715)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:139)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:150)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:229)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:222)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:204)
[activemq-core-5.6.0.jar:5.6.0]
        at java.lang.Thread.run(Thread.java:722) [rt.jar:1.7.0_02]

12:04:01,821 WARN  [org.apache.activemq.broker.TransportConnection.Service]
(ActiveMQ Transport: tcp:///10.40.145.76:51282) Async error occurred:
java.lang.IllegalStateException: Cannot add a producer to a connection that
had not been registered: ID:no1slu076.intranet.global.corp.com
-51118-1348554802563-13:1:
java.lang.IllegalStateException: Cannot add a producer to a connection that
had not been registered:
ID:no1slu076.intranet.global.corp.com-51118-1348554802563-13:1
        at
org.apache.activemq.broker.TransportConnection.processAddProducer(TransportConnection.java:498)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.command.ProducerInfo.visit(ProducerInfo.java:105)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:150)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:229)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:222)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:204)
[activemq-core-5.6.0.jar:5.6.0]
        at java.lang.Thread.run(Thread.java:722) [rt.jar:1.7.0_02]

12:04:40,475 WARN  [org.apache.activemq.broker.TransportConnection.Service]
(ActiveMQ Transport: tcp:///10.40.145.76:51291) Async error occurred:
java.lang.IllegalStateException: Cannot add a consumer to a connection that
had not been registered:
ID:no1slu076.intranet.global.corp.com-51118-1348554802563-20:1:
java.lang.IllegalStateException: Cannot add a consumer to a connection that
had not been registered:
ID:no1slu076.intranet.global.corp.com-51118-1348554802563-20:1
        at
org.apache.activemq.broker.TransportConnection.processAddConsumer(TransportConnection.java:548)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:349)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:150)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:229)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:222)
[activemq-core-5.6.0.jar:5.6.0]
        at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:204)
[activemq-core-5.6.0.jar:5.6.0]
        at java.lang.Thread.run(Thread.java:722) [rt.jar:1.7.0_02]




Thanks,
+Shirish

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message