public class OFSocketTransportImpl extends Object implements SocketTransport
Constructor and Description |
---|
OFSocketTransportImpl() |
Modifier and Type | Method and 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.
|
public String getName()
SocketTransport
getName
in interface SocketTransport
public Socket connect(URL aURI, long aTimeout) throws SocketException
SocketTransport
connect
in interface SocketTransport
aURI
- - URI containing service endpoint info: host&portaTimeout
- - max time in millis to wait for responseSocketException
public CAS process(Socket aSocket, CAS aCas) throws SocketTimeoutException, SocketException
SocketTransport
process
in interface SocketTransport
aSocket
- - Socket bound to fenced CasProcessoraCas
- - CAS to be sent to the CasProcessor for analysisSocketTimeoutException
SocketException
public ProcessingResourceMetaData getProcessingResourceMetaData(Socket aSocket) throws SocketException
SocketTransport
getProcessingResourceMetaData
in interface SocketTransport
aSocket
- -
socket to the fenced CasProcessorSocketException
- passthruCopyright © 2014. All rights reserved.