Помогите с JMS
Підписуйтеся на Telegram-канал «DOU #tech», щоб не пропустити нові технічні статті.
Здраствуйте. Имею задание. На вход приходит очередь и сообщение, мне нужно отправить сообщение в очередь. Так вот я не могу определить где очередь начинается.
Я так понимаю, что это Destination queue? Зарание спасибо.
public class Producer { public static void main(String[] args) { try { // Получает контекст JNDI Context jndiContext = new InitialContext(); // Выполняет поиск администрируемых объектов ConnectionFactory connectionFactory = (ConnectionFactory) jndiContext.lookup("jms/javaee7/ConnectionFactory" ); Destination queue = (Destination) jndiContext.lookup("jms/javaee7/Queue"); //Создает необходимые артефакты для соединения с очередью Connection connection = connectionFactory.createConnection(); Session session = connection.createSession(false, Session.AUTO_ ACKNOWLEDGE); MessageProducer producer = session.createProducer(queue); // Отправляет текстовое сообщение в очередь TextMessage message = session.createTextMessage("Сообщение отправлено " + new Date()); producer.send(message); connection.close(); } catch (NamingException | JMSException e) { e.printStackTrace(); } } }
10 коментарів
Додати коментар Підписатись на коментаріВідписатись від коментарів