ClusterJMS Jboss7
erasmomarciano Jul 8, 2013 9:28 AMHi
I have this scenary
1) JBOSS A
--> ./standalone.sh --server-config=standalone-full_jms_cluster.xml
2) JBOSS B
--> ./standalone2.sh --server-config=standalone-full_jms_cluster.xml
Both Jboss nodes started without errors.
The cluster is correctly configured, as following:
5:17:21,878 INFO [org.hornetq.core.server.cluster.impl.BridgeImpl] (Thread-9 (HornetQ-server-HornetQServerImpl::serverUUID=7b3d2f3f-e7cf-11e2-a0d4-31e7b898d520-23822211)) Bridge ClusterConnectionBridge@1162ab9 [name=sf.my-cluster.81d3e434-e7cf-11e2-ac8a-29b3614b96a4, queue=QueueImpl[name=sf.my-cluster.81d3e434-e7cf-11e2-ac8a-29b3614b96a4, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=7b3d2f3f-e7cf-11e2-a0d4-31e7b898d520]]@4eda4a targetConnector=ServerLocatorImpl (identity=(Cluster-connection-bridge::ClusterConnectionBridge@1162ab9 [name=sf.my-cluster.81d3e434-e7cf-11e2-ac8a-29b3614b96a4, queue=QueueImpl[name=sf.my-cluster.81d3e434-e7cf-11e2-ac8a-29b3614b96a4, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=7b3d2f3f-e7cf-11e2-a0d4-31e7b898d520]]@4eda4a targetConnector=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-netty-NettyConnectorFactory?port=5446&host=localhost-localdomain], discoveryGroupConfiguration=null]]::ClusterConnectionImpl@9874503[nodeUUID=7b3d2f3f-e7cf-11e2-a0d4-31e7b898d520, connector=org-hornetq-core-remoting-impl-netty-NettyConnectorFactory?port=5445&host=localhost-localdomain, address=jms, server=HornetQServerImpl::serverUUID=7b3d2f3f-e7cf-11e2-a0d4-31e7b898d520])) [initialConnectors=[org-hornetq-core-remoting-impl-netty-NettyConnectorFactory?port=5446&host=localhost-localdomain], discoveryGroupConfiguration=null]] is connected
I have an client Jms(queue) that connects in this mode:
private static final String DEFAULT_CONNECTION_FACTORY = "jms/RemoteConnectionFactory";
private static final String DEFAULT_DESTINATION = "jms/queue/test";
private static final String DEFAULT_MESSAGE_COUNT = "1000";
private static final String DEFAULT_USERNAME = "quickstartUser";
private static final String DEFAULT_PASSWORD = "quickstartPassword";
private static final String INITIAL_CONTEXT_FACTORY = "org.jboss.naming.remote.client.InitialContextFactory";
private static final String PROVIDER_URL = "remote://localhost:4447";
The queue messages are only delivered locally
How can I send and receive messages on both nodes ?
Is there a Cluster Vip, Common Port or something that i am missing?
thank you