28 lines
960 B
Java
28 lines
960 B
Java
package com.baeldung.wildfly.mdb;
|
|
|
|
import javax.ejb.ActivationConfigProperty;
|
|
import javax.ejb.MessageDriven;
|
|
import javax.jms.JMSException;
|
|
import javax.jms.Message;
|
|
import javax.jms.MessageListener;
|
|
import javax.jms.TextMessage;
|
|
|
|
/**
|
|
* Message-Driven Bean implementation class for: ReadMessageMDB
|
|
*/
|
|
@MessageDriven(
|
|
activationConfig = {
|
|
@ActivationConfigProperty(propertyName = "destination", propertyValue = "tutorialQueue"),
|
|
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
|
|
})
|
|
public class ReadMessageMDB implements MessageListener {
|
|
|
|
public void onMessage(Message message) {
|
|
TextMessage textMessage = (TextMessage) message;
|
|
try {
|
|
System.out.println("Message received: " + textMessage.getText());
|
|
} catch (JMSException e) {
|
|
System.out.println("Error while trying to consume messages: " + e.getMessage());
|
|
}
|
|
}
|
|
} |