public class SocketFactory extends Object implements TransportFactory
TransportFactory
for the socket-based transport.TransportFactory.ConnectorInfo
Constructor and Description |
---|
SocketFactory() |
Modifier and Type | Method and Description |
---|---|
InPushConnector |
createInPushConnector(Properties properties,
ConverterSelectionStrategy<?> converters)
Creates an in connector for receiving events in an asynchronous fashion.
|
OutConnector |
createOutConnector(Properties properties,
ConverterSelectionStrategy<?> converters)
Creates an out connector for sending events.
|
TransportFactory.ConnectorInfo |
getInfo()
Returns information aobut the transport for which this factory
constructs connectors.
|
public TransportFactory.ConnectorInfo getInfo()
TransportFactory
getInfo
in interface TransportFactory
public OutConnector createOutConnector(Properties properties, ConverterSelectionStrategy<?> converters) throws InitializeException
TransportFactory
createOutConnector
in interface TransportFactory
properties
- specific options for the connector to be createdconverters
- the converter selection strategy to use in the new connectorInitializeException
- error creating a new connectorpublic InPushConnector createInPushConnector(Properties properties, ConverterSelectionStrategy<?> converters) throws InitializeException
TransportFactory
createInPushConnector
in interface TransportFactory
properties
- specific options for the connector to be createdconverters
- the converter selection strategy to use in the new connectorInitializeException
- error creating a new connectorCopyright © 2018 CoR-Lab. All rights reserved.