org.springframework.messaging.core

Class GenericMessagingTemplate

java.lang.Object

org.springframework.messaging.core.AbstractMessageSendingTemplate<D>

org.springframework.messaging.core.AbstractMessagingTemplate<D>

org.springframework.messaging.core.AbstractDestinationResolvingMessagingTemplate<MessageChannel>

org.springframework.messaging.core.GenericMessagingTemplate

All Implemented Interfaces:

Aware, BeanFactoryAware, DestinationResolvingMessageReceivingOperations<MessageChannel>, DestinationResolvingMessageRequestReplyOperations<MessageChannel>, DestinationResolvingMessageSendingOperations<MessageChannel>, MessageReceivingOperations<MessageChannel>, MessageRequestReplyOperations<MessageChannel>, MessageSendingOperations<MessageChannel>

public class GenericMessagingTemplate
extends AbstractDestinationResolvingMessagingTemplate<MessageChannel>
implements BeanFactoryAware

Since:

4.0

Author:

Mark Fisher

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	GenericMessagingTemplate.TemporaryReplyChannel

Field Summary

Fields

Modifier and Type	Field and Description
private long	receiveTimeout
private long	sendTimeout
private boolean	throwExceptionOnLateReply

Fields inherited from class org.springframework.messaging.core.AbstractMessageSendingTemplate

logger

Constructor Summary

Constructors

Constructor and Description
GenericMessagingTemplate()

Method Summary

Modifier and Type	Method and Description
protected <P> Message<P>	doReceive(MessageChannel destination)
protected void	doSend(MessageChannel destination, Message<?> message)
protected <S,R> Message<R>	doSendAndReceive(MessageChannel destination, Message<S> requestMessage)
void	setBeanFactory(BeanFactory beanFactory) Callback that supplies the owning factory to a bean instance.
void	setReceiveTimeout(long receiveTimeout) Specify the timeout value to use for receive operations.
void	setSendTimeout(long sendTimeout) Specify the timeout value to use for send operations.
void	setThrowExceptionOnLateReply(boolean throwExceptionOnLateReply) Specify whether or not an attempt to send on the reply channel throws an exception if no receiving thread will actually receive the reply.

Methods inherited from class org.springframework.messaging.core.AbstractDestinationResolvingMessagingTemplate

convertAndSend, convertAndSend, convertSendAndReceive, convertSendAndReceive, receive, receiveAndConvert, resolveDestination, send, sendAndReceive, setDestinationResolver

Methods inherited from class org.springframework.messaging.core.AbstractMessagingTemplate

convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, receive, receive, receiveAndConvert, receiveAndConvert, sendAndReceive, sendAndReceive

Methods inherited from class org.springframework.messaging.core.AbstractMessageSendingTemplate

convertAndSend, convertAndSend, convertAndSend, convertAndSend, getConverter, getDefaultDestination, getRequiredDefaultDestination, send, send, setConverter, setDefaultDestination, setMessageConverter

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.messaging.core.MessageSendingOperations

convertAndSend, convertAndSend, convertAndSend, convertAndSend, send, send

Methods inherited from interface org.springframework.messaging.core.MessageReceivingOperations

receive, receive, receiveAndConvert, receiveAndConvert

Methods inherited from interface org.springframework.messaging.core.MessageRequestReplyOperations

convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, sendAndReceive, sendAndReceive

Field Detail

sendTimeout

private volatile long sendTimeout

receiveTimeout

private volatile long receiveTimeout

throwExceptionOnLateReply

private volatile boolean throwExceptionOnLateReply

Constructor Detail

GenericMessagingTemplate

public GenericMessagingTemplate()

Method Detail

setSendTimeout

public void setSendTimeout(long sendTimeout)

Specify the timeout value to use for send operations.

Parameters:

sendTimeout - the send timeout in milliseconds

setReceiveTimeout

public void setReceiveTimeout(long receiveTimeout)

Specify the timeout value to use for receive operations.

Parameters:

receiveTimeout - the receive timeout in milliseconds

setThrowExceptionOnLateReply

public void setThrowExceptionOnLateReply(boolean throwExceptionOnLateReply)

Specify whether or not an attempt to send on the reply channel throws an exception if no receiving thread will actually receive the reply. This can occur if the receiving thread has already timed out, or will never call receive() because it caught an exception, or has already received a reply. (default false - just a WARN log is emitted in these cases).

Parameters:

throwExceptionOnLateReply - TRUE or FALSE.

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)
                    throws BeansException

Description copied from interface: BeanFactoryAware

Callback that supplies the owning factory to a bean instance.

Invoked after the population of normal bean properties but before an initialization callback such as InitializingBean.afterPropertiesSet() or a custom init-method.

Specified by:

setBeanFactory in interface BeanFactoryAware

Parameters:

beanFactory - owning BeanFactory (never null). The bean can immediately call methods on the factory.

Throws:

BeansException - in case of initialization errors

See Also:

BeanInitializationException

doSend

protected final void doSend(MessageChannel destination,
          Message<?> message)

Specified by:

doSend in class AbstractMessageSendingTemplate<MessageChannel>

doReceive

protected final <P> Message<P> doReceive(MessageChannel destination)

Specified by:

doReceive in class AbstractMessagingTemplate<MessageChannel>

doSendAndReceive

protected final <S,R> Message<R> doSendAndReceive(MessageChannel destination,
                                Message<S> requestMessage)

Specified by:

doSendAndReceive in class AbstractMessagingTemplate<MessageChannel>