org.jacorb.orb.giop
Class ClientGIOPConnection
java.lang.Object
java.io.OutputStream
org.jacorb.orb.giop.GIOPConnection
org.jacorb.orb.giop.ClientGIOPConnection
- All Implemented Interfaces:
- org.apache.avalon.framework.configuration.Configurable
- public class ClientGIOPConnection
- extends GIOPConnection
- implements org.apache.avalon.framework.configuration.Configurable
- Version:
- $Id: ClientGIOPConnection.java,v 1.15 2005/10/31 11:28:56 andre.spiegel Exp $
- Author:
- Nicolas Noffke
Method Summary |
void |
closeAllowReopen()
Closes the underlying transport, but keeps this ClientGIOPConnection
alive. |
void |
configure(org.apache.avalon.framework.configuration.Configuration configuration)
|
protected void |
readTimedOut()
Client-side implementation what to do when a read on the
underlying transport times out. |
protected void |
streamClosed()
Client-side implementation what to do when the underlying transport
is closed during a read operation. |
java.lang.String |
toString()
|
Methods inherited from class org.jacorb.orb.giop.GIOPConnection |
allocate_cubby_id, close, decPendingMessages, flush, get_cubby, getRequestListener, getStatisticsProvider, getTCS, getTCSW, getTransport, getWriteLock, hasPendingMessages, incPendingMessages, isSSL, isTCSNegotiated, markTCSNegotiated, receiveMessages, releaseWriteLock, sendReply, sendRequest, set_cubby, setCodeSets, setConnectionListener, setReplyListener, setRequestListener, write, write, write |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
ClientGIOPConnection
public ClientGIOPConnection(Profile profile,
Connection transport,
RequestListener request_listener,
ReplyListener reply_listener,
StatisticsProvider statistics_provider)
configure
public void configure(org.apache.avalon.framework.configuration.Configuration configuration)
throws org.apache.avalon.framework.configuration.ConfigurationException
- Specified by:
configure
in interface org.apache.avalon.framework.configuration.Configurable
- Overrides:
configure
in class GIOPConnection
- Throws:
org.apache.avalon.framework.configuration.ConfigurationException
readTimedOut
protected void readTimedOut()
- Client-side implementation what to do when a read on the
underlying transport times out. If we have no pending messages
for which we haven't received a reply yet, or if the property
jacorb.connection.client.timeout_ignores_pending_messages is on,
then we close the transport, but allow it to be reopened later.
If we have pending message and are not allowed to ignore that,
do nothing.
- Specified by:
readTimedOut
in class GIOPConnection
streamClosed
protected void streamClosed()
- Client-side implementation what to do when the underlying transport
is closed during a read operation. We mark the transport as closed
and allow it to be reopened later, when the client retries.
- Specified by:
streamClosed
in class GIOPConnection
closeAllowReopen
public void closeAllowReopen()
- Closes the underlying transport, but keeps this ClientGIOPConnection
alive. If, subsequently, another request is sent to this connection,
it will try to reopen the transport.
toString
public java.lang.String toString()