JMS CLUSTER example HelloWorldJMSClient
erasmomarciano Oct 3, 2012 9:40 AMHI
I think I've made a correct configuration JMS CLUSTER with two JBOSS
I have in output the following message:
NODE A
15:35:12,889 INFO [org.hornetq.core.server.cluster.impl.BridgeImpl] (Thread-9 (HornetQ-server-HornetQServerImpl::serverUUID=aee80f1a-ff17-11e1-9bb7-31536c526998-17798304)) Bridge ClusterConnectionBridge@260657 [name=sf.my-cluster.b2778f9b-0d54-11e2-be2b-db8313d291f3, queue=QueueImpl[name=sf.my-cluster.b2778f9b-0d54-11e2-be2b-db8313d291f3, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=aee80f1a-ff17-11e1-9bb7-31536c526998]]@6a4209 targetConnector=ServerLocatorImpl (identity=(Cluster-connection-bridge::ClusterConnectionBridge@260657 [name=sf.my-cluster.b2778f9b-0d54-11e2-be2b-db8313d291f3, queue=QueueImpl[name=sf.my-cluster.b2778f9b-0d54-11e2-be2b-db8313d291f3, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=aee80f1a-ff17-11e1-9bb7-31536c526998]]@6a4209 targetConnector=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-netty-NettyConnectorFactory?port=5446&host=localhost-localdomain], discoveryGroupConfiguration=null]]::ClusterConnectionImpl@4639333[nodeUUID=aee80f1a-ff17-11e1-9bb7-31536c526998, connector=org-hornetq-core-remoting-impl-netty-NettyConnectorFactory?port=5445&host=localhost-localdomain, address=jms, server=HornetQServerImpl::serverUUID=aee80f1a-ff17-11e1-9bb7-31536c526998])) [initialConnectors=[org-hornetq-core-remoting-impl-netty-NettyConnectorFactory?port=5446&host=localhost-localdomain], discoveryGroupConfiguration=null]] is connected
NODE B
15:35:12,915 INFO [org.hornetq.core.server.cluster.impl.BridgeImpl] (Thread-6 (HornetQ-server-HornetQServerImpl::serverUUID=b2778f9b-0d54-11e2-be2b-db8313d291f3-29237054)) Bridge ClusterConnectionBridge@17f6796 [name=sf.my-cluster.aee80f1a-ff17-11e1-9bb7-31536c526998, queue=QueueImpl[name=sf.my-cluster.aee80f1a-ff17-11e1-9bb7-31536c526998, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=b2778f9b-0d54-11e2-be2b-db8313d291f3]]@169bc15 targetConnector=ServerLocatorImpl (identity=(Cluster-connection-bridge::ClusterConnectionBridge@17f6796 [name=sf.my-cluster.aee80f1a-ff17-11e1-9bb7-31536c526998, queue=QueueImpl[name=sf.my-cluster.aee80f1a-ff17-11e1-9bb7-31536c526998, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=b2778f9b-0d54-11e2-be2b-db8313d291f3]]@169bc15 targetConnector=ServerLocatorImpl [initialConnectors=[org-hornetq-core-remoting-impl-netty-NettyConnectorFactory?port=5445&host=localhost-localdomain], discoveryGroupConfiguration=null]]::ClusterConnectionImpl@32983140[nodeUUID=b2778f9b-0d54-11e2-be2b-db8313d291f3, connector=org-hornetq-core-remoting-impl-netty-NettyConnectorFactory?port=5446&host=localhost-localdomain, address=jms, server=HornetQServerImpl::serverUUID=b2778f9b-0d54-11e2-be2b-db8313d291f3])) [initialConnectors=[org-hornetq-core-remoting-impl-netty-NettyConnectorFactory?port=5445&host=localhost-localdomain], discoveryGroupConfiguration=null]] is connected
Now I'd like to test.
I using the HelloWorldJMSClient but doesn't work.
// Set up all the default values
private static final String DEFAULT_MESSAGE = "Hello, World! ERASMOi CLUSTER JMS";
private static final String DEFAULT_CONNECTION_FACTORY = "jms/RemoteConnectionFactory";
private static final String DEFAULT_DESTINATION = "jms/queue/test";
//private static final String DEFAULT_DESTINATION = "jms/topic/test";
private static final String DEFAULT_MESSAGE_COUNT = "10000";
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://127.0.0.1:4447";
Can I use the my udp in this String?
private static final String PROVIDER_URL = "remote://231.7.7.7:9876";
.............
Thank you