org.cometd.server.ext
Class AcknowledgedMessagesClientExtension

java.lang.Object
  extended by 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.


Constructor Summary
AcknowledgedMessagesClientExtension(Client client)
           
 
Method Summary
 Message rcv(Client from, Message message)
           
 Message rcvMeta(Client from, Message message)
          Handle received meta messages.
 Message send(Client from, Message message)
           
 Message sendMeta(Client from, Message message)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AcknowledgedMessagesClientExtension

public AcknowledgedMessagesClientExtension(Client client)
Method Detail

rcv

public Message rcv(Client from,
                   Message message)
Specified by:
rcv in interface Extension
Returns:
modified message or null to discard message

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
Returns:
modified message

send

public Message send(Client from,
                    Message message)
Specified by:
send in interface Extension
Returns:
modified message or null to discard message

sendMeta

public Message sendMeta(Client from,
                        Message message)
Specified by:
sendMeta in interface Extension
Returns:
modified message


Copyright © 2011 Dojo Foundation. All Rights Reserved.