org.jboss.messaging.core.distributed.replicator
Class AcknowledgmentCollector
java.lang.Object
org.jboss.messaging.core.distributed.replicator.AcknowledgmentCollector
- All Implemented Interfaces:
- org.jboss.messaging.core.distributed.replicator.AcknowledgmentCollectorFacade, ServerFacade
- public class AcknowledgmentCollector
- extends java.lang.Object
- implements org.jboss.messaging.core.distributed.replicator.AcknowledgmentCollectorFacade
TODO: thread safety, synchronize. Right now is wide open.
- Version:
- $Revision: 707 $
$Id: AcknowledgmentCollector.java 707 2006-03-07 17:11:38Z timfox $
- Author:
- Ovidiu Feodorov
Constructor Summary |
AcknowledgmentCollector(java.io.Serializable groupID,
java.io.Serializable id,
RpcDispatcher dispatcher)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
DELIVERY_RETRIES
public static final int DELIVERY_RETRIES
- See Also:
- Constant Field Values
id
protected java.io.Serializable id
groupID
protected java.io.Serializable groupID
dispatcher
protected RpcDispatcher dispatcher
collectorMessageListener
protected MessageListener collectorMessageListener
deliveries
protected java.util.Map deliveries
AcknowledgmentCollector
public AcknowledgmentCollector(java.io.Serializable groupID,
java.io.Serializable id,
RpcDispatcher dispatcher)
getID
public java.io.Serializable getID()
- Description copied from interface:
ServerFacade
- Return the ID under which server object is registered with the RpcServer.
- Specified by:
getID
in interface ServerFacade
acknowledge
public void acknowledge(PeerIdentity originator,
java.io.Serializable messageID)
- Specified by:
acknowledge
in interface org.jboss.messaging.core.distributed.replicator.AcknowledgmentCollectorFacade
cancel
public void cancel(PeerIdentity originator,
java.io.Serializable messageID)
- Specified by:
cancel
in interface org.jboss.messaging.core.distributed.replicator.AcknowledgmentCollectorFacade
start
public void start()
stop
public void stop()
startCollecting
public void startCollecting(java.util.Set dels)
- Parameters:
dels
- - Set.
remove
public void remove(java.util.Set dels)
- Parameters:
dels
- - Set.
toString
public java.lang.String toString()
Copyright © 2006 JBoss Inc. All Rights Reserved.