Using Fuse embeded ActiveMQ on production
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