java.lang.Object
- org.objectweb.joram.mom.proxies.ReliableConnectionContext

All Implemented Interfaces:

Serializable, ConnectionContext
```
public class ReliableConnectionContext
extends Object
implements ConnectionContext, Serializable
```
Reliable implementation of the interface to abstract the communication between the client and the MOM.

See Also:

Serialized Form

Nested Class Summary
- Nested classes/interfaces inherited from interface org.objectweb.joram.mom.proxies.ConnectionContext
  ConnectionContext.Type

Field Summary

Fields
Modifier and Type	Field	Description
`private boolean`	`active`
`private boolean`	`closed`
`private int`	`heartBeat`
`private long`	`inputCounter`
`private int`	`key`
`private static Logger`	`logger`
`private boolean`	`noAckedQueue`
`private long`	`outputCounter`
`private AckedQueue`	`queue`
`private QueueWorker`	`queueWorker`
`private static long`	`serialVersionUID`

Constructor Summary

Constructors
Constructor Description

ReliableConnectionContext()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger
```
private static final Logger logger
```

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
```

closed
```
private boolean closed
```

noAckedQueue
```
private boolean noAckedQueue
```

queueWorker
```
private QueueWorker queueWorker
```

active
```
private boolean active
```

Constructor Detail
- ReliableConnectionContext
```
public ReliableConnectionContext()
```

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(Object obj)
```
Specified by:

getRequest in interface ConnectionContext

isNoAckedQueue
```
public boolean isNoAckedQueue()
```

add

private void add(ProxyMessage msg)

getQueueWorker
```
public QueueWorker getQueueWorker()
```

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

initialize

public void initialize(int key,
                       OpenConnectionNot not)

Specified by:: initialize in interface ConnectionContext

setActive

public void setActive(boolean active)

isActive
```
public boolean isActive()
```

Class ReliableConnectionContext

Nested Class Summary

Nested classes/interfaces inherited from interface org.objectweb.joram.mom.proxies.ConnectionContext

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

logger

serialVersionUID

key

inputCounter

outputCounter

queue

heartBeat

closed

noAckedQueue

queueWorker

active

Constructor Detail

ReliableConnectionContext

Method Detail

getKey

getQueue

getHeartBeat

getInputCounter

getRequest

isNoAckedQueue

add

getQueueWorker

pushReply

pushError

isClosed

initialize

setActive

isActive