EJB - MDB/Topic

EJB | MDB/Topic

Créer une application qui utilise des MDB/Topic

Créer une application qui utilise des MDB/Topic
- Créer une classe Java pour déclarer un MDB :
  package com.mtitek.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; @MessageDriven( activationConfig = { @ActivationConfigProperty(propertyName = "destination", propertyValue = "topic/testA"), @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Topic") } ) public class MessageDrivenTopicA1 implements MessageListener { @Override public void onMessage(Message message) { System.out.println("MessageDrivenTopicA1 (" + this.toString() + ").onMessage - Start"); try { if (message instanceof TextMessage) { TextMessage textMessage = (TextMessage) message; System.out.println("MessageDrivenTopicA1.onMessage: (" + message.getClass().getName() + ") = " + textMessage.getText()); } else { System.out.println("MessageDrivenTopicA1.onMessage: (" + message.getClass().getName() + ") = NOT SUPPORTED YET !!!"); } } catch (JMSException e) { throw new RuntimeException(e); } System.out.println("MessageDrivenTopicA1 (" + this.toString() + ").onMessage - End"); } }
- Envoyer un message à un Topic :
  Ce type de connexion doit être utilisé lorsque le client et le serveur s'exécutent dans la même JVM.
  package com.mtitek.mdb.test; import javax.annotation.Resource; import javax.ejb.LocalBean; import javax.ejb.Stateless; import javax.jms.JMSException; import javax.jms.MessageProducer; import javax.jms.Session; import javax.jms.TextMessage; import javax.jms.Topic; import javax.jms.TopicConnection; import javax.jms.TopicConnectionFactory; import javax.jms.TopicSession; @Stateless @LocalBean public class MessageDrivenTopicAManagerBean { @Resource(mappedName = "java:/topic/testA") private Topic topic; @Resource(mappedName = "java:/ConnectionFactory") private TopicConnectionFactory topicConnectionFactory; public void sendTextMessage() { System.out.println("MessageDrivenTopicAManagerBean (" + this.toString() + ").sendTextMessage - Start"); TopicConnection topicConnection = null; TopicSession topicSession = null; try { topicConnection = topicConnectionFactory.createTopicConnection(); topicConnection.start(); topicSession = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer messageProducer = (MessageProducer) topicSession.createProducer(topic); TextMessage textMessage = topicSession.createTextMessage(); textMessage.setText("Hello, world! !"); messageProducer.send(textMessage); } catch (JMSException e) { e.printStackTrace(); } finally { try { if (topicSession != null) { topicSession.close(); } } catch (JMSException e) { e.printStackTrace(); } try { if (topicConnection != null) { topicConnection.close(); } } catch (JMSException e) { e.printStackTrace(); } } System.out.println("MessageDrivenTopicAManagerBean (" + this.toString() + ").sendTextMessage - End"); } }