activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From shirish <shirishredd...@gmail.com>
Subject Re: Network of brokers gives the following warnings asyc error occurred, client already connected, cannot add producer/consumer
Date Tue, 25 Sep 2012 16:11:02 GMT
Forgot to add the version of activemq its 5.6.0


On Tue, Sep 25, 2012 at 4:31 PM, shirish <shirishreddy89@gmail.com> wrote:

>
> 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