Package org.cometd.client.ext
Class TimesyncClientExtension
- java.lang.Object
-
- org.cometd.client.ext.TimesyncClientExtension
-
- All Implemented Interfaces:
ClientSession.Extension
public class TimesyncClientExtension extends java.lang.Object implements ClientSession.Extension
-
-
Constructor Summary
Constructors Constructor Description TimesyncClientExtension()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
getLag()
int
getOffset()
long
getServerTime()
boolean
rcvMeta(ClientSession session, Message.Mutable message)
Callback method invoked every time a meta message is received.boolean
sendMeta(ClientSession session, Message.Mutable message)
Callback method invoked every time a meta message is being sent.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.cometd.bayeux.client.ClientSession.Extension
incoming, outgoing, rcv, send
-
-
-
-
Method Detail
-
rcvMeta
public boolean rcvMeta(ClientSession session, Message.Mutable message)
Description copied from interface:ClientSession.Extension
Callback method invoked every time a meta message is received.- Specified by:
rcvMeta
in interfaceClientSession.Extension
- Parameters:
session
- the session object that is receiving the meta messagemessage
- the meta message received- Returns:
- true if message processing should continue, false if it should stop
-
sendMeta
public boolean sendMeta(ClientSession session, Message.Mutable message)
Description copied from interface:ClientSession.Extension
Callback method invoked every time a meta message is being sent.- Specified by:
sendMeta
in interfaceClientSession.Extension
- Parameters:
session
- the session object that is sending the messagemessage
- the meta message being sent- Returns:
- true if message processing should continue, false if it should stop
-
getOffset
public int getOffset()
-
getLag
public int getLag()
-
getServerTime
public long getServerTime()
-
-