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:

java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable, org.jacorb.config.Configurable

public class ClientGIOPConnection
extends GIOPConnection
implements org.jacorb.config.Configurable

Version:

$Id: ClientGIOPConnection.java,v 1.19 2009-04-25 10:10:36 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, statistics_provider_adapter, transport

Constructor Summary

Constructors

Constructor and Description
ClientGIOPConnection(Profile profile, Connection transport, RequestListener request_listener, ReplyListener reply_listener, StatisticsProvider statistics_provider)

Method Summary

Modifier and Type	Method and Description
void	closeAllowReopen() Closes the underlying transport, but keeps this ClientGIOPConnection alive.
void	configure(org.jacorb.config.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, getStatisticsProvider, getStatisticsProviderAdapter, getTCS, getTCSW, getTransport, getWriteLock, hasPendingMessages, incPendingMessages, isSSL, isTCSNegotiated, markTCSNegotiated, receiveMessages, releaseWriteLock, sendReply, sendRequest, set_cubby, setCodeSets, 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.jacorb.config.Configuration configuration)
               throws org.jacorb.config.ConfigurationException

Specified by:

configure in interface org.jacorb.config.Configurable

Overrides:

configure in class GIOPConnection

Throws:

org.jacorb.config.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()

Overrides:

toString in class java.lang.Object