org.objectweb.joram.client.jms.tcp
Class ReliableTcpConnection
java.lang.Object
org.objectweb.joram.client.jms.tcp.ReliableTcpConnection
public class ReliableTcpConnection
- extends java.lang.Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
INIT
public static final int INIT
- See Also:
- Constant Field Values
CONNECT
public static final int CONNECT
- See Also:
- Constant Field Values
CONNECTING
public static final int CONNECTING
- See Also:
- Constant Field Values
statusNames
public static final java.lang.String[] statusNames
logger
public static org.objectweb.util.monolog.api.Logger logger
WINDOW_SIZE_PROP_NAME
public static java.lang.String WINDOW_SIZE_PROP_NAME
DEFAULT_WINDOW_SIZE
public static int DEFAULT_WINDOW_SIZE
windowSize
private int windowSize
inputCounter
private volatile long inputCounter
outputCounter
private long outputCounter
unackCounter
private volatile int unackCounter
pendingMessages
private java.util.Vector pendingMessages
sock
private java.net.Socket sock
nos
private ReliableTcpConnection.NetOutputStream nos
bis
private java.io.BufferedInputStream bis
inputLock
private java.lang.Object inputLock
outputLock
private java.lang.Object outputLock
status
private int status
timer
private java.util.Timer timer
ReliableTcpConnection
public ReliableTcpConnection(java.util.Timer timer2)
setStatus
private void setStatus(int status)
getStatus
private final int getStatus()
init
public void init(java.net.Socket sock)
throws java.io.IOException
- Throws:
java.io.IOException
send
public void send(AbstractJmsMessage request)
throws java.io.IOException
- Throws:
java.io.IOException
doSend
private void doSend(long id,
long ackId,
AbstractJmsMessage msg)
throws java.io.IOException
- Throws:
java.io.IOException
addPendingMessage
private void addPendingMessage(ReliableTcpConnection.TcpMessage msg)
ackPendingMessages
private void ackPendingMessages(long ackId)
receive
public AbstractJmsReply receive()
throws java.lang.Exception
- Throws:
java.lang.Exception
close
public void close()
Copyright © 2010 ScalAgent D.T.. All Rights Reserved.