Package org.apache.uima.collection.impl.cpm.container.deployer.socket

Class OFSocketTransportImpl

java.lang.Object

org.apache.uima.collection.impl.cpm.container.deployer.socket.OFSocketTransportImpl

All Implemented Interfaces:

SocketTransport

public class OFSocketTransportImpl
extends Object
implements SocketTransport

The Class OFSocketTransportImpl.

Constructor Summary

Constructors

Constructor	Description
OFSocketTransportImpl()	Instantiates a new OF socket transport impl.

Method Summary

Modifier and Type	Method	Description
Socket	connect(URL aURI, long aTimeout)	Creates a socket connection to a given endpoint.
String	getName()	Returns transport identifier.
ProcessingResourceMetaData	getProcessingResourceMetaData(Socket aSocket)	Returns metadata associated with the fenced CasProcessor.
CAS	process(Socket aSocket, CAS aCas)	Invokes fenced CasProcessor.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OFSocketTransportImpl

public OFSocketTransportImpl()

Instantiates a new OF socket transport impl.

Method Details

getName

public String getName()

Description copied from interface: SocketTransport

Returns transport identifier.

Specified by:

getName in interface SocketTransport

Returns:

- String uniquely identifying the transport.

connect

public Socket connect(URL aURI,
 long aTimeout)
               throws SocketException

Description copied from interface: SocketTransport

Creates a socket connection to a given endpoint. This method blocks until all Connections are resolved or an error occurs.

Specified by:

connect in interface SocketTransport

Parameters:

aURI - URI containing service endpoint info: host & port

aTimeout - max time in millis to wait for response

Returns:

Socket bound to a given endpoint

Throws:

SocketException - Failed to connect

process

public CAS process(Socket aSocket,
 CAS aCas)
            throws SocketTimeoutException,
SocketException

Description copied from interface: SocketTransport

Invokes fenced CasProcessor.

Specified by:

process in interface SocketTransport

Parameters:

aSocket - - Socket bound to fenced CasProcessor

aCas - - CAS to be sent to the CasProcessor for analysis

Returns:

- CAS - CAS returned from the fenced CasProcessor

Throws:

SocketTimeoutException - the socket timeout exception

SocketException - the socket exception

getProcessingResourceMetaData

public ProcessingResourceMetaData getProcessingResourceMetaData(Socket aSocket)
                                                         throws SocketException

Description copied from interface: SocketTransport

Returns metadata associated with the fenced CasProcessor.

Specified by:

getProcessingResourceMetaData in interface SocketTransport

Parameters:

aSocket - - socket to the fenced CasProcessor

Returns:

- metadata

Throws:

SocketException - passthru