public class CometDReplayExtension
extends org.cometd.bayeux.client.ClientSession.Extension.Adapter
client.addExtension(new CometDReplayExtension<>(replayMap));
Constructor and Description |
---|
CometDReplayExtension() |
Modifier and Type | Method and Description |
---|---|
void |
addChannelReplayId(String channelName,
long replayId) |
boolean |
rcv(org.cometd.bayeux.client.ClientSession session,
org.cometd.bayeux.Message.Mutable message) |
boolean |
rcvMeta(org.cometd.bayeux.client.ClientSession session,
org.cometd.bayeux.Message.Mutable message) |
boolean |
sendMeta(org.cometd.bayeux.client.ClientSession session,
org.cometd.bayeux.Message.Mutable message) |
public void addChannelReplayId(String channelName, long replayId)
public boolean rcv(org.cometd.bayeux.client.ClientSession session, org.cometd.bayeux.Message.Mutable message)
rcv
in interface org.cometd.bayeux.client.ClientSession.Extension
rcv
in class org.cometd.bayeux.client.ClientSession.Extension.Adapter
public boolean rcvMeta(org.cometd.bayeux.client.ClientSession session, org.cometd.bayeux.Message.Mutable message)
rcvMeta
in interface org.cometd.bayeux.client.ClientSession.Extension
rcvMeta
in class org.cometd.bayeux.client.ClientSession.Extension.Adapter
public boolean sendMeta(org.cometd.bayeux.client.ClientSession session, org.cometd.bayeux.Message.Mutable message)
sendMeta
in interface org.cometd.bayeux.client.ClientSession.Extension
sendMeta
in class org.cometd.bayeux.client.ClientSession.Extension.Adapter
Apache Camel