@Configuration
public class JMSConfig {
@Bean
public ActiveMQConnectionFactory activeMQConnectionFactory() {
ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory();
activeMQConnectionFactory.setBrokerURL("failover:(tcp://127.0.0.1:61616)");
activeMQConnectionFactory.setUserName("admin");
activeMQConnectionFactory.setPassword("admin");
return activeMQConnectionFactory;
}
}
private void sendJmsMessageToQueue(String message, String queueName) {
try {
Connection connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue(queueName);
MessageProducer producer = session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
TextMessage textMessage = session.createTextMessage(message);
producer.send(textMessage);
session.close();
connection.close();
System.out.println("JMS Message Sent");
} catch (JMSException e) {
e.printStackTrace();
}
}
Advertisements
