Context context = new InitialContext();
ConnectionFactory factory = (ConnectionFactory) context.lookup("jms/ConnectionFactory");
Connection connection = factory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = (Queue) context.lookup("jms/Queue");
MessageProducer producer = session.createProducer(queue);
TextMessage message = session.createTextMessage("Hello JMS!");
message.setJMSDeliveryMode(DeliveryMode.PERSISTENT);
producer.send(message);
Context context = new InitialContext();
ConnectionFactory factory = (ConnectionFactory) context.lookup("jms/ConnectionFactory");
Connection connection = factory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = (Queue) context.lookup("jms/Queue");
MessageConsumer consumer = session.createConsumer(queue);
connection.start();
TextMessage message = (TextMessage) consumer.receive();
System.out.println("Received message: " + message.getText());
Context context = new InitialContext();
ConnectionFactory factory = (ConnectionFactory) context.lookup("jms/ConnectionFactory");
Connection connection = factory.createConnection();
Session session = connection.createSession(true, Session.SESSION_TRANSACTED);
Queue queue = (Queue) context.lookup("jms/Queue");
MessageProducer producer = session.createProducer(queue);
TextMessage message1 = session.createTextMessage("Message 1");
TextMessage message2 = session.createTextMessage("Message 2");
producer.send(message1);
producer.send(message2);
session.commit();