Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package com.travelagency.msg;
- import javax.jms.Connection;
- import javax.jms.Destination;
- import javax.jms.JMSException;
- import javax.jms.Message;
- import javax.jms.MessageConsumer;
- import javax.jms.MessageListener;
- import javax.jms.ObjectMessage;
- import javax.jms.Session;
- import org.apache.activemq.ActiveMQConnectionFactory;
- import com.travelagency.business.AgencyManager;
- import com.travelagency.model.user.Customer;
- public class MsgConsumer2 implements MessageListener{
- AgencyManager agencyManager = new AgencyManager();
- public MsgConsumer2(){
- try {
- //create Connection
- ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
- Connection connection = connectionFactory.createConnection();
- connection.start();
- Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
- //create Consumer
- Destination queue = session.createQueue("CREATE_CUSTOMER");
- MessageConsumer consumer = session.createConsumer(queue);
- consumer.setMessageListener(this);
- } catch (JMSException e) {
- e.printStackTrace();
- }
- }
- @Override
- public void onMessage(Message msg) {
- try{
- System.out.println("onMessage() " + msg);
- if (msg instanceof ObjectMessage) {
- ObjectMessage objectMessage = (ObjectMessage) msg;
- Customer customer = (Customer) objectMessage.getObject();
- String messageId = msg.getJMSMessageID();
- System.out.println("es geht");
- switch(messageId){
- case "CREATE_CUSTOMER": agencyManager.addCustomer(customer);
- }
- }
- } catch(JMSException e){}
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement