0 Replies Latest reply on Jul 17, 2013 2:47 AM by Damu R

    Using Fuse embeded ActiveMQ on production

    Damu R Newbie

      Hi,

       

      Please help me with the below questions.

       

      1. Can I use the embedded ActivieMQ in Fuse on production level deployment?

      Is there any disadvantages in using the embedded activeMQ over a separate activeMQ.

       

      As per my understanding using the internal activeMQ is the recommended approach as described in the below links.

       

      http://fusesource.com/docs/broker/5.4/tuning/GenTuning-Colocate.html

      http://fusesource.com/docs/broker/5.4/clustering/index.html

       

      2.  If I use the Fuse internal activeMQ.

            

          a) Should I be using ../etc/activemq.xml for configuring my settings? (persistent settings, tunning config etc.)?

          b) What is the default location used by the internal activeMQ for persistent data staorage? (if I am using kahadb)

       

      3. I am trying to make my fuse talk to a remote activeMQ by changing the

      ..profiles/mq-base/broker.xml -> transportConnector -> uri. I am getting the below error during start up. I can confirm that that the network connectivity exists between the two boxes on the specified port. The remote activeMQ is up and running and there are other consumers already connecting to the same host/port from different servers.

       

      java.io.IOException: Transport Connector could not be registered in JMX: Failed to bind to server socket: tcp://{my host}:61616 due to: java.net.BindException: Cannot assign requested address

          at org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:27)[125:org.apache.activemq.activemq-core:5.7.0.fuse-71-047]

          at org.apache.activemq.broker.BrokerService.registerConnectorMBean(BrokerService.java:1977)[125:org.apache.activemq.activemq-core:5.7.0.fuse-71-047]

          at org.apache.activemq.broker.BrokerService.startTransportConnector(BrokerService.java:2468)[125:org.apache.activemq.activemq-core:5.7.0.fuse-71-047]

          at org.apache.activemq.broker.BrokerService.startAllConnectors(BrokerService.java:2385)[125:org.apache.activemq.activemq-core:5.7.0.fuse-71-047]

          at org.apache.activemq.broker.BrokerService.doStartBroker(BrokerService.java:684)[125:org.apache.activemq.activemq-core:5.7.0.fuse-71-047]

          at org.apache.activemq.broker.BrokerService.startBroker(BrokerService.java:642)[125:org.apache.activemq.activemq-core:5.7.0.fuse-71-047]

          at org.apache.activemq.broker.BrokerService.start(BrokerService.java:578)[125:org.apache.activemq.activemq-core:5.7.0.fuse-71-047]

          at org.fusesource.mq.fabric.ActiveMQServiceFactory$ClusteredConfiguration$$anon$3.run(ActiveMQServiceFactory.scala:307)[145:org.fusesource.mq.mq-fabric:7.1.0.fuse-047]

      Caused by: java.io.IOException: Failed to bind to server socket: tcp://lon02-ft66-jms-01:61616 due to: java.net.BindException: Cannot assign requested address

          at org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:33)[125:org.apache.activemq.activemq-core:5.7.0.fuse-71-047]

          at org.apache.activemq.transport.tcp.TcpTransportServer.bind(TcpTransportServer.java:135)[125:org.apache.activemq.activemq-core:5.7.0.fuse-71-047]

          at org.apache.activemq.transport.tcp.TcpTransportFactory.doBind(TcpTransportFactory.java:60)[125:org.apache.activemq.activemq-core:5.7.0.fuse-71-047]

          at org.apache.activemq.transport.TransportFactory.bind(TransportFactory.java:124)[125:org.apache.activemq.activemq-core:5.7.0.fuse-71-047]

          at org.apache.activemq.broker.TransportConnector.createTransportServer(TransportConnector.java:310)[125:org.apache.activemq.activemq-core:5.7.0.fuse-71-047]

          at org.apache.activemq.broker.TransportConnector.getServer(TransportConnector.java:136)[125:org.apache.activemq.activemq-core:5.7.0.fuse-71-047]

          at org.apache.activemq.broker.TransportConnector.asManagedConnector(TransportConnector.java:105)[125:org.apache.activemq.activemq-core:5.7.0.fuse-71-047]

          at org.apache.activemq.broker.BrokerService.registerConnectorMBean(BrokerService.java:1972)[125:org.apache.activemq.activemq-core:5.7.0.fuse-71-047]

          ... 6 more

      Caused by: java.net.BindException: Cannot assign requested address

          at java.net.PlainSocketImpl.socketBind(Native Method)[:1.7.0_21]

          at java.net.AbstractPlainSocketImpl.bind(AbstractPlainSocketImpl.java:376)[:1.7.0_21]

          at java.net.ServerSocket.bind(ServerSocket.java:376)[:1.7.0_21]

          at java.net.ServerSocket.(ServerSocket.java:237)[:1.7.0_21]

          at javax.net.DefaultServerSocketFactory.createServerSocket(ServerSocketFactory.java:231)[:1.7.0_21]

          at org.apache.activemq.transport.tcp.TcpTransportServer.bind(TcpTransportServer.java:132)[125:org.apache.activemq.activemq-core:5.7.0.fuse-71-047]

       

       

      Thanks in advance for any help.

       

      --damu