org.openorb.iiop
Class IIOPClientChannel

java.lang.Object
  org.openorb.iiop.IIOPClientChannel

All Implemented Interfaces:

Channel, ClientChannel

public class IIOPClientChannel

extends java.lang.Object

implements ClientChannel

Implements the ClientChannel interface for IIOP.

Version:

$Revision: 1.14 $ $Date: 2001/08/13 03:47:33 $

Author:

Chris Wood <wood@intalio.com>

Field Summary

Fields inherited from interface org.openorb.net.ClientChannel

STATE_CLOSED, STATE_CONNECTED, STATE_PAUSED

Method Summary

int	active_requests() Active request count.
int	channel_age() Indication of channel age.
void	close(boolean kill_requests, SystemException ex) Change to the CLOSED state and reject new requests by throwing a system exception with status COMPLETED_NO.
ClientRequest	create_locate_request(Object target, Address address, java.lang.Object tpAssc) Create a locate request.
ClientRequest	create_request(Object target, Address address, java.lang.Object tpAssc, java.lang.String operation, boolean response_expected) Create a request.
int	getTCSC() The selected char codeset.
int	getTCSW() The selected wide codeset.
ORB	orb() An orb reference.
void	pause() Begin the pausing sequence, enter the PAUSED state.
boolean	recv(int timeout) Wait the specified amount of time for an incoming message.
void	run_recv() Donate a thread for recieving messages.
int	state() Connection state.
java.lang.String	toString()
Version	version() Return the GIOP/IIOP version

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

toString

public java.lang.String toString()

version

public Version version()

Return the GIOP/IIOP version

getTCSC

public int getTCSC()

The selected char codeset.

getTCSW

public int getTCSW()

The selected wide codeset.

orb

public ORB orb()

Description copied from interface: ClientChannel

An orb reference.

Specified by:

orb in interface ClientChannel

state

public int state()

Connection state. Note that state values are 0x1000000 apart, Allowing this value to be ORed with the binding priority.

Specified by:

state in interface ClientChannel

active_requests

public int active_requests()

Active request count. This is the number of requests which have not yet been sent or are still expecting a reply.

Specified by:

active_requests in interface Channel

channel_age

public int channel_age()

Indication of channel age. This will result in a call to peek_request_id if active_requests would be non-zero, otherwise it returns whatever peek_request_id returned the last time active_requests dropped to zero.

Specified by:

channel_age in interface Channel

pause

public void pause()

Begin the pausing sequence, enter the PAUSED state. As soon as work_pending returns false this will close the connection.

Specified by:

pause in interface ClientChannel

close

public void close(boolean kill_requests,
                  SystemException ex)

Change to the CLOSED state and reject new requests by throwing a system exception with status COMPLETED_NO. If kill_requests is true, call cancel on any active ClientRequests, otherwise wait until they complete before closing.

Specified by:

close in interface ClientChannel

create_request

public ClientRequest create_request(Object target,
                                    Address address,
                                    java.lang.Object tpAssc,
                                    java.lang.String operation,
                                    boolean response_expected)
                             throws RebindChannelException

Create a request. If this is the first request on this channel then client_connect will be called on all ChannelInterceptor before returning the request. This may throw a system exception if the channel cannot establish a connection for some reason, for example INV_POLICY if client side policies prevent a successfull invocation, COMM_FAILURE if a communication problem occours, or REBIND if channel is temporaraly closed and a NO_REBIND policy is in effect.

Specified by:

create_request in interface ClientChannel

Parameters:

target - The target of the request.

address - The target address. If the target has been redirected this may not correspond to the target's ior.

Throws:

RebindChannelException

create_locate_request

public ClientRequest create_locate_request(Object target,
                                           Address address,
                                           java.lang.Object tpAssc)
                                    throws RebindChannelException

Create a locate request. This may throw a system exception if the channel cannot establish a connection for some reason, for example INV_POLICY if client side policies prevent a successfull invocation, COMM_FAILURE if a communication problem occours, or REBIND if channel is temporaraly closed and a NO_REBIND policy is in effect.

Specified by:

create_locate_request in interface ClientChannel

Parameters:

target - The target of the request.

address - The target address. If the target has been redirected this may not correspond to the target's ior.

Throws:

RebindChannelException

recv

public boolean recv(int timeout)

Wait the specified amount of time for an incoming message.

Specified by:

recv in interface Channel

run_recv

public void run_recv()

Donate a thread for recieving messages. This function returns when interrupt is called on the thread or the channel is closed.

Specified by:

run_recv in interface Channel