@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