com.neeve.sma.spi.executor

Class AbstractExecutorBusProcessorFactory

java.lang.Object

com.neeve.sma.spi.executor.AbstractExecutorBusProcessorFactory

public abstract class AbstractExecutorBusProcessorFactory
extends Object

A factory class allowing an Executor Bus implementation to create the application provided ExecutorBusProcessor.

Implementations must provide a zero argument constructor for the factory to allow it to be instantiated by the executor bus binding.

Each bus of type executor must define the property to allow a processor to be provided to the executor bus. A factory does not necessarily need to instantiate a new processor when this is called, it may through some static mechanism return an already existing class that implements the ExecutorBusProcessor.

Constructor Summary

Constructors

Constructor and Description
AbstractExecutorBusProcessorFactory() Subclasses are expected to provide a zero argument public constructor as well.

Method Summary

Modifier and Type	Method and Description
abstract ExecutorBusProcessor	createExecutorBusProcessor(MessageBusBinding binding) Create the executor bus processor for the given message bus binding.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractExecutorBusProcessorFactory

public AbstractExecutorBusProcessorFactory()

Subclasses are expected to provide a zero argument public constructor as well.

Method Detail

createExecutorBusProcessor

public abstract ExecutorBusProcessor createExecutorBusProcessor(MessageBusBinding binding)

Create the executor bus processor for the given message bus binding.

For applications that use multiple executor buses with different processing semantics the factory can return different process implementations. A factory may inspect the following from the binding in determining what processor to return:

• The binding's MessageBusDescriptor via the binding's getDescriptor() method and use it to return the appropriate processor type.
• The binding's userName retrieved via getUserName() to determine the user that created the bus. A Rumi AepEngine for example will use the application name as the user name for a bus.

retrieve the binding's MessageBusDescriptor via the binding's getDescriptor() method and use it to return the appropriate processor type.

Parameters:

binding - The executor bus binding.

Returns:

An ExecutorBusProcessor for the given executor bus.