while (iter.hasNext()) {
RosterEntry entry = (RosterEntry) iter.next();
int index = Collections.binarySearch((List)colaboradores,entry.getUser(),comparator);
if (index > -1) {
try {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
Presence presence = roster.getPresence(entry.getUser());
System.out.println(“PRESENCE:”+presence);
if (presence != null && presence.getType() == Presence.Type.AVAILABLE) {
Message message = new Message();
message.setTo(entry.getUser());
message.setSubject(“Controle de Build”);
message.setBody(msg);
connection.sendPacket(message);
System.out.println(“ola”);
connection.addPacketWriterListener(new PacketListener(){
public void processPacket(Packet packet) {
if (packet instanceof Message) {
System.out.println(“Message is:”+((Message)packet).getBody());
connection.sendPacket(packet);
System.out.println(“ola2”);
}
}
}, null);
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
}
}
}
}
} catch (XMPPException e) {
e.printStackTrace();
} finally{
connection.close();
connection = null;
}
System.out.println(System.currentTimeMillis() - inicial);
}