import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
public class JmsMessageSender {
public static void sendMessage(String message) {
try {
ConnectionFactory connectionFactory = InitialContext.lookup("jms/javaee7/ConnectionFactory");
Connection connection = connectionFactory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue("myQueue");
MessageProducer producer = session.createProducer(queue);
TextMessage textMessage = session.createTextMessage();
textMessage.setText(message);
producer.send(textMessage, DeliveryMode.PERSISTENT, 4, 0);
connection.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageConsumer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
public class JmsMessageReceiver {
public static void receiveMessage() {
try {
ConnectionFactory connectionFactory = InitialContext.lookup("jms/javaee7/ConnectionFactory");
Connection connection = connectionFactory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue("myQueue");
MessageConsumer consumer = session.createConsumer(queue);
connection.start();
TextMessage message = (TextMessage) consumer.receive();
System.out.println("Received message: " + message.getText());
connection.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
<jms-queue name="myQueue">
<entry name="java:jboss/exported/jms/queue/myQueue"/>
</jms-queue>
