Examples of org.jivesoftware.smackx.packet.Time

org.jivesoftware.smackx.packet.Time
est the time from a remote user. Time timeRequest = new Time(); timeRequest.setType(IQ.Type.GET); timeRequest.setTo(someUser@example.com/resource); // Create a packet collector to listen for a response. PacketCollector collector = con.createPacketCollector( new PacketIDFilter(timeRequest.getPacketID())); con.sendPacket(timeRequest); // Wait up to 5 seconds for a result. IQ result = (IQ)collector.nextResult(5000); if (result != null && result.getType() == IQ.Type.RESULT) { Time timeResult = (Time)result; // Do something with result... }
Warning: this is an non-standard protocol documented by XEP-0090. Because this is a non-standard protocol, it is subject to change. @author Matt Tucker

    public void run() {
        if( dialog.cancelled ) return;


        XMPPConnection con = BuddyList.getInstance().getConnection();


        Time request = new Time();
        request.setType(IQ.Type.GET);
        request.setTo(dialog.getUser());


        // Create a packet collector to listen for a response.
        PacketCollector collector = con
                .createPacketCollector(new PacketIDFilter(request.getPacketID()));


        con.sendPacket(request);




        // Wait up to 5 seconds for a result.
        IQ result = (IQ) collector.nextResult(SmackConfiguration
                .getPacketReplyTimeout());
        collector.cancel();
        if( dialog.cancelled ) return;


        if (result != null && result.getType() == IQ.Type.RESULT) {
            Time t = (Time) result;


            field.setText(t.getDisplay());
        } else
            field.setText("N/A");
        field.validate();
    }

View Full Code Here

            
            // query server version
            sendIQGetWithTimestamp(connection, new Version());


            // query server time
            sendIQGetWithTimestamp(connection, new Time());


/*            while (to != null) {
//                chat.sendMessage("Hello " + to + " at " + new Date());
                try { Thread.sleep((new Random().nextInt(15)+1)*1000 ); } catch (InterruptedException e) { ; }
            }*/

View Full Code Here


            // query server version
            sendIQGetWithTimestamp(connection, new Version());


            // query server time
            sendIQGetWithTimestamp(connection, new Time());


            /*            while (to != null) {
            //                chat.sendMessage("Hello " + to + " at " + new Date());
                            try { Thread.sleep((new Random().nextInt(15)+1)*1000 ); } catch (InterruptedException e) { ; }
                        }*/

View Full Code Here

    public void processPacket(Packet message) {
        if (!(message instanceof Time)
                || ((IQ) message).getType() != IQ.Type.GET)
            return;


        Time time = (Time) message;


        String from = message.getFrom();
        String to = message.getTo();


        com.valhalla.Logger.debug("Time request received from " + from);


        Calendar cal = Calendar.getInstance();


        SimpleDateFormat utcFormat = new SimpleDateFormat("yyyyMMdd'T'hh:mm:ss");
        DateFormat displayFormat = DateFormat.getDateTimeInstance();


        TimeZone timeZone = cal.getTimeZone();
        time.setTz(cal.getTimeZone().getID());
        time.setDisplay(displayFormat.format(cal.getTime()));
        // Convert local time to the UTC time.
        time.setUtc(utcFormat.format(new Date(cal.getTimeInMillis()
                - timeZone.getOffset(cal.getTimeInMillis()))));
        time.setTo(from);
        time.setFrom(to);
        time.setType(IQ.Type.RESULT);


        // send the response
        if (BuddyList.getInstance().checkConnection())
            BuddyList.getInstance().getConnection().sendPacket(time);
    }

View Full Code Here

            System.out.println("Registered as " + writerAddress);


            // Look for the reader process.
            System.out.print("Looking for " + readerAddress + "...");
            while (true) {
                IQ testIQ = new Time();
                testIQ.setType(IQ.Type.GET);
                testIQ.setTo(readerAddress);
                PacketCollector collector = con.createPacketCollector(new PacketIDFilter(testIQ.getPacketID()));
                con.sendPacket(testIQ);
                // Wait 5 seconds.
                long start = System.currentTimeMillis();
                Packet result = collector.nextResult(5000);
                collector.cancel();

View Full Code Here


            // Look for the reader process.
            System.out.print("Waiting for " + writerAddress + "...");
            PacketCollector collector = con.createPacketCollector(new AndFilter(
                    new FromMatchesFilter(writerAddress), new PacketTypeFilter(Time.class)));
            Time timeRequest = (Time)collector.nextResult();
            Time timeReply = new Time(Calendar.getInstance());
            timeReply.setPacketID(timeRequest.getPacketID());
            timeReply.setType(IQ.Type.RESULT);
            timeReply.setTo(timeRequest.getFrom());
            con.sendPacket(timeReply);
            System.out.println(" found writer. Now in reading mode.");


            // Track how many packets we've read.
            con.addPacketListener(new PacketListener() {

View Full Code Here

TOP

Related Classes of org.jivesoftware.smackx.packet.Time

com.valhalla.jbother.jabber.smack.TimeListener

com.valhalla.jbother.TimeCollector

org.apache.vysper.smack.BasicClient

org.jivesoftware.openfire.test.throttle.ThrottleTestReader

org.jivesoftware.openfire.test.throttle.ThrottleTestWriter

java.util.TimeZone

java.util.Calendar

java.util.Date

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.