1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 package org.jboss.as.quickstarts.mdb;
18
19 import java.util.logging.Logger;
20 import javax.ejb.ActivationConfigProperty;
21 import javax.ejb.MessageDriven;
22 import javax.jms.JMSException;
23 import javax.jms.Message;
24 import javax.jms.MessageListener;
25 import javax.jms.TextMessage;
26
27
28
29
30
31
32
33
34
35 @MessageDriven(name = "HelloWorldQueueMDB", activationConfig = {
36 @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
37 @ActivationConfigProperty(propertyName = "destination", propertyValue = "${property.helloworldmdb.queue}"),
38 @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge") })
39 public class HelloWorldQueueMDB implements MessageListener {
40
41 private final static Logger LOGGER = Logger.getLogger(HelloWorldQueueMDB.class.toString());
42
43
44
45
46 public void onMessage(Message rcvMessage) {
47 TextMessage msg = null;
48 try {
49 if (rcvMessage instanceof TextMessage) {
50 msg = (TextMessage) rcvMessage;
51 LOGGER.info("Received Message from queue: " + msg.getText());
52 } else {
53 LOGGER.warning("Message of wrong type: " + rcvMessage.getClass().getName());
54 }
55 } catch (JMSException e) {
56 throw new RuntimeException(e);
57 }
58 }
59 }