Lines Matching full:collector
264 PacketCollector collector = this.connection.createPacketCollector(new AndFilter(new PacketTypeFilter(Presence.class), new FromContainsFilter(workgroupJID)));
268 presence = (Presence)collector.nextResult(5000);
269 collector.cancel();
369 PacketCollector collector = this.connection.createPacketCollector(new AndFilter(new PacketTypeFilter(Presence.class), new FromContainsFilter(workgroupJID)));
373 presence = (Presence)collector.nextResult(5000);
374 collector.cancel();
419 PacketCollector collector = this.connection.createPacketCollector(new AndFilter(new PacketTypeFilter(Presence.class),
424 presence = (Presence)collector.nextResult(5000);
425 collector.cancel();
515 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID()));
518 OccupantsInfo response = (OccupantsInfo)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
520 // Cancel the collector.
521 collector.cancel();
807 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(notes.getPacketID()));
811 IQ response = (IQ)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
813 // Cancel the collector.
814 collector.cancel();
836 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID()));
839 ChatNotes response = (ChatNotes)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
841 // Cancel the collector.
842 collector.cancel();
874 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID()));
877 AgentChatHistory response = (AgentChatHistory)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
879 // Cancel the collector.
880 collector.cancel();
901 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID()));
905 SearchSettings response = (SearchSettings)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
907 // Cancel the collector.
908 collector.cancel();
931 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID()));
935 Macros response = (Macros)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
937 // Cancel the collector.
938 collector.cancel();
961 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID()));
965 IQ response = (IQ)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
967 // Cancel the collector.
968 collector.cancel();
990 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID()));
994 ChatMetadata response = (ChatMetadata)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
996 // Cancel the collector.
997 collector.cancel();
1046 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(iq.getPacketID()));
1049 IQ response = (IQ)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
1051 // Cancel the collector.
1052 collector.cancel();
1098 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(iq.getPacketID()));
1101 IQ response = (IQ)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
1103 // Cancel the collector.
1104 collector.cancel();
1126 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(setting.getPacketID()));
1129 GenericSettings response = (GenericSettings)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
1131 // Cancel the collector.
1132 collector.cancel();
1147 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID()));
1150 MonitorPacket response = (MonitorPacket)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
1152 // Cancel the collector.
1153 collector.cancel();
1171 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID()));
1174 Packet response = collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
1176 // Cancel the collector.
1177 collector.cancel();