com.ibm.ulc.corba
Class UlcCorbaBasedTransport
java.lang.Object
|
+--com.ibm.ulc.comm.UlcTransport
|
+--com.ibm.ulc.corba.UlcCorbaBasedTransport
- Direct Known Subclasses:
- UlcCorbaTransport
- public class UlcCorbaBasedTransport
- extends UlcTransport
An implemention for ULC transports using CORBA.
- See Also:
UlcTransport
, Serialized Form
Method Summary |
java.lang.String |
getLocalUrlString()
Return an URL String describing this transports local endpoint. |
static org.omg.CORBA.ORB |
getOrb()
|
protected void |
initPeerConnection()
Initialize connection to peer if necessary. |
boolean |
readsAsynch()
Does the transport asynchronous reads itself?
Otherwise it inherits the automatic asynchronous read support
of this class by overriding readRequests(). |
protected void |
sendDirect(Request r,
boolean flush)
Sends a request directly (without using WriterThread) |
UlcCorbaServant |
startReceiver()
|
com.ibm.ulc.corba.generated.UlcCorbaObject |
startSender()
|
void |
stopReceiver()
|
void |
stopSender()
|
protected void |
termPeerConnection()
Method to perform connection termination with peer. |
boolean |
writesAsynch()
Does the transport asynchronous writes itself?
Otherwise it inherits the automatic asynchronous write support
of this class by overriding writeRequests(). |
Methods inherited from class com.ibm.ulc.comm.UlcTransport |
close,
create,
flushWriter,
getConnection,
getHost,
getPort,
getProperties,
getRemoteUrlString,
getUrlFile,
getUrlString,
readRequests,
receive,
send,
setConnection,
setUrlString,
start,
writeRequests |
Methods inherited from class java.lang.Object |
clone,
equals,
finalize,
getClass,
hashCode,
notify,
notifyAll,
toString,
wait,
wait,
wait |
fReceiver
public UlcCorbaServant fReceiver
fSender
public com.ibm.ulc.corba.generated.UlcCorbaObject fSender
fReceiverIOR
public java.lang.String fReceiverIOR
UlcCorbaBasedTransport
public UlcCorbaBasedTransport()
- UlcCorbaTransport constructor.
UlcCorbaBasedTransport
public UlcCorbaBasedTransport(com.ibm.ulc.corba.generated.UlcCorbaObject sender,
UlcCorbaServant receiver,
java.lang.String receiverIOR)
- UlcCorbaTransport constructor.
Will use the passed in Corba client object.
- Parameters:
sender
- com.ibm.ulc.corba.UlcCorbaObjectreceiver
- com.ibm.ulc.corba.UlcCorbaServantreceiverIOR
- java.lang.String
UlcCorbaBasedTransport
public UlcCorbaBasedTransport(java.lang.String urlString)
- UlcCorbaTransport constructor.
Will use the passed in URL to create a connection to a Corba servant object.
- Parameters:
urlString
- java.lang.String
getLocalUrlString
public java.lang.String getLocalUrlString()
- Description copied from class: UlcTransport
- Return an URL String describing this transports local endpoint.
- Overrides:
- getLocalUrlString in class UlcTransport
getOrb
public static org.omg.CORBA.ORB getOrb()
initPeerConnection
protected void initPeerConnection()
throws UlcTransportException
- Initialize connection to peer if necessary.
- Overrides:
- initPeerConnection in class UlcTransport
readsAsynch
public boolean readsAsynch()
- Description copied from class: UlcTransport
- Does the transport asynchronous reads itself?
Otherwise it inherits the automatic asynchronous read support
of this class by overriding readRequests().
- Overrides:
- readsAsynch in class UlcTransport
sendDirect
protected void sendDirect(Request r,
boolean flush)
- Description copied from class: UlcTransport
- Sends a request directly (without using WriterThread)
- Overrides:
- sendDirect in class UlcTransport
startReceiver
public UlcCorbaServant startReceiver()
throws UlcTransportException
startSender
public com.ibm.ulc.corba.generated.UlcCorbaObject startSender()
throws UlcTransportException
stopReceiver
public void stopReceiver()
stopSender
public void stopSender()
termPeerConnection
protected void termPeerConnection()
- Description copied from class: UlcTransport
- Method to perform connection termination with peer.
- Overrides:
- termPeerConnection in class UlcTransport
writesAsynch
public boolean writesAsynch()
- Description copied from class: UlcTransport
- Does the transport asynchronous writes itself?
Otherwise it inherits the automatic asynchronous write support
of this class by overriding writeRequests().
- Overrides:
- writesAsynch in class UlcTransport