public class ReliableConnectionContext extends Object implements ConnectionContext, Serializable
ConnectionContext.Type
Modifier and Type | Field and Description |
---|---|
private boolean |
active |
private boolean |
closed |
private int |
heartBeat |
private long |
inputCounter |
private int |
key |
static Logger |
logger |
private boolean |
noAckedQueue |
private long |
outputCounter |
private AckedQueue |
queue |
private QueueWorker |
queueWorker |
private static long |
serialVersionUID |
Constructor and Description |
---|
ReliableConnectionContext() |
Modifier and Type | Method and Description |
---|---|
private void |
add(ProxyMessage msg) |
int |
getHeartBeat() |
long |
getInputCounter() |
int |
getKey() |
AckedQueue |
getQueue() |
QueueWorker |
getQueueWorker() |
AbstractJmsRequest |
getRequest(Object obj) |
void |
initialize(int key,
OpenConnectionNot not) |
boolean |
isActive() |
boolean |
isClosed() |
boolean |
isNoAckedQueue() |
void |
pushError(MomException exc) |
void |
pushReply(AbstractJmsReply reply) |
void |
setActive(boolean active) |
public static Logger logger
private static final long serialVersionUID
private int key
private long inputCounter
private long outputCounter
private AckedQueue queue
private int heartBeat
private boolean closed
private boolean noAckedQueue
private QueueWorker queueWorker
private boolean active
public int getKey()
getKey
in interface ConnectionContext
public AckedQueue getQueue()
public int getHeartBeat()
public long getInputCounter()
public AbstractJmsRequest getRequest(Object obj)
getRequest
in interface ConnectionContext
public boolean isNoAckedQueue()
private void add(ProxyMessage msg)
public QueueWorker getQueueWorker()
public void pushReply(AbstractJmsReply reply)
pushReply
in interface ConnectionContext
public void pushError(MomException exc)
pushError
in interface ConnectionContext
public boolean isClosed()
isClosed
in interface ConnectionContext
public void initialize(int key, OpenConnectionNot not)
initialize
in interface ConnectionContext
public void setActive(boolean active)
public boolean isActive()
Copyright © 2023 ScalAgent D.T.. All rights reserved.