Michael Owen [
https://community.jboss.org/people/liverpoolilove] created the discussion
"A question about the transaction?"
To view the discussion, visit:
https://community.jboss.org/message/823591#823591
--------------------------------------------------------------
I created an MDB in my project.As follows:
/**
* Message-Driven Bean implementation class for: QueueListenerMDB
*/
@MessageDriven(activationConfig = {
@ActivationConfigProperty(propertyName = "destinationType",
propertyValue = "javax.jms.Queue"),
@ActivationConfigProperty(propertyName = "destination",
propertyValue = "queue/test") })
@Interceptors(SpringBeanAutowiringInterceptor.class)
public class QueueListenerMDB implements MessageListener {
/**
* Default constructor.
*/
public QueueListenerMDB() {
}
/**
* @see MessageListener#onMessage(Message)
*/
public void onMessage(Message message) {
sendMessage(message);
}
public void sendMessage(Message message) {
try {
if (message instanceof TextMessage) {
System.out.println("Queue: I received a
TextMessage at "
+ new Date());
TextMessage msg = (TextMessage) message;
System.out.println("Message is : " +
msg.getText());
} else if (message instanceof ObjectMessage) {
System.out.println("Queue: I received an
ObjectMessage at "
+ new Date());
ObjectMessage msg = (ObjectMessage) message;
DBTrigger trigger = (DBTrigger) msg.getObject();
triggerService.saveTrigger(trigger);
System.out.println("trigger Details:
");
System.out.println(trigger);
} else {
System.out.println("Not valid message for
this Queue MDB");
}
} catch (JMSException e) {
e.printStackTrace();
}
}
--------------------------------------------------------------
Reply to this message by going to Community
[
https://community.jboss.org/message/823591#823591]
Start a new discussion in EJB3 at Community
[
https://community.jboss.org/choose-container!input.jspa?contentType=1&...]