In my Java EE application, I want send and receive a message using a RabbitMQ
broker and a Qpid JMS client. 


The information about RabbitMQ broker is as follow:

Server: turtle.rmq.cloudamqp.com
User: tsikywzh
Password: Z_1x359XUuKfkcK0PoohUVBWlqXtxVh
AMQP URL:
amqp://tsikywzh:z_1x359xuukfkck0poohuvbwlqxt...@turtle.rmq.cloudamqp.com/tsikywzh


The code for send a message using the Qpid JMS client:

public void sendMessage(){
        logger.log(Level.INFO, "Sending message {0}", messageText);
        Properties properties = new Properties();
   
properties.load(SenderBean.class.getResourceAsStream("/websimplemessage.properties"));
        Context context = new InitialContext(properties);
        ConnectionFactory connectionFactory = (ConnectionFactory)
context.lookup("qpidConnectionfactory");
        Connection connection = connectionFactory.createConnection();
        connection.start();            
        Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
        Destination destination = (Destination)
context.lookup("topicExchange");
        MessageProducer messageProducer =
session.createProducer(destination);
        String text = "Message from producer: " + messageText;
        TextMessage message = session.createTextMessage(text);
        messageProducer.send(message);
        connection.close();
        context.close();
}
Which uses this Apache Qpid JNDI Properties File websimplemessage.properties
:

java.naming.factory.initial =
org.apache.qpid.jndi.PropertiesFileInitialContextFactory
connectionfactory.qpidConnectionfactory =
amqp://tsikywzh:z_1x359xuukfkck0poohuvbwlqxt...@turtle.rmq.cloudamqp.com/tsikywzh?brokerlist='tcp://localhost:5672'
destination.topicExchange = amq.topic

Unfortunately, when I run the application, I get connection errors:

SenderBean.sendMessage: Exception: javax.jms.JMSException: Error creating
connection: Connection refused

I am sure RabbitMQ broker is work. Maybe the Qpid JNDI properties File is
not correct.

How can I solve this error? Thanks



--
View this message in context: 
http://apache-qpid-developers.2158895.n2.nabble.com/connection-refused-error-for-a-Java-EE-app-with-RabbitMQ-broker-Qpid-JMS-client-tp7590925.html
Sent from the Apache Qpid developers mailing list archive at Nabble.com.

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@qpid.apache.org
For additional commands, e-mail: dev-h...@qpid.apache.org

Reply via email to