Uploaded image for project: 'FUSE ESB'
  1. FUSE ESB
  2. ESB-1345

Refreshing a camel route that uses a shared ActiveMQ connection factory fails due to connection already created.

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: None
    • Labels:
      None

      Description

      We create a camel route that listens on a topioc, providing a clientId and connectionId. The route uses a shared activemq connection factory, accessed via an OSGi service.

      We find that the route works fine. However, if we refresh the bundle, we get the following error:

      11:59:33,799 | WARN  | /127.0.0.1:50231 | TransportConnection              | ivemq.broker.TransportConnection  699 | 46 - org.apache.activemq.activemq-core - 5.4.1.fuse-01-00 | Failed to add Connection
      javax.jms.InvalidClientIDException: Broker: default - Client: conn01 already connected from /127.0.0.1:50205
      	at org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:243)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:85)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:78)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:85)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:85)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:91)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:696)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:83)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:137)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:311)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:185)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:228)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:220)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)[46:org.apache.activemq.activemq-core:5.4.1.fuse-01-00]
      	at java.lang.Thread.run(Thread.java:680)[:1.6.0_22]
      11:59:33,801 | WARN  | tenerContainer-1 | DefaultMessageListenerContainer  | .DefaultMessageListenerContainer  875 | 80 - org.springframework.jms - 3.0.3.RELEASE | Could not refresh JMS Connection for destination 'CentraleTopic' - retrying in 5000 ms. Cause: Broker: default - Client: conn01 already connected from /127.0.0.1:50205

        Gliffy Diagrams

          Attachments

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                ade1 Adrian Trenaman
              • Votes:
                2 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated: