rsb.transport.spread

Class SpreadFactory

java.lang.Object

rsb.transport.spread.SpreadFactory

All Implemented Interfaces:

TransportFactory

public class SpreadFactory
extends Object
implements TransportFactory

A TransportFactory implementation for the spread transport.

Author:

jwienke, swrede

Constructor Summary

Constructors

Constructor and Description
SpreadFactory()

Method Summary

Methods

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

SpreadFactory

public SpreadFactory()

Method Detail

createInPushConnector

public InPushConnector createInPushConnector(Properties properties,
                                    ConverterSelectionStrategy<?> converters)
                                      throws InitializeException

Description copied from interface: TransportFactory

Creates an in connector for receiving events in an asynchronous fashion.

Specified by:

createInPushConnector in interface TransportFactory

Parameters:

properties - specific options for the connector to be created

converters - the converter selection strategy to use in the new connector

Returns:

new connector instance

Throws:

InitializeException - error creating a new connector

createOutConnector

public OutConnector createOutConnector(Properties properties,
                              ConverterSelectionStrategy<?> converters)
                                throws InitializeException

Description copied from interface: TransportFactory

Creates an out connector for sending events.

Specified by:

createOutConnector in interface TransportFactory

Parameters:

properties - specific options for the connector to be created

converters - the converter selection strategy to use in the new connector

Returns:

new connector instance

Throws:

InitializeException - error creating a new connector