Hi,I'm facing the problem in subject.The system is done by a broker (in
future a cluster of), a couple of consumers and some producers.Initially
I've setup one producer and messages sent arrive to one consumer only.I've
the broker configured with two TransportConnectors:First consumer connects
to "openwire" connector (follows the code) from the company intranet, this
is the one that doesn't receive any message.ConnectionFactory
connectionFactory = new
ActiveMQConnectionFactory(SingltProv.INSTANCE.getStringProperty(KEY_BROKER_URL));
 
// failover://tcp://127.0.0.1:61616connection =
connectionFactory.createConnection(SingltProv.INSTANCE.getStringProperty(KEY_BROKER_USERNAME),SingltProv.INSTANCE.getStringProperty(KEY_BROKER_PASSWORD));connection.start();/*
Creating session for sending messages */session =
connection.createSession(false, Session.AUTO_ACKNOWLEDGE);/* Getting the
topic */Destination destination = session.createTopic(TOPIC_NAME);/*
Creating the messageConsumer */messageConsumer =
session.createConsumer(destination);Second consumer connects to "nio+ssl"
connector (follows the code) from the public Internet, this is the one that
receives all the messages.ConnectionFactory connectionFactory = new
ActiveMQConnectionFactory(url);   //
failover://ssl://127.0.0.1:61617connection =
connectionFactory.createConnection(username,
password);connection.start();session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);Destination destination;destination =
session.createTopic(resourceName);consumer =
session.createConsumer(destination);Have you any suggestion?



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/One-consumer-out-of-two-doesn-t-receive-messages-sent-to-a-topic-tp4684939.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Reply via email to