2012-12-08 35 views
0

我试图使用openfire服务器和asmack库实现pubsub。 我已经配置我的节点以这样的方式subscribers必须采取的publishers使用smack读取pubsub中的传入消息数据包

我现在想读取使用下面的代码Message包的批准,但我没有得到任何数据包。我想读取Message数据包,因为我想知道订阅者何时向发布者发送请求以获得订阅。

PacketTypeFilter filter = new PacketTypeFilter(org.jivesoftware.smack.packet.Message.class); 

    PacketListener myListener = new PacketListener(){ 

     @Override 
     public void processPacket(Packet packet) { 
      // TODO Auto-generated method stub 

      Log.d("PACKET" , "READ"); 

      if(packet instanceof org.jivesoftware.smack.packet.Message){ 

        org.jivesoftware.smack.packet.Message msg = (org.jivesoftware.smack.packet.Message) packet; 

      Log.d("MY MESSAGE" , msg.toXML()+ ""); 


        } 
       } 

      }; 

    cxmpp.addPacketListener(myListener, filter); 

所有我想要的是读取传入消息包

回答

1

如果你把所有的配置位和您的发布 - 订阅组件正常工作,然后得到一个正常的消息,你会做这样的事情:

ConnectionConfiguration config = new ConnectionConfiguration("ADDRESS",PORT); // service name, also known as XMPP domain of the target server. 
config.setServiceName(this.pubsubServiceAddress); 
connection = new XMPPConnection(config); 
connection.connect(); 

PacketFilter filter = new MessageTypeFilter(Message.Type.normal); 

connection.addPacketListener(new PacketListener() { 
    public void processPacket(Packet packet) { 
    Message mes = (Message)packet; 
     // do your stuff here 
    } 
}, filter);