com.adaptris.core.services.splitter

Class PoolingSplitJoinService

java.lang.Object

com.adaptris.core.ServiceImp

com.adaptris.core.services.splitter.SplitJoinService

com.adaptris.core.services.splitter.PoolingSplitJoinService

All Implemented Interfaces:

AdaptrisComponent, ComponentLifecycle, ComponentLifecycleExtension, EventHandlerAware, MessageEventGenerator, Service, ServiceWrapper, StateManagedComponent

Deprecated.

since 3.11.1 Use PooledSplitJoinService instead; since performance characteristics are unpredictable in constrained environments

@Deprecated
 @ComponentProfile(summary="Split a message and then execute the associated services on the split items, aggregating the split messages afterwards",
                  tag="service,splitjoin",
                  since="3.7.1")
 @ConfigDeprecated(removalVersion="4.0.0",
                  message="Use pooled-split-join-service instead; since performance characteristics are unpredictable in constrained environments",
                  groups=java.lang.Deprecated.class)
public class PoolingSplitJoinService
extends SplitJoinService

Variant of SplitJoinService that uses a underlying thread and object pool to execute the service on each split message.

This service splits a message according to the configured MessageSplitter implementation, executes the configured Service and subsequently joins all the messages back using the configured MessageAggregator implementation

This differs from SplitJoinService in that a pool of Service instances is maintained and re-used for each message; so the high cost of initialisation for the service, is not incurred (more than the max number of threads specified) as much.

In the adapter configuration file this class is aliased as pooling-split-join-service which is the preferred alternative to the fully qualified classname when building your configuration.

Field Summary

Fields inherited from class com.adaptris.core.ServiceImp

log

Constructor Summary

Constructors

Constructor and Description
PoolingSplitJoinService() Deprecated.

Method Summary

Modifier and Type	Method and Description
protected java.util.List<java.util.concurrent.Callable<AdaptrisMessage>>	buildTasks(ServiceExceptionHandler handler, java.util.List<AdaptrisMessage> msgs) Deprecated.
void	closeService() Deprecated.
protected java.util.concurrent.ExecutorService	createExecutor() Deprecated.
java.lang.Integer	getMaxThreads() Deprecated.
java.lang.Boolean	getWarmStart() Deprecated.
void	initService() Deprecated.
void	prepare() Deprecated. Prepare for initialisation.
void	setMaxThreads(java.lang.Integer size) Deprecated. Set the max number of threads to handle the execution of the split messages.
void	setWarmStart(java.lang.Boolean b) Deprecated. Specify if the underlying object pool should be warmed up on start().
void	start() Deprecated. Starts the component.
PoolingSplitJoinService	withMaxThreads(java.lang.Integer max) Deprecated.
PoolingSplitJoinService	withWarmStart(java.lang.Boolean b) Deprecated.

Methods inherited from class com.adaptris.core.services.splitter.SplitJoinService

doService, getAggregator, getSendEvents, getService, getSplitter, getTimeout, registerEventHandler, sendEvents, sendEvents, setAggregator, setExceptionStrategy, setSendEvents, setService, setSplitter, setTimeout, wrappedServices

Methods inherited from class com.adaptris.core.ServiceImp

changeState, close, continueOnFailure, createName, createQualifier, getContinueOnFail, getIsTrackingEndpoint, getUniqueId, init, isBranching, isTrackingEndpoint, requestClose, requestInit, requestStart, requestStop, retrieveComponentState, setContinueOnFail, setIsTrackingEndpoint, setUniqueId, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.adaptris.core.Service

continueOnFailure, isBranching, setUniqueId

Methods inherited from interface com.adaptris.core.MessageEventGenerator

createName, createQualifier, isTrackingEndpoint

Methods inherited from interface com.adaptris.core.StateManagedComponent

changeState, requestClose, requestInit, requestStart, requestStop, retrieveComponentState

Methods inherited from interface com.adaptris.core.AdaptrisComponent

getUniqueId

Methods inherited from interface com.adaptris.core.ComponentLifecycle

close, init, stop

Constructor Detail

PoolingSplitJoinService

public PoolingSplitJoinService()

Deprecated.

Method Detail

prepare

public void prepare()
             throws CoreException

Deprecated.

Description copied from interface: ComponentLifecycleExtension

Prepare for initialisation.

Specified by:

prepare in interface ComponentLifecycleExtension

Overrides:

prepare in class SplitJoinService

Throws:

CoreException

initService

public void initService()
                 throws CoreException

Deprecated.

Overrides:

initService in class SplitJoinService

Throws:

CoreException

start

public void start()
           throws CoreException

Deprecated.

Description copied from interface: ComponentLifecycle

Starts the component.

Once a component is started it should be ready to process messages. In the case of AdaptrisMessageConsumer, calling start will begin message delivery.

Specified by:

start in interface ComponentLifecycle

Overrides:

start in class ServiceImp

Throws:

CoreException - wrapping any underlying Exceptions

closeService

public void closeService()

Deprecated.

Overrides:

closeService in class SplitJoinService

buildTasks

protected java.util.List<java.util.concurrent.Callable<AdaptrisMessage>> buildTasks(ServiceExceptionHandler handler,
                                                                                    java.util.List<AdaptrisMessage> msgs)
                                                                             throws java.lang.Exception

Deprecated.

Overrides:

buildTasks in class SplitJoinService

Throws:

java.lang.Exception

createExecutor

protected java.util.concurrent.ExecutorService createExecutor()

Deprecated.

Overrides:

createExecutor in class SplitJoinService

getMaxThreads

public java.lang.Integer getMaxThreads()

Deprecated.

setMaxThreads

public void setMaxThreads(java.lang.Integer size)

Deprecated.

Set the max number of threads to handle the execution of the split messages.

Parameters:

size - the max number of threads, defaults to 10 if not specified.

withMaxThreads

public PoolingSplitJoinService withMaxThreads(java.lang.Integer max)

Deprecated.

getWarmStart

public java.lang.Boolean getWarmStart()

Deprecated.

setWarmStart

public void setWarmStart(java.lang.Boolean b)

Deprecated.

Specify if the underlying object pool should be warmed up on start().

Parameters:

b - true or false (default false if not specified).

withWarmStart

public PoolingSplitJoinService withWarmStart(java.lang.Boolean b)

Deprecated.