Thursday, 8 August 2013

How will I send messages to Activemq

How will I send messages to Activemq

I never work on JMS. Recently I downloaded Activemq and changed port no
from 61616 to 61617 in all conf/activemq-*.xml files.I run the following
command from command prompt and open console page on browser.
C:\Users\Infratab
Bangalore\Desktop\Queueing\apache-activemq-5.8.0\bin>activemq

Now I want to send messages from java code using JMS to Activemq.For this
I wrote the following code. And run my code using Apache Tomcat
server.it's not working
This code is implemented in Eclipse.
package PackageName;
import java.io.IOException;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.activemq.ActiveMQConnectionFactory;
public class MessageProducer extends HttpServlet {
@Override
protected void service(HttpServletRequest arg0, HttpServletResponse arg1)
throws ServletException, IOException {
try {
//created ConnectionFactory object for creating connection
ConnectionFactory factory = new
ActiveMQConnectionFactory("admin","admin","tcp://localhost:61617");
//Establish the connection
Connection connection = factory.createConnection();
Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue("Test");
//Added as a producer
javax.jms.MessageProducer producer = session.createProducer(queue);
// Create and send the message
TextMessage msg = session.createTextMessage();
msg.setText("TestMessage");
producer.send(msg);
} catch (Exception e) {
// TODO: handle exception
}
}
}
can you suggest me, where I wrote wrong.
Thanks.

No comments:

Post a Comment