I'm trying to set up a publisher using an embedded broker in a single process and a set of subscribers running in other processes connected via tcp. It all works if the subscribers are running on the same machine as the publisher and they connect using tcp://localhost:61616. However, if I try to run the subscribers on a different machine I get "no route to host" errors.

The broker and publisher are set up as follows:

broker = new BrokerService();

// connection for the subscribers

broker.addConnector("tcp://localhost:61616");

broker.start();

// Create a producer.

String connectURL =

                "vm://SPAR?marshal=false&create=false";

ActiveMQConnectionFactory connectionFactory =

                new ActiveMQConnectionFactory(connectURL);

connection = connectionFactory.createTopicConnection();

session = connection.createTopicSession(

                false, Session.AUTO_ACKNOWLEDGE);

Topic topic = session.createTopic(TOPIC_NAME);

producer = session.createProducer(topic);

I've tried both "tcp://localhost:61616" and "tcp://192.168.100.11:61616" in the initial addConnector call (192.168.100.11 is the IP of the machine running the broker). The client code is as follows:

        ActiveMQConnectionFactory connectionFactory =

                new ActiveMQConnectionFactory(connectionUrl);

        connection = connectionFactory.createTopicConnection();

        connection.start();

        session = connection.createTopicSession(

              false, Session.AUTO_ACKNOWLEDGE);

        Topic topic = session.createTopic(PublishingBroker.TOPIC_NAME);

        userSubscriber = session.createSubscriber(

                topic, subscriptionRule, false);

        userSubscriber.setMessageListener(userMessageListener);

here connectionUrl comes from the command line and, if running on the same machine as the broker, is set to tcp://localhost:61616 and if running on a different host it's tcp://192.168.100.11:61616 which is the address of the machine where the broker is running.

As noted above if the subscriber and the broker are running on the same machine at connectionUrl = tcp://localhost:61616 and the broker is started with tcp://localhost:61616 everything works as expected. However, if I move the subscriber to a different machine I get a "no route to host" error:

Exception in thread "main" javax.jms.JMSException: Could not connect to broker URL: tcp://192.168.100.11:61616. Reason: java.net.NoRouteToHostException: No route to host

        at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:35)

        at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:286)

        at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:230)

        at org.apache.activemq.ActiveMQConnectionFactory.createTopicConnection(ActiveMQConnectionFactory.java:208)

        at edu.mit.ll.spar.SparClient.(SparClient.java:71)

        at edu.mit.ll.spar.TestNetworkClient.run(TestNetworkClient.java:95)

        at edu.mit.ll.spar.TestNetworkClient.main(TestNetworkClient.java:131)

Caused by: java.net.NoRouteToHostException: No route to host

        at java.net.PlainSocketImpl.socketConnect(Native Method)

        at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:327)

        at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:193)

        at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:180)

        at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:384)

        at java.net.Socket.connect(Socket.java:546)

        at org.apache.activemq.transport.tcp.TcpTransport.connect(TcpTransport.java:484)

        at org.apache.activemq.transport.tcp.TcpTransport.doStart(TcpTransport.java:447)

        at org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:53)

        at org.apache.activemq.transport.InactivityMonitor.start(InactivityMonitor.java:126)

        at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58)

        at org.apache.activemq.transport.WireFormatNegotiator.start(WireFormatNegotiator.java:72)

        at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58)

        at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58)

        at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:266)

        ... 5 more

I've tried this with the broker configured with broker.addConnector("tcp://localhost:61616"); and with broker.addConnector("tcp://192.168.100.11:61616");. One potentially complicating factor is that both machines are multi-homed (have more than one NIC card and more than 1 IP address). As a result I don't think the tcp://localhost connector can work as ActiveMQ wouldn't know which address it should bind to. When started with tcp://192.168.100.11:61616 netstat shows that the broker is indeed running and listening on that port:

]$ netstat -t -l

Active Internet connections (only servers)

Proto Recv-Q Send-Q Local Address               Foreign Address             State

... other stuff...

tcp        0      0 ::ffff:192.168.100.11:61616 :                         LISTEN

Also note that these machines are able to talk to each other on the network. They can ping each other and I can ssh from one to the other and vice versa.

Any idea what I'm doing wrong??