Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package com.simpleapplication.Profiler;
- import javax.jms.*;
- import org.apache.activemq.ActiveMQConnection;
- import org.apache.activemq.ActiveMQConnectionFactory;
- public class ActiveMQProducer {
- // = localhost
- private static String url = ActiveMQConnection.DEFAULT_BROKER_URL;
- // Name of the queue
- private static String subject = "Profiler";
- // Singleton
- private static final ActiveMQProducer instance = new ActiveMQProducer();
- private static ConnectionFactory connectionFactory;
- private static Connection connection;
- private static Session session;
- private static Destination destination;
- private static MessageProducer producer;
- private ActiveMQProducer() {
- connectionFactory = new ActiveMQConnectionFactory(url);
- }
- public void configure() {
- try {
- connection = connectionFactory.createConnection();
- connection.start();
- session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
- destination = session.createQueue(subject);
- } catch (JMSException e) {
- e.printStackTrace();
- }
- }
- public static ActiveMQProducer getInstance() {
- return instance;
- }
- public void addToQueue(String stacktrace) {
- try {
- producer = session.createProducer(destination);
- TextMessage message = session.createTextMessage(stacktrace);
- producer.send(message);
- } catch (JMSException e) {
- e.printStackTrace();
- }
- }
- public void close() {
- try {
- connection.close();
- } catch (JMSException e) {
- e.printStackTrace();
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement