org.objectweb.joram.mom.proxies
Class ReliableConnectionContext

java.lang.Object
  extended by org.objectweb.joram.mom.proxies.ReliableConnectionContext
All Implemented Interfaces:
java.io.Serializable, ConnectionContext

public class ReliableConnectionContext
extends java.lang.Object
implements ConnectionContext, java.io.Serializable

See Also:
Serialized Form

Field Summary
private  boolean closed
           
private  int heartBeat
           
private  long inputCounter
           
private  int key
           
private  long outputCounter
           
private  ProxyImpl proxyImpl
           
private  AckedQueue queue
           
private static long serialVersionUID
           
 
Constructor Summary
ReliableConnectionContext(ProxyImpl proxyImpl, int key, int heartBeat)
           
 
Method Summary
 int getHeartBeat()
           
 long getInputCounter()
           
 int getKey()
           
 AckedQueue getQueue()
           
 AbstractJmsRequest getRequest(java.lang.Object obj)
           
 boolean isClosed()
           
 void pushError(MomException exc)
           
 void pushReply(AbstractJmsReply reply)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

serialVersionUID

private static final long serialVersionUID
See Also:
Constant Field Values

key

private int key

inputCounter

private long inputCounter

outputCounter

private long outputCounter

queue

private AckedQueue queue

heartBeat

private int heartBeat

proxyImpl

private ProxyImpl proxyImpl

closed

private boolean closed
Constructor Detail

ReliableConnectionContext

ReliableConnectionContext(ProxyImpl proxyImpl,
                          int key,
                          int heartBeat)
Method Detail

getKey

public int getKey()
Specified by:
getKey in interface ConnectionContext

getQueue

public AckedQueue getQueue()

getHeartBeat

public int getHeartBeat()

getInputCounter

public long getInputCounter()

getRequest

public AbstractJmsRequest getRequest(java.lang.Object obj)
Specified by:
getRequest in interface ConnectionContext

pushReply

public void pushReply(AbstractJmsReply reply)
Specified by:
pushReply in interface ConnectionContext

pushError

public void pushError(MomException exc)
Specified by:
pushError in interface ConnectionContext

isClosed

public boolean isClosed()
Specified by:
isClosed in interface ConnectionContext


Copyright © 2010 ScalAgent D.T.. All Rights Reserved.