com.adaptris.core.lifecycle

Class NonBlockingChannelStartStrategy

java.lang.Object

com.adaptris.core.DefaultChannelLifecycleStrategy

com.adaptris.core.lifecycle.NonBlockingChannelStartStrategy

All Implemented Interfaces:

ChannelLifecycleStrategy

public class NonBlockingChannelStartStrategy
extends DefaultChannelLifecycleStrategy

Non Blocking start strategy for channels.

This strategy attempts to start each channel in a non-blocking manner through the use of an ExecutorService for each channel.

If this strategy is chosen then it is possible that AdapterLifecycleEvents will be generated that do not accurately reflect the internal state of the Adapter.

In the adapter configuration file this class is aliased as non-blocking-channel-start-strategy which is the preferred alternative to the fully qualified classname when building your configuration.

Field Summary

Fields inherited from class com.adaptris.core.DefaultChannelLifecycleStrategy

log

Constructor Summary

Constructors

Constructor and Description
NonBlockingChannelStartStrategy()

Method Summary

Modifier and Type	Method and Description
void	close(java.util.List<Channel> channels) Close a list of channels.
void	init(java.util.List<Channel> channels) Initialise a list of channels.
void	start(java.util.List<Channel> channels) Start a list of channels.
void	stop(java.util.List<Channel> channels) Stop a list of channels.

Methods inherited from class java.lang.Object

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

Constructor Detail

NonBlockingChannelStartStrategy

public NonBlockingChannelStartStrategy()

Method Detail

start

public void start(java.util.List<Channel> channels)
           throws CoreException

Description copied from interface: ChannelLifecycleStrategy

Start a list of channels.

Specified by:

start in interface ChannelLifecycleStrategy

Overrides:

start in class DefaultChannelLifecycleStrategy

Parameters:

channels - a list of channels that have already been initialised.

Throws:

CoreException - wrapping any underlying exception.

See Also:

ChannelLifecycleStrategy.start(java.util.List)

init

public void init(java.util.List<Channel> channels)
          throws CoreException

Description copied from interface: ChannelLifecycleStrategy

Initialise a list of channels.

Specified by:

init in interface ChannelLifecycleStrategy

Overrides:

init in class DefaultChannelLifecycleStrategy

Parameters:

channels - a list of channels that require initialising.

Throws:

CoreException - wrapping any underlying exception.

See Also:

ChannelLifecycleStrategy.init(java.util.List)

stop

public void stop(java.util.List<Channel> channels)

Description copied from interface: ChannelLifecycleStrategy

Stop a list of channels.

Specified by:

stop in interface ChannelLifecycleStrategy

Overrides:

stop in class DefaultChannelLifecycleStrategy

Parameters:

channels - a list of channels that have previously been started.

See Also:

ChannelLifecycleStrategy.stop(java.util.List)

close

public void close(java.util.List<Channel> channels)

Description copied from interface: ChannelLifecycleStrategy

Close a list of channels.

Specified by:

close in interface ChannelLifecycleStrategy

Overrides:

close in class DefaultChannelLifecycleStrategy

Parameters:

channels - a list of channels.

See Also:

ChannelLifecycleStrategy.close(java.util.List)