Nie można uruchomić odbiornika pakietów Smack

Question

Próbuję napisać listenera dla pakietu asmack. Co się dzieje, to słuchacz czasami po prostu nie dostaje pakietu i nie przetwarza go. Oto niektóre z kodu:

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)); 

pamiętać, że jest wewnątrz doInBackground (ciąg ... params) część asynctask.

Pakiet jest wysyłany przy użyciu:

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

Jeżeli JIDIQ jest asmack IQ. Ten kod działa poprawnie NAJCZĘŚCIEJ. Ale czasami pakiet PacketListener po prostu nie otrzymuje wysłanego pakietu. Zastanawiam się, czy zamiast tego powinienem używać PacketCollector, czy też słuchacz jakoś umiera. Czy ktoś wie, dlaczego nie otrzyma pakietu? Każda wiedza na ten temat byłaby ogromnie doceniona!

Answer 1

To się stanie, gdy jeden z twoich innych programów nasłuchujących wywoła wyjątek.
Za każdym razem, gdy pojawia się pakiet, następuje odpalanie spawn trafienia do wszystkich detektorów pakietów w jednym wątku, wewnątrz jednej pętli for. Jeśli wyjątek zostanie zgłoszony w detektorze pakietów, przerwie to wątek i nie zostaną uruchomione żadne dalsze detektory pakietów.

Najbardziej dokładnym sposobem wykrycia, gdzie to się dzieje, jest rekompilacja klapsów i dodanie procedury obsługi błędów w PacketReader.java.

Oto odpowiednia sekcja kodu. Widać, że każdy wyjątek, który zostanie zgłoszony, spowoduje przerwanie wątku, ponieważ nie ma obsługi błędów.

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

Myślę, że PacketIDFilter filtruje pakiety, więc twój odbiornik pakietów ich nie pobiera.

Po odebraniu pakietu przez pakiet nasłuchujący pakietu należy sprawdzić log smack, aby sprawdzić, czy identyfikator pakietu jest tym, czego oczekuje filtr pakietów.