connect_sync
protected Object connect_sync
discard_messages
protected boolean discard_messages
do_close
protected boolean do_close
pendingUndecidedSync
protected Object pendingUndecidedSync
allocate_cubby_id
public static int allocate_cubby_id()
configure
public void configure(Configuration configuration)
throws ConfigurationException
decPendingMessages
public final void decPendingMessages()
flush
public final void flush()
throws java.io.IOException
getRequestListener
protected final RequestListener getRequestListener()
Get the value of request_listener.
- value of request_listener.
getStatisticsProvider
public final StatisticsProvider getStatisticsProvider()
Get the statistics provider for transport usage statistics.
getTCS
public final int getTCS()
getTCSW
public final int getTCSW()
getTransport
public final Connection getTransport()
getWriteLock
protected final void getWriteLock()
get_cubby
public Object get_cubby(int id)
hasPendingMessages
public final boolean hasPendingMessages()
incPendingMessages
public final void incPendingMessages()
isSSL
public final boolean isSSL()
isTCSNegotiated
public final boolean isTCSNegotiated()
markTCSNegotiated
public final void markTCSNegotiated()
readTimedOut
protected void readTimedOut()
receiveMessages
public final void receiveMessages()
throws IOException
releaseWriteLock
protected final void releaseWriteLock()
sendRequest
public final void sendRequest(MessageOutputStream out,
boolean expect_reply)
throws IOException
setCodeSets
public final void setCodeSets(int TCS,
int TCSW)
setConnectionListener
public final void setConnectionListener(ConnectionListener connection_listener)
setReplyListener
public final void setReplyListener(ReplyListener v)
Set the value of reply_listener.
v
- Value to assign to reply_listener.
setRequestListener
public final void setRequestListener(RequestListener v)
Set the value of request_listener.
v
- Value to assign to request_listener.
set_cubby
public void set_cubby(int id,
Object obj)
streamClosed
protected void streamClosed()
write
public final void write(byte[] b)
throws java.io.IOException
write
public final void write(byte[] fragment,
int start,
int size)
write (a fragment of) the message (passes it on to the wire)
write
public final void write(int i)
throws java.io.IOException