我用的是activemq,呵呵 里面包括5种消息类型:TexmMessage,ObejectMessage,MapMessage,BytesMessage,StreamMessage
你send和receive的该是个对象吧,那就用ObejectMessage类型

解决方案 »

  1.   

    那ObjectMessage类型的消息,如何接收啊?
      

  2.   


    我用了listener接受:
    public void onMessage(Message message)
    {
    try{
    if(message instanceof ObjectMessage)
    {
    ObjectMessage obMsg = (ObjectMessage)message;
    Problem pro =(Problem)(obMsg.getObject());
    System.out.println("receive:"+pro.getCommunity());
    }
    }catch(Exception e){
     e.printStackTrace();
    }
    }
    当然上面也可以用同步方式接收:ObjectMessage om = (ObjectMessage)receiver.receive();
      

  3.   

    恕我愚钝“比如Code内容有A,B,C,三种,能够生成三个消息队列, 
    分别为消息队列A,消息队列B,消息队列C ”如何实现啊?