Advertisement
Guest User

Untitled

a guest
Jan 20th, 2017
110
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.69 KB | None | 0 0
  1. package com.travelagency.msg;
  2.  
  3.  
  4. import javax.jms.Connection;
  5. import javax.jms.Destination;
  6. import javax.jms.JMSException;
  7. import javax.jms.Message;
  8. import javax.jms.MessageConsumer;
  9. import javax.jms.MessageListener;
  10. import javax.jms.ObjectMessage;
  11. import javax.jms.Session;
  12.  
  13. import org.apache.activemq.ActiveMQConnectionFactory;
  14.  
  15. import com.travelagency.business.AgencyManager;
  16. import com.travelagency.model.user.Customer;
  17.  
  18. public class MsgConsumer2 implements MessageListener{
  19.  
  20. AgencyManager agencyManager = new AgencyManager();
  21.  
  22. public MsgConsumer2(){
  23. try {
  24. //create Connection
  25. ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
  26. Connection connection = connectionFactory.createConnection();
  27. connection.start();
  28. Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  29.  
  30. //create Consumer
  31. Destination queue = session.createQueue("CREATE_CUSTOMER");
  32. MessageConsumer consumer = session.createConsumer(queue);
  33. consumer.setMessageListener(this);
  34.  
  35. } catch (JMSException e) {
  36. e.printStackTrace();
  37. }
  38.  
  39. }
  40.  
  41. @Override
  42. public void onMessage(Message msg) {
  43. try{
  44. System.out.println("onMessage() " + msg);
  45.  
  46. if (msg instanceof ObjectMessage) {
  47. ObjectMessage objectMessage = (ObjectMessage) msg;
  48. Customer customer = (Customer) objectMessage.getObject();
  49. String messageId = msg.getJMSMessageID();
  50. System.out.println("es geht");
  51. switch(messageId){
  52. case "CREATE_CUSTOMER": agencyManager.addCustomer(customer);
  53. }
  54. }
  55.  
  56. } catch(JMSException e){}
  57. }
  58. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement