org.commonreality.participant.impl.ack

Class SessionAcknowledgements

java.lang.Object

org.commonreality.participant.impl.ack.SessionAcknowledgements

public class SessionAcknowledgements
extends java.lang.Object

contains session specific ack data. Many IMessages require an acknowledgment. Some code may want to block until that ack is received. Once the ack is received, any locks are released and the ack is moved to a memory sensitive cache, allowing it to be accessed for a limited duration of time.

Author:

harrison

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.concurrent.Future<IAcknowledgement>	EMPTY

Constructor Summary

Constructors

Constructor and Description
SessionAcknowledgements(org.apache.mina.core.session.IoSession session)

Method Summary

Modifier and Type	Method and Description
void	acknowledgementReceived(IAcknowledgement ack)
java.util.concurrent.Future<IAcknowledgement>	getAckFuture(long messageId)
org.apache.mina.core.session.IoSession	getSession()
static SessionAcknowledgements	getSessionAcks(org.apache.mina.core.session.IoSession session)
protected void	install(org.apache.mina.core.session.IoSession session)
java.util.concurrent.Future<IAcknowledgement>	newAckFuture(IMessage message)
protected void	uninstall(org.apache.mina.core.session.IoSession session)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

EMPTY

public static final java.util.concurrent.Future<IAcknowledgement> EMPTY

Constructor Detail

SessionAcknowledgements

public SessionAcknowledgements(org.apache.mina.core.session.IoSession session)

Method Detail

getSessionAcks

public static SessionAcknowledgements getSessionAcks(org.apache.mina.core.session.IoSession session)

install

protected void install(org.apache.mina.core.session.IoSession session)

uninstall

protected void uninstall(org.apache.mina.core.session.IoSession session)

newAckFuture

public java.util.concurrent.Future<IAcknowledgement> newAckFuture(IMessage message)

getAckFuture

public java.util.concurrent.Future<IAcknowledgement> getAckFuture(long messageId)

acknowledgementReceived

public void acknowledgementReceived(IAcknowledgement ack)

getSession

public org.apache.mina.core.session.IoSession getSession()