Le programme d'écoute de paquets Smack ne fonctionne pas

Question

J'essaie d'écrire un programme d'écoute pour un paquet asmack. Ce qui finit par arriver, c'est que parfois l'auditeur n'obtient pas le paquet et le traite. Voici le code:

try { 

      XMPPMethods.getConnection().addPacketListener(new PacketListener() { 
        @Override 
        public synchronized void processPacket(Packet packet) { 

         if (packet.getPacketID().equals(lastCustomIQId)) { 

          android.os.Message msg = new android.os.Message(); 
          msg.obj = privateData; 
          msg.what = XMPPMethods.ADD_CONTACT_RESULTS; 
          AddContact.addContactHandler.sendMessage(msg); 
         } 
        } 
       }, new PacketIDFilter(lastCustomIQId)); 

Notez que c'est à l'intérieur de la doInBackground (string ... params) partie d'un AsyncTask.

Le paquet est envoyé en utilisant:

JIDIQ.setPacketID(lastCustomIQId); 
JIDIQ.setFrom(XMPPMethods.getCurrentUserFullUserName()); 
JIDIQ.setType(Type.GET); 
XMPPMethods.getConnection().sendPacket(JIDIQ); 

Lorsque le JIDIQ est un QI de asmack. Ce code fonctionne correctement dans la plupart des cas. Mais parfois, le PacketListener ne reçoit pas le paquet envoyé. Je me demande si je devrais utiliser un PacketCollector à la place, ou si l'auditeur est en train de mourir. Est-ce que quelqu'un sait pourquoi cela ne recevrait pas le paquet? Toute connaissance de ce sujet serait grandement appréciée!

Answer 1

Cela se produira en cas de problème si l'un de vos autres écouteurs de paquets émet une exception.
Chaque fois qu'un paquet arrive en mode smack d'un hit pour tous les paquets d'écoute dans un thread, à l'intérieur d'une boucle for. Si une exception est levée dans un programme d'écoute de paquets, cela interrompra ce processus et aucun autre écouteur de paquets ne sera déclenché.

La manière la plus complète de détecter où cela se produit est de recompiler smack et d'ajouter un gestionnaire d'erreur dans PacketReader.java.

Voici la section de code pertinente. Vous pouvez voir que toute exception levée entraînera l'abandon du thread car il n'y a pas de gestion des erreurs.

private class ListenerNotification implements Runnable { 

    private Packet packet; 

    public ListenerNotification(Packet packet) { 
     this.packet = packet; 
    } 

    public void run() { 
     for (ListenerWrapper listenerWrapper : connection.recvListeners.values()) { 
      listenerWrapper.notifyListener(packet); 
     } 
    } 
} 

Answer 2

Je pense que le PacketIDFilter filtre les paquets, donc votre écouteur de paquets ne les obtient pas. Lorsque votre programme d'écoute de paquets n'obtient pas le paquet, vérifiez dans le journal smack si l'ID de paquet est ce que le filtre de paquets attend.