TopicConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
TopicConnection connection = connectionFactory.createTopicConnection();
TopicSession session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
Topic topic = session.createTopic("example.topic");
TopicSubscriber subscriber = session.createDurableSubscriber(topic, "subscriberId");
connection.start();
Message message = subscriber.receive();
connection.close();
QueueConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
QueueConnection connection = connectionFactory.createQueueConnection();
QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue("example.queue");
QueueSender sender = session.createSender(queue);
connection.start();
for (int i = 0; i < 100; i++) {
TextMessage message = session.createTextMessage("Message " + i);
sender.send(message);
}
connection.close();
QueueConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
QueueConnection connection = connectionFactory.createQueueConnection();
QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue("example.queue");
QueueReceiver receiver = session.createReceiver(queue);
connection.start();
Message[] messages = receiver.receive(100);
for (Message message : messages) {
}
connection.close();
QueueConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
QueueConnection connection = connectionFactory.createQueueConnection();
QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue("example.queue");
QueueReceiver receiver = session.createReceiver(queue);
connection.start();
Message message = receiver.receive();
connection.close();
