org.jacorb.orb.giop
Class ClientGIOPConnection

java.lang.Object
  extended byjava.io.OutputStream
      extended byorg.jacorb.orb.giop.GIOPConnection
          extended byorg.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

Field Summary
 
Fields inherited from class org.jacorb.orb.giop.GIOPConnection
connect_sync, connection_listener, discard_messages, do_close, logger, pendingUndecidedSync, profile, statistics_provider, transport
 
Constructor Summary
ClientGIOPConnection(Profile profile, Connection transport, RequestListener request_listener, ReplyListener reply_listener, StatisticsProvider statistics_provider)
           
 
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
 

Constructor Detail

ClientGIOPConnection

public ClientGIOPConnection(Profile profile,
                            Connection transport,
                            RequestListener request_listener,
                            ReplyListener reply_listener,
                            StatisticsProvider statistics_provider)
Method Detail

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()