org.cometd.server.ext
Class AcknowledgedMessagesClientExtension
java.lang.Object
org.cometd.server.ext.AcknowledgedMessagesClientExtension
- All Implemented Interfaces:
- Extension
public class AcknowledgedMessagesClientExtension
- extends java.lang.Object
- implements Extension
Acknowledged Message Client extension.
Tracks the batch id of messages sent to a client.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AcknowledgedMessagesClientExtension
public AcknowledgedMessagesClientExtension(Client client)
rcv
public Message rcv(Client from,
Message message)
- Specified by:
rcv
in interface Extension
rcvMeta
public Message rcvMeta(Client from,
Message message)
- Handle received meta messages.
Looks for meta/connect messages with ext/ack fields.
If present, delete all messages that have been acked and requeue messages that
have not been acked.
- Specified by:
rcvMeta
in interface Extension
send
public Message send(Client from,
Message message)
- Specified by:
send
in interface Extension
sendMeta
public Message sendMeta(Client from,
Message message)
- Specified by:
sendMeta
in interface Extension
Copyright © 2009 Dojo Foundation. All Rights Reserved.