org.springframework.ws.transport.support

Class AbstractAsyncStandaloneMessageReceiver

java.lang.Object

org.springframework.ws.transport.support.WebServiceMessageReceiverObjectSupport

org.springframework.ws.transport.support.SimpleWebServiceMessageReceiverObjectSupport

org.springframework.ws.transport.support.AbstractStandaloneMessageReceiver

org.springframework.ws.transport.support.AbstractAsyncStandaloneMessageReceiver

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle

Direct Known Subclasses:

MailMessageReceiver

public abstract class AbstractAsyncStandaloneMessageReceiver
extends AbstractStandaloneMessageReceiver
implements org.springframework.beans.factory.BeanNameAware

Abstract base class for asynchronous standalone, server-side transport objects. Contains a Spring TaskExecutor, and various lifecycle callbacks.

Author:

Arjen Poutsma

Field Summary

Fields

Modifier and Type	Field and Description
String	DEFAULT_THREAD_NAME_PREFIX Default thread name prefix.

Fields inherited from class org.springframework.ws.transport.support.WebServiceMessageReceiverObjectSupport

logger

Constructor Summary

Constructors

Constructor and Description
AbstractAsyncStandaloneMessageReceiver()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet() Calls AbstractStandaloneMessageReceiver.activate() when the BeanFactory initializes the receiver instance.
protected org.springframework.core.task.TaskExecutor	createDefaultTaskExecutor() Create a default TaskExecutor.
protected void	execute(Runnable runnable) Executes the given Runnable via this receiver's TaskExecutor.
void	setBeanName(String beanName)
void	setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor) Set the Spring TaskExecutor to use for running the listener threads.

Methods inherited from class org.springframework.ws.transport.support.AbstractStandaloneMessageReceiver

activate, destroy, isActive, isRunning, onActivate, onShutdown, onStart, onStop, setAutoStartup, shutdown, start, stop

Methods inherited from class org.springframework.ws.transport.support.SimpleWebServiceMessageReceiverObjectSupport

getMessageReceiver, handleConnection, setMessageReceiver

Methods inherited from class org.springframework.ws.transport.support.WebServiceMessageReceiverObjectSupport

getMessageFactory, handleConnection, handleNoEndpointFoundException, setMessageFactory

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_THREAD_NAME_PREFIX

public final String DEFAULT_THREAD_NAME_PREFIX

Default thread name prefix.

Constructor Detail

AbstractAsyncStandaloneMessageReceiver

public AbstractAsyncStandaloneMessageReceiver()

Method Detail

setTaskExecutor

public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)

Set the Spring TaskExecutor to use for running the listener threads. Default is SimpleAsyncTaskExecutor, starting up a number of new threads.

Specify an alternative task executor for integration with an existing thread pool, such as the org.springframework.scheduling.commonj.WorkManagerTaskExecutor to integrate with WebSphere or WebLogic.

setBeanName

public void setBeanName(String beanName)

Specified by:

setBeanName in interface org.springframework.beans.factory.BeanNameAware

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Description copied from class: AbstractStandaloneMessageReceiver

Calls AbstractStandaloneMessageReceiver.activate() when the BeanFactory initializes the receiver instance.

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Overrides:

afterPropertiesSet in class AbstractStandaloneMessageReceiver

Throws:

Exception

createDefaultTaskExecutor

protected org.springframework.core.task.TaskExecutor createDefaultTaskExecutor()

Create a default TaskExecutor. Called if no explicit TaskExecutor has been specified.

The default implementation builds a SimpleAsyncTaskExecutor with the specified bean name (or the class name, if no bean name specified) as thread name prefix.

See Also:

SimpleAsyncTaskExecutor.SimpleAsyncTaskExecutor(String)

execute

protected void execute(Runnable runnable)

Executes the given Runnable via this receiver's TaskExecutor.

See Also:

setTaskExecutor(TaskExecutor)