import javax.jms.Message;
import javax.jms.MessageListener;
public class MyMessageListener implements MessageListener {
@Override
public void onMessage(Message message) {
System.out.println("Received message: " + message);
}
}
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.Message;
import javax.jms.MessageListener;
@MessageDriven(activationConfig = {
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
@ActivationConfigProperty(propertyName = "destination", propertyValue = "myQueue")
})
public class MyMessageDrivenBean implements MessageListener {
@Override
public void onMessage(Message message) {
System.out.println("Received message: " + message);
}
}
<ejb-jar>
<enterprise-beans>
<message-driven>
<ejb-name>MyMessageDrivenBean</ejb-name>
<ejb-class>com.example.MyMessageDrivenBean</ejb-class>
<activation-config>
<activation-config-property>
<activation-config-property-name>destinationType</activation-config-property-name>
<activation-config-property-value>javax.jms.Queue</activation-config-property-value>
</activation-config-property>
<activation-config-property>
<activation-config-property-name>destination</activation-config-property-name>
<activation-config-property-value>myQueue</activation-config-property-value>
</activation-config-property>
</activation-config>
</message-driven>
</enterprise-beans>
<message-driven-destination>
<message-driven-destination-name>myQueue</message-driven-destination-name>
</message-driven-destination>
<connection-factory>
<connection-factory-name>MyConnectionFactory</connection-factory-name>
<connection-interface>javax.jms.ConnectionFactory</connection-interface>
<config-property>
<config-property-name>java.naming.factory.initial</config-property-name>
<config-property-value>org.apache.activemq.jndi.ActiveMQInitialContextFactory</config-property-value>
</config-property>
<config-property>
<config-property-name>java.naming.provider.url</config-property-name>
<config-property-value>tcp://localhost:61616</config-property-value>
</config-property>
</connection-factory>
</ejb-jar>
