|
Spring Integration | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Message in org.springframework.integration |
---|
Methods in org.springframework.integration that return Message | |
---|---|
Message<?> |
MessagingException.getFailedMessage()
|
Methods in org.springframework.integration with parameters of type Message | |
---|---|
void |
MessagingException.setFailedMessage(Message<?> message)
|
Uses of Message in org.springframework.integration.aggregator |
---|
Methods in org.springframework.integration.aggregator that return Message | |
---|---|
Message<Object> |
CorrelatingMessageBarrier.receive()
|
Methods in org.springframework.integration.aggregator with parameters of type Message | |
---|---|
int |
SequenceNumberComparator.compare(Message<?> o1,
Message<?> o2)
If both messages have a sequence number then compare that, otherwise if one has a sequence number and the other doesn't then the numbered message comes first, or finally of neither has a sequence number then they are equal in rank. |
int |
SequenceNumberComparator.compare(Message<?> o1,
Message<?> o2)
If both messages have a sequence number then compare that, otherwise if one has a sequence number and the other doesn't then the numbered message comes first, or finally of neither has a sequence number then they are equal in rank. |
int |
MessageSequenceComparator.compare(Message<?> message1,
Message<?> message2)
|
int |
MessageSequenceComparator.compare(Message<?> message1,
Message<?> message2)
|
Object |
HeaderAttributeCorrelationStrategy.getCorrelationKey(Message<?> message)
|
Object |
CorrelationStrategy.getCorrelationKey(Message<?> message)
|
Object |
CorrelationStrategyAdapter.getCorrelationKey(Message<?> message)
|
protected void |
CorrelatingMessageBarrier.handleMessageInternal(Message<?> message)
|
protected void |
CorrelatingMessageHandler.handleMessageInternal(Message<?> message)
|
Method parameters in org.springframework.integration.aggregator with type arguments of type Message | |
---|---|
protected Object |
MessageListMethodAdapter.executeMethod(Collection<? extends Message<?>> messages)
|
void |
ResequencingMessageGroupProcessor.setComparator(Comparator<Message<?>> comparator)
A comparator to use to order messages before processing. |
Uses of Message in org.springframework.integration.channel |
---|
Methods in org.springframework.integration.channel that return Message | |
---|---|
protected Message<?> |
QueueChannel.doReceive(long timeout)
|
protected abstract Message<?> |
AbstractPollableChannel.doReceive(long timeout)
Subclasses must implement this method. |
protected Message<?> |
PriorityChannel.doReceive(long timeout)
|
Message<?> |
ChannelInterceptor.postReceive(Message<?> message,
MessageChannel channel)
Invoked immediately after a Message has been retrieved but before it is returned to the caller. |
Message<?> |
AbstractMessageChannel.ChannelInterceptorList.postReceive(Message<?> message,
MessageChannel channel)
|
Message<?> |
ChannelInterceptor.preSend(Message<?> message,
MessageChannel channel)
Invoked before the Message is actually sent to the channel. |
Message<?> |
AbstractMessageChannel.ChannelInterceptorList.preSend(Message<?> message,
MessageChannel channel)
|
Message<?> |
AbstractPollableChannel.receive()
Receive the first available message from this channel. |
Message<?> |
NullChannel.receive()
|
Message<?> |
AbstractPollableChannel.receive(long timeout)
Receive the first available message from this channel. |
Message<?> |
NullChannel.receive(long timeout)
|
Methods in org.springframework.integration.channel that return types with arguments of type Message | |
---|---|
List<Message<?>> |
QueueChannel.clear()
Remove all Messages from this channel. |
List<Message<?>> |
ChannelPurger.purge()
|
List<Message<?>> |
QueueChannel.purge(MessageSelector selector)
Remove any Messages that are not accepted by the provided selector. |
Methods in org.springframework.integration.channel with parameters of type Message | |
---|---|
protected boolean |
QueueChannel.doSend(Message<?> message,
long timeout)
|
protected abstract boolean |
AbstractMessageChannel.doSend(Message<?> message,
long timeout)
Subclasses must implement this method. |
protected boolean |
AbstractSubscribableChannel.doSend(Message<?> message,
long timeout)
|
protected boolean |
PriorityChannel.doSend(Message<?> message,
long timeout)
|
Message<?> |
ChannelInterceptor.postReceive(Message<?> message,
MessageChannel channel)
Invoked immediately after a Message has been retrieved but before it is returned to the caller. |
Message<?> |
AbstractMessageChannel.ChannelInterceptorList.postReceive(Message<?> message,
MessageChannel channel)
|
void |
ChannelInterceptor.postSend(Message<?> message,
MessageChannel channel,
boolean sent)
Invoked immediately after the send invocation. |
void |
AbstractMessageChannel.ChannelInterceptorList.postSend(Message<?> message,
MessageChannel channel,
boolean sent)
|
Message<?> |
ChannelInterceptor.preSend(Message<?> message,
MessageChannel channel)
Invoked before the Message is actually sent to the channel. |
Message<?> |
AbstractMessageChannel.ChannelInterceptorList.preSend(Message<?> message,
MessageChannel channel)
|
boolean |
NullChannel.send(Message<?> message)
|
boolean |
AbstractMessageChannel.send(Message<?> message)
Send a message on this channel. |
boolean |
NullChannel.send(Message<?> message,
long timeout)
|
boolean |
AbstractMessageChannel.send(Message<?> message,
long timeout)
Send a message on this channel. |
Constructor parameters in org.springframework.integration.channel with type arguments of type Message | |
---|---|
PriorityChannel(Comparator<Message<?>> comparator)
Create a channel with an unbounded queue. |
|
PriorityChannel(int capacity,
Comparator<Message<?>> comparator)
Create a channel with the specified queue capacity. |
|
QueueChannel(BlockingQueue<Message<?>> queue)
Create a channel with the specified queue. |
Uses of Message in org.springframework.integration.channel.interceptor |
---|
Methods in org.springframework.integration.channel.interceptor that return Message | |
---|---|
Message<?> |
GlobalChannelInterceptorWrapper.postReceive(Message<?> message,
MessageChannel channel)
|
Message<?> |
ChannelInterceptorAdapter.postReceive(Message<?> message,
MessageChannel channel)
|
Message<?> |
GlobalChannelInterceptorWrapper.preSend(Message<?> message,
MessageChannel channel)
|
Message<?> |
ChannelInterceptorAdapter.preSend(Message<?> message,
MessageChannel channel)
|
Message<?> |
MessageSelectingInterceptor.preSend(Message<?> message,
MessageChannel channel)
|
Message<?> |
WireTap.preSend(Message<?> message,
MessageChannel channel)
Intercept the Message and, if accepted by the MessageSelector ,
send it to the secondary target. |
Methods in org.springframework.integration.channel.interceptor with parameters of type Message | |
---|---|
Message<?> |
GlobalChannelInterceptorWrapper.postReceive(Message<?> message,
MessageChannel channel)
|
Message<?> |
ChannelInterceptorAdapter.postReceive(Message<?> message,
MessageChannel channel)
|
void |
GlobalChannelInterceptorWrapper.postSend(Message<?> message,
MessageChannel channel,
boolean sent)
|
void |
ChannelInterceptorAdapter.postSend(Message<?> message,
MessageChannel channel,
boolean sent)
|
Message<?> |
GlobalChannelInterceptorWrapper.preSend(Message<?> message,
MessageChannel channel)
|
Message<?> |
ChannelInterceptorAdapter.preSend(Message<?> message,
MessageChannel channel)
|
Message<?> |
MessageSelectingInterceptor.preSend(Message<?> message,
MessageChannel channel)
|
Message<?> |
WireTap.preSend(Message<?> message,
MessageChannel channel)
Intercept the Message and, if accepted by the MessageSelector ,
send it to the secondary target. |
Uses of Message in org.springframework.integration.context |
---|
Methods in org.springframework.integration.context with parameters of type Message | |
---|---|
protected void |
IntegrationObjectSupport.writeMessageHistory(Message<?> message)
|
Uses of Message in org.springframework.integration.core |
---|
Classes in org.springframework.integration.core that implement Message | |
---|---|
class |
ErrorMessage
A message implementation that accepts a Throwable payload. |
class |
GenericMessage<T>
Base Message class defining common properties such as id, payload, and headers. |
class |
StringMessage
A message implementation that accepts a String payload. |
Methods in org.springframework.integration.core that return Message | |
---|---|
Message<T> |
MessageBuilder.build()
|
Message<?> |
MessagingTemplate.receive()
|
Message<?> |
PollableChannel.receive()
Receive a message from this channel, blocking indefinitely if necessary. |
Message<T> |
MessageSource.receive()
Retrieve the next available message from this source. |
Message<?> |
PollableChannel.receive(long timeout)
Receive a message from this channel, blocking until either a message is available or the specified timeout period elapses. |
Message<?> |
MessagingTemplate.receive(PollableChannel channel)
|
Message<?> |
MessagingTemplate.sendAndReceive(Message<?> request)
|
Message<?> |
MessagingTemplate.sendAndReceive(MessageChannel channel,
Message<?> request)
|
Methods in org.springframework.integration.core with parameters of type Message | ||
---|---|---|
boolean |
MessageSelector.accept(Message<?> message)
|
|
static
|
MessageBuilder.fromMessage(Message<T> message)
Create a builder for a new Message instance pre-populated with
all of the headers copied from the provided message. |
|
void |
MessageHandler.handleMessage(Message<?> message)
Handles the message if possible. |
|
boolean |
MessagingTemplate.send(Message<?> message)
|
|
boolean |
MessageChannel.send(Message<?> message)
Send a Message to this channel. |
|
boolean |
MessageChannel.send(Message<?> message,
long timeout)
Send a message, blocking until either the message is accepted or the specified timeout period elapses. |
|
boolean |
MessagingTemplate.send(MessageChannel channel,
Message<?> message)
|
|
Message<?> |
MessagingTemplate.sendAndReceive(Message<?> request)
|
|
Message<?> |
MessagingTemplate.sendAndReceive(MessageChannel channel,
Message<?> request)
|
Uses of Message in org.springframework.integration.dispatcher |
---|
Methods in org.springframework.integration.dispatcher with parameters of type Message | |
---|---|
boolean |
UnicastingDispatcher.dispatch(Message<?> message)
|
boolean |
BroadcastingDispatcher.dispatch(Message<?> message)
|
boolean |
MessageDispatcher.dispatch(Message<?> message)
|
Iterator<MessageHandler> |
LoadBalancingStrategy.getHandlerIterator(Message<?> message,
List<MessageHandler> handlers)
|
Iterator<MessageHandler> |
RoundRobinLoadBalancingStrategy.getHandlerIterator(Message<?> message,
List<MessageHandler> handlers)
Returns an iterator that starts at a new point in the list every time the first part of the list that is skipped will be used at the end of the iteration, so it guarantees all handlers are returned once on subsequent next() invocations. |
Constructors in org.springframework.integration.dispatcher with parameters of type Message | |
---|---|
AggregateMessageDeliveryException(Message<?> undeliveredMessage,
String description,
List<? extends Exception> aggregatedExceptions)
|
Uses of Message in org.springframework.integration.endpoint |
---|
Methods in org.springframework.integration.endpoint that return Message | |
---|---|
Message<Object> |
MethodInvokingMessageSource.receive()
|
Methods in org.springframework.integration.endpoint with parameters of type Message | |
---|---|
protected boolean |
MessageProducerSupport.sendMessage(Message<?> message)
|
Uses of Message in org.springframework.integration.event |
---|
Methods in org.springframework.integration.event that return Message | |
---|---|
Message<?> |
MessagingEvent.getMessage()
|
Methods in org.springframework.integration.event with parameters of type Message | |
---|---|
protected void |
ApplicationEventPublishingMessageHandler.handleMessageInternal(Message<?> message)
|
Constructors in org.springframework.integration.event with parameters of type Message | |
---|---|
MessagingEvent(Message<?> message)
|
Uses of Message in org.springframework.integration.file |
---|
Methods in org.springframework.integration.file that return Message | |
---|---|
Message<File> |
FileReadingMessageSource.receive()
|
Methods in org.springframework.integration.file with parameters of type Message | |
---|---|
String |
DefaultFileNameGenerator.generateFileName(Message<?> message)
|
String |
FileNameGenerator.generateFileName(Message<?> message)
|
protected Object |
FileWritingMessageHandler.handleRequestMessage(Message<?> requestMessage)
|
void |
FileReadingMessageSource.onFailure(Message<File> failedMessage,
Throwable t)
Adds the failed message back to the 'toBeReceived' queue if there is room. |
void |
FileReadingMessageSource.onSend(Message<File> sentMessage)
The message is just logged. |
Uses of Message in org.springframework.integration.file.transformer |
---|
Methods in org.springframework.integration.file.transformer that return Message | |
---|---|
Message<?> |
AbstractFilePayloadTransformer.transform(Message<?> message)
|
Methods in org.springframework.integration.file.transformer with parameters of type Message | |
---|---|
Message<?> |
AbstractFilePayloadTransformer.transform(Message<?> message)
|
Uses of Message in org.springframework.integration.filter |
---|
Methods in org.springframework.integration.filter with parameters of type Message | |
---|---|
protected Object |
MessageFilter.handleRequestMessage(Message<?> message)
|
Uses of Message in org.springframework.integration.gateway |
---|
Methods in org.springframework.integration.gateway that return Message | |
---|---|
Message<?> |
RemotingInboundGatewaySupport.exchange(Message<?> message)
|
Message<?> |
RequestReplyExchanger.exchange(Message<?> request)
|
Message<?> |
SimpleMessagingGateway.sendAndReceiveMessage(Object object)
|
protected Message<?> |
AbstractMessagingGateway.sendAndReceiveMessage(Object object)
|
Message<?> |
SimpleMessageMapper.toMessage(Object object)
Returns a Message with the given object as its payload, unless the object is already a Message in which case it will be returned as-is. |
protected Message<?> |
SimpleMessagingGateway.toMessage(Object object)
|
protected Message<?> |
AbstractMessagingGateway.toMessage(Object object)
|
Methods in org.springframework.integration.gateway with parameters of type Message | |
---|---|
Message<?> |
RemotingInboundGatewaySupport.exchange(Message<?> message)
|
Message<?> |
RequestReplyExchanger.exchange(Message<?> request)
|
Object |
SimpleMessageMapper.fromMessage(Message<?> message)
Returns the Message payload (or null if the Message is null). |
protected Object |
SimpleMessagingGateway.fromMessage(Message<?> message)
|
protected Object |
AbstractMessagingGateway.fromMessage(Message<?> message)
|
Object |
AbstractRemotingOutboundGateway.handleRequestMessage(Message<?> message)
|
Uses of Message in org.springframework.integration.groovy |
---|
Methods in org.springframework.integration.groovy with parameters of type Message | |
---|---|
protected Object |
GroovyScriptExecutingMessageProcessor.executeScript(ScriptSource scriptSource,
Message<?> message)
|
Uses of Message in org.springframework.integration.handler |
---|
Methods in org.springframework.integration.handler that return Message | |
---|---|
Message<?> |
ArgumentArrayMessageMapper.toMessage(Object[] arguments)
|
Methods in org.springframework.integration.handler with parameters of type Message | |
---|---|
protected Object |
AbstractMessageProcessor.evaluateExpression(Expression expression,
Message<?> message,
Class<?> expectedType)
|
protected abstract Object |
AbstractScriptExecutingMessageProcessor.executeScript(ScriptSource scriptSource,
Message<?> message)
Subclasses must implement this method. |
void |
MethodInvokingMessageHandler.handleMessage(Message<?> message)
|
void |
DelayHandler.handleMessage(Message<?> message)
|
void |
AbstractMessageHandler.handleMessage(Message<?> message)
|
void |
MessageHandlerChain.handleMessage(Message<?> message)
|
protected void |
AbstractReplyProducingMessageHandler.handleMessageInternal(Message<?> message)
|
protected abstract void |
AbstractMessageHandler.handleMessageInternal(Message<?> message)
|
protected void |
LoggingHandler.handleMessageInternal(Message<?> message)
|
protected abstract Object |
AbstractReplyProducingMessageHandler.handleRequestMessage(Message<?> requestMessage)
Subclasses must implement this method to handle the request Message. |
protected Object |
BridgeHandler.handleRequestMessage(Message<?> requestMessage)
|
protected Object |
ServiceActivatingHandler.handleRequestMessage(Message<?> message)
|
Object |
MethodInvokingMessageProcessor.processMessage(Message<?> message)
|
Object |
ExpressionEvaluatingMessageProcessor.processMessage(Message<?> message)
Processes the Message by evaluating the expression with that Message as the root object. |
Object |
MessageProcessor.processMessage(Message<?> message)
Process the Message and return a value (or null). |
Object |
AbstractScriptExecutingMessageProcessor.processMessage(Message<?> message)
Executes the script and returns the result. |
Method |
PayloadTypeMatchingHandlerMethodResolver.resolveHandlerMethod(Message<?> message)
|
Method |
StaticHandlerMethodResolver.resolveHandlerMethod(Message<?> message)
|
Method |
HandlerMethodResolver.resolveHandlerMethod(Message<?> message)
|
protected MessageChannel |
AbstractMessageHandler.resolveReplyChannel(Message<?> requestMessage,
MessageChannel defaultOutputChannel)
|
protected boolean |
AbstractReplyProducingMessageHandler.sendReplyMessage(Message<?> replyMessage,
MessageChannel replyChannel)
|
Uses of Message in org.springframework.integration.http |
---|
Methods in org.springframework.integration.http that return Message | |
---|---|
Message<?> |
DefaultInboundRequestMapper.toMessage(javax.servlet.http.HttpServletRequest request)
|
Message<?> |
DataBindingInboundRequestMapper.toMessage(javax.servlet.http.HttpServletRequest request)
|
Methods in org.springframework.integration.http with parameters of type Message | |
---|---|
HttpEntity<?> |
DefaultOutboundRequestMapper.fromMessage(Message<?> message)
|
Map<String,?> |
ParameterExtractor.fromMessage(Message<?> requestMessage)
|
Map<String,?> |
DefaultParameterExtractor.fromMessage(Message<?> requestMessage)
|
protected Object |
HttpRequestExecutingMessageHandler.handleRequestMessage(Message<?> requestMessage)
|
Uses of Message in org.springframework.integration.ip.tcp |
---|
Methods in org.springframework.integration.ip.tcp that return Message | |
---|---|
protected Message<?> |
SimpleTcpNetInboundGateway.toMessage(Object object)
|
Message<Object> |
SocketMessageMapper.toMessage(SocketReader socketReader)
|
Methods in org.springframework.integration.ip.tcp with parameters of type Message | |
---|---|
protected void |
AbstractTcpSendingMessageHandler.doWrite(Message<?> message)
Method that actually does the write. |
protected void |
TcpSendingMessageHandler.doWrite(Message<?> message)
Method that actually does the write. |
Object |
SocketMessageMapper.fromMessage(Message<?> message)
|
protected Object |
SimpleTcpNetInboundGateway.fromMessage(Message<?> message)
|
void |
AbstractTcpSendingMessageHandler.handleMessage(Message<?> message)
Writes the message payload to the underlying socket, using the specified message format. |
void |
TcpSendingMessageHandler.handleMessage(Message<?> message)
Writes the message payload to the underlying socket, using the specified message format. |
protected Object |
SimpleTcpNetOutboundGateway.handleRequestMessage(Message<?> requestMessage)
Synchronized to prevent multiplexing requests over the same socket. |
void |
TcpReceivingChannelAdapter.onMessage(Message<?> message)
|
Uses of Message in org.springframework.integration.ip.tcp.connection |
---|
Methods in org.springframework.integration.ip.tcp.connection that return Message | |
---|---|
Message<Object> |
TcpMessageMapper.toMessage(TcpConnection connection)
|
Methods in org.springframework.integration.ip.tcp.connection with parameters of type Message | |
---|---|
Object |
TcpMessageMapper.fromMessage(Message<?> message)
|
void |
TcpListener.onMessage(Message<?> message)
Called by a TCPConnection when a new message arrives. |
void |
TcpNioConnection.send(Message<?> message)
|
void |
TcpConnection.send(Message<?> message)
Converts and sends the message. |
void |
TcpNetConnection.send(Message<?> message)
|
Uses of Message in org.springframework.integration.ip.udp |
---|
Methods in org.springframework.integration.ip.udp that return Message | |
---|---|
Message<byte[]> |
DatagramPacketMessageMapper.toMessage(DatagramPacket packet)
|
Methods in org.springframework.integration.ip.udp with parameters of type Message | |
---|---|
DatagramPacket |
DatagramPacketMessageMapper.fromMessage(Message<?> message)
Raw byte[] from message, possibly with a length field up front. |
void |
UnicastSendingMessageHandler.handleMessage(Message<?> message)
|
protected void |
UnicastReceivingChannelAdapter.sendAck(Message<byte[]> message)
|
Uses of Message in org.springframework.integration.jdbc |
---|
Methods in org.springframework.integration.jdbc that return Message | ||
---|---|---|
|
JdbcMessageStore.addMessage(Message<T> message)
|
|
Message<?> |
JdbcMessageStore.getMessage(UUID id)
|
|
Message<Object> |
JdbcPollingChannelAdapter.receive()
Executes the query. |
|
Message<?> |
JdbcMessageStore.removeMessage(UUID id)
|
Methods in org.springframework.integration.jdbc with parameters of type Message | ||
---|---|---|
|
JdbcMessageStore.addMessage(Message<T> message)
|
|
MessageGroup |
JdbcMessageStore.addMessageToGroup(Object groupId,
Message<?> message)
|
|
void |
JdbcMessageHandler.handleMessage(Message<?> message)
Executes the update, passing the message into the SqlParameterSourceFactory . |
|
MessageGroup |
JdbcMessageStore.removeMessageFromGroup(Object groupId,
Message<?> messageToMark)
|
Uses of Message in org.springframework.integration.jms |
---|
Methods in org.springframework.integration.jms that return Message | |
---|---|
Message<Object> |
JmsDestinationPollingSource.receive()
Will receive a JMS Message converting and returning it as
a Spring Integration Message . |
Methods in org.springframework.integration.jms with parameters of type Message | |
---|---|
void |
JmsSendingMessageHandler.handleMessage(Message<?> message)
|
protected Object |
JmsOutboundGateway.handleRequestMessage(Message<?> message)
|
boolean |
JmsDestinationBackedMessageChannel.send(Message<?> message)
|
boolean |
JmsDestinationBackedMessageChannel.send(Message<?> message,
long timeout)
|
Uses of Message in org.springframework.integration.jmx |
---|
Methods in org.springframework.integration.jmx that return Message | |
---|---|
Message<?> |
AttributePollingMessageSource.receive()
Retrieves the attribute value and returns it in the payload of a Message. |
Methods in org.springframework.integration.jmx with parameters of type Message | |
---|---|
protected void |
NotificationPublishingMessageHandler.handleMessageInternal(Message<?> message)
|
protected Object |
OperationInvokingMessageHandler.handleRequestMessage(Message<?> requestMessage)
|
Uses of Message in org.springframework.integration.json |
---|
Methods in org.springframework.integration.json that return Message | |
---|---|
Message<?> |
InboundJsonMessageMapper.toMessage(String jsonMessage)
|
Methods in org.springframework.integration.json with parameters of type Message | |
---|---|
String |
OutboundJsonMessageMapper.fromMessage(Message<?> message)
|
Uses of Message in org.springframework.integration.mail |
---|
Methods in org.springframework.integration.mail that return Message | |
---|---|
Message<javax.mail.Message> |
MailReceivingMessageSource.receive()
|
Methods in org.springframework.integration.mail with parameters of type Message | |
---|---|
void |
MailSendingMessageHandler.handleMessage(Message<?> message)
|
Uses of Message in org.springframework.integration.mail.transformer |
---|
Methods in org.springframework.integration.mail.transformer that return Message | |
---|---|
Message<?> |
AbstractMailMessageTransformer.transform(Message<?> message)
|
Methods in org.springframework.integration.mail.transformer with parameters of type Message | |
---|---|
Message<?> |
AbstractMailMessageTransformer.transform(Message<?> message)
|
Uses of Message in org.springframework.integration.mapping |
---|
Methods in org.springframework.integration.mapping that return Message | |
---|---|
Message<?> |
InboundMessageMapper.toMessage(T object)
|
Methods in org.springframework.integration.mapping with parameters of type Message | |
---|---|
T |
OutboundMessageMapper.fromMessage(Message<?> message)
|
Constructors in org.springframework.integration.mapping with parameters of type Message | |
---|---|
MessageMappingException(Message<?> failedMessage,
String description)
|
|
MessageMappingException(Message<?> failedMessage,
String description,
Throwable cause)
|
Uses of Message in org.springframework.integration.router |
---|
Methods in org.springframework.integration.router with parameters of type Message | |
---|---|
boolean |
RecipientListRouter.Recipient.accept(Message<?> message)
|
protected MessageChannel |
PayloadTypeRouter.determineTargetChannel(Message<?> message)
|
protected MessageChannel |
ErrorMessageExceptionTypeRouter.determineTargetChannel(Message<?> message)
|
protected abstract MessageChannel |
AbstractSingleChannelRouter.determineTargetChannel(Message<?> message)
Subclasses must implement this method to return the target channel. |
protected abstract String |
AbstractSingleChannelNameRouter.determineTargetChannelName(Message<?> message)
Subclasses must implement this method to return the channel name. |
protected Collection<MessageChannel> |
AbstractChannelNameResolvingMessageRouter.determineTargetChannels(Message<?> message)
|
protected abstract Collection<MessageChannel> |
AbstractMessageRouter.determineTargetChannels(Message<?> message)
Subclasses must implement this method to return the target channels for a given Message. |
protected Collection<MessageChannel> |
AbstractSingleChannelRouter.determineTargetChannels(Message<?> message)
|
protected Collection<MessageChannel> |
RecipientListRouter.determineTargetChannels(Message<?> message)
|
protected abstract List<Object> |
AbstractChannelNameResolvingMessageRouter.getChannelIndicatorList(Message<?> message)
Subclasses must implement this method to return the channel indicators. |
protected List<Object> |
AbstractSingleChannelNameRouter.getChannelIndicatorList(Message<?> message)
|
protected List<Object> |
HeaderValueRouter.getChannelIndicatorList(Message<?> message)
|
protected void |
AbstractMessageRouter.handleMessageInternal(Message<?> message)
|
Uses of Message in org.springframework.integration.security.channel |
---|
Methods in org.springframework.integration.security.channel that return Message | |
---|---|
Message<?> |
ChannelInvocation.getMessage()
|
Uses of Message in org.springframework.integration.selector |
---|
Methods in org.springframework.integration.selector with parameters of type Message | |
---|---|
boolean |
UnexpiredMessageSelector.accept(Message<?> message)
|
boolean |
PayloadTypeSelector.accept(Message<?> message)
|
boolean |
MessageSelectorChain.accept(Message<?> message)
Pass the message through the selector chain. |
Uses of Message in org.springframework.integration.splitter |
---|
Methods in org.springframework.integration.splitter with parameters of type Message | |
---|---|
protected Object |
AbstractMessageSplitter.handleRequestMessage(Message<?> message)
|
protected Object |
DefaultMessageSplitter.splitMessage(Message<?> message)
|
protected abstract Object |
AbstractMessageSplitter.splitMessage(Message<?> message)
Subclasses must override this method to split the received Message. |
Uses of Message in org.springframework.integration.store |
---|
Fields in org.springframework.integration.store with type parameters of type Message | |
---|---|
BlockingQueue<Message<?>> |
SimpleMessageGroup.marked
|
BlockingQueue<Message<?>> |
SimpleMessageGroup.unmarked
|
Methods in org.springframework.integration.store that return Message | ||
---|---|---|
|
MessageStore.addMessage(Message<T> message)
Put the provided Message into the MessageStore. |
|
|
SimpleMessageStore.addMessage(Message<T> message)
|
|
Message<?> |
MessageStore.getMessage(UUID id)
Return the Message with the given id, or null if no Message with that id exists in the MessageStore. |
|
Message<?> |
SimpleMessageStore.getMessage(UUID key)
|
|
Message<?> |
SimpleMessageGroup.getOne()
|
|
Message<?> |
MessageGroup.getOne()
|
|
Message<?> |
MessageGroupQueue.peek()
|
|
Message<?> |
MessageGroupQueue.poll()
|
|
Message<?> |
MessageGroupQueue.poll(long timeout,
TimeUnit unit)
|
|
Message<?> |
MessageStore.removeMessage(UUID id)
Remove the Message with the given id from the MessageStore, if present, and return it. |
|
Message<?> |
SimpleMessageStore.removeMessage(UUID key)
|
|
Message<?> |
MessageGroupQueue.take()
|
Methods in org.springframework.integration.store that return types with arguments of type Message | |
---|---|
Collection<Message<?>> |
SimpleMessageGroup.getMarked()
|
Collection<Message<?>> |
MessageGroup.getMarked()
|
Collection<Message<?>> |
SimpleMessageGroup.getUnmarked()
|
Collection<Message<?>> |
MessageGroup.getUnmarked()
|
Iterator<Message<?>> |
MessageGroupQueue.iterator()
|
Methods in org.springframework.integration.store with parameters of type Message | ||
---|---|---|
void |
SimpleMessageGroup.add(Message<?> message)
|
|
|
MessageStore.addMessage(Message<T> message)
Put the provided Message into the MessageStore. |
|
|
SimpleMessageStore.addMessage(Message<T> message)
|
|
MessageGroup |
MessageGroupStore.addMessageToGroup(Object groupId,
Message<?> message)
Store a message with an association to a group id. |
|
MessageGroup |
SimpleMessageStore.addMessageToGroup(Object groupId,
Message<?> message)
|
|
boolean |
SimpleMessageGroup.canAdd(Message<?> message)
|
|
boolean |
MessageGroup.canAdd(Message<?> message)
Query if the message can be added. |
|
void |
SimpleMessageGroup.mark(Message<?> messageToMark)
|
|
boolean |
MessageGroupQueue.offer(Message<?> e)
|
|
boolean |
MessageGroupQueue.offer(Message<?> e,
long timeout,
TimeUnit unit)
|
|
void |
MessageGroupQueue.put(Message<?> e)
|
|
void |
SimpleMessageGroup.remove(Message<?> message)
|
|
MessageGroup |
MessageGroupStore.removeMessageFromGroup(Object key,
Message<?> messageToMark)
Persist a mark on a single message from the group. |
|
MessageGroup |
SimpleMessageStore.removeMessageFromGroup(Object key,
Message<?> messageToMark)
|
Method parameters in org.springframework.integration.store with type arguments of type Message | |
---|---|
int |
MessageGroupQueue.drainTo(Collection<? super Message<?>> c)
|
int |
MessageGroupQueue.drainTo(Collection<? super Message<?>> c,
int maxElements)
|
Constructor parameters in org.springframework.integration.store with type arguments of type Message | |
---|---|
SimpleMessageGroup(Collection<? extends Message<?>> unmarked,
Collection<? extends Message<?>> marked,
Object groupId,
long timestamp)
|
|
SimpleMessageGroup(Collection<? extends Message<?>> unmarked,
Collection<? extends Message<?>> marked,
Object groupId,
long timestamp)
|
|
SimpleMessageGroup(Collection<? extends Message<?>> unmarked,
Object groupId)
|
Uses of Message in org.springframework.integration.stream |
---|
Methods in org.springframework.integration.stream that return Message | |
---|---|
Message<byte[]> |
ByteStreamReadingMessageSource.receive()
|
Methods in org.springframework.integration.stream with parameters of type Message | |
---|---|
void |
ByteStreamWritingMessageHandler.handleMessage(Message<?> message)
|
void |
CharacterStreamWritingMessageHandler.handleMessage(Message<?> message)
|
Uses of Message in org.springframework.integration.test |
---|
Classes in org.springframework.integration.test that implement Message | |
---|---|
class |
TestMessage
|
Uses of Message in org.springframework.integration.test.matcher |
---|
Methods in org.springframework.integration.test.matcher that return Message | ||
---|---|---|
static Message<?> |
MockitoMessageMatchers.messageWithHeaderEntries(Map<String,?> entries)
|
|
static
|
MockitoMessageMatchers.messageWithHeaderEntry(String key,
org.hamcrest.Matcher<T> valueMatcher)
|
|
static Message<?> |
MockitoMessageMatchers.messageWithHeaderEntry(String key,
Object value)
|
|
static Message<?> |
MockitoMessageMatchers.messageWithHeaderKey(String key)
|
|
static
|
MockitoMessageMatchers.messageWithPayload(org.hamcrest.Matcher<T> payloadMatcher)
|
|
static
|
MockitoMessageMatchers.messageWithPayload(T payload)
|
Methods in org.springframework.integration.test.matcher that return types with arguments of type Message | ||
---|---|---|
static org.hamcrest.Matcher<Message<?>> |
HeaderMatcher.hasAllHeaders(Map<String,?> entries)
|
|
static
|
HeaderMatcher.hasCorrelationId(T value)
|
|
static org.hamcrest.Matcher<Message<?>> |
HeaderMatcher.hasExpirationDate(Date value)
|
|
static org.hamcrest.Matcher<Message<?>> |
HeaderMatcher.hasExpirationDate(org.hamcrest.Matcher<Long> matcher)
|
|
static
|
HeaderMatcher.hasHeader(String key,
org.hamcrest.Matcher<?> valueMatcher)
|
|
static
|
HeaderMatcher.hasHeader(String key,
T value)
|
|
static
|
HeaderMatcher.hasHeaderKey(String key)
|
|
static
|
HeaderMatcher.hasMessageId(T value)
|
|
static
|
PayloadMatcher.hasPayload(org.hamcrest.Matcher<T> payloadMatcher)
|
|
static
|
PayloadMatcher.hasPayload(T payload)
|
|
static org.hamcrest.Matcher<Message<?>> |
HeaderMatcher.hasSequenceNumber(Integer value)
|
|
static org.hamcrest.Matcher<Message<?>> |
HeaderMatcher.hasSequenceNumber(org.hamcrest.Matcher<Integer> matcher)
|
|
static org.hamcrest.Matcher<Message<?>> |
HeaderMatcher.hasSequenceSize(Integer value)
|
|
static org.hamcrest.Matcher<Message<?>> |
HeaderMatcher.hasSequenceSize(org.hamcrest.Matcher<Integer> value)
|
|
static org.hamcrest.Matcher<Message<?>> |
HeaderMatcher.hasTimestamp(Date value)
|
|
static org.hamcrest.Matcher<Message<?>> |
HeaderMatcher.hasTimestamp(org.hamcrest.Matcher<Long> matcher)
|
|
static org.hamcrest.Matcher<Message<?>> |
PayloadAndHeaderMatcher.sameExceptIgnorableHeaders(Message<?> expected,
String... ignoreKeys)
|
Methods in org.springframework.integration.test.matcher with parameters of type Message | |
---|---|
boolean |
HeaderMatcher.matchesSafely(Message<?> item)
Subclasses should implement this. |
boolean |
PayloadMatcher.matchesSafely(Message<?> message)
Subclasses should implement this. |
static org.hamcrest.Matcher<Message<?>> |
PayloadAndHeaderMatcher.sameExceptIgnorableHeaders(Message<?> expected,
String... ignoreKeys)
|
Uses of Message in org.springframework.integration.test.util |
---|
Method parameters in org.springframework.integration.test.util with type arguments of type Message | |
---|---|
static MessageHandler |
TestUtils.handlerExpecting(org.hamcrest.Matcher<Message> messageMatcher)
|
Uses of Message in org.springframework.integration.transformer |
---|
Methods in org.springframework.integration.transformer that return Message | |
---|---|
Message<?> |
MessageTransformingChannelInterceptor.postReceive(Message<?> message,
MessageChannel channel)
|
Message<?> |
MessageTransformingChannelInterceptor.preSend(Message<?> message,
MessageChannel channel)
|
Message<?> |
HeaderEnricher.transform(Message<?> message)
|
Message<?> |
AbstractTransformer.transform(Message<?> message)
|
Message<?> |
Transformer.transform(Message<?> message)
|
Message<?> |
AbstractMessageProcessingTransformer.transform(Message<?> message)
|
Message<?> |
HeaderFilter.transform(Message<?> message)
|
Methods in org.springframework.integration.transformer with parameters of type Message | |
---|---|
protected abstract Object |
AbstractTransformer.doTransform(Message<?> message)
Subclasses must implement this method to provide the transformation logic. |
protected Object |
ClaimCheckOutTransformer.doTransform(Message<?> message)
|
protected Object |
ClaimCheckInTransformer.doTransform(Message<?> message)
|
U |
AbstractPayloadTransformer.doTransform(Message<?> message)
|
protected Object |
MessageTransformingHandler.handleRequestMessage(Message<?> message)
|
Message<?> |
MessageTransformingChannelInterceptor.postReceive(Message<?> message,
MessageChannel channel)
|
Message<?> |
MessageTransformingChannelInterceptor.preSend(Message<?> message,
MessageChannel channel)
|
Message<?> |
HeaderEnricher.transform(Message<?> message)
|
Message<?> |
AbstractTransformer.transform(Message<?> message)
|
Message<?> |
Transformer.transform(Message<?> message)
|
Message<?> |
AbstractMessageProcessingTransformer.transform(Message<?> message)
|
Message<?> |
HeaderFilter.transform(Message<?> message)
|
Constructors in org.springframework.integration.transformer with parameters of type Message | |
---|---|
MessageTransformationException(Message<?> message,
String description)
|
|
MessageTransformationException(Message<?> message,
String description,
Throwable cause)
|
|
MessageTransformationException(Message<?> message,
Throwable cause)
|
Uses of Message in org.springframework.integration.ws |
---|
Methods in org.springframework.integration.ws with parameters of type Message | |
---|---|
Object |
AbstractWebServiceOutboundGateway.handleRequestMessage(Message<?> message)
|
Uses of Message in org.springframework.integration.xml.router |
---|
Methods in org.springframework.integration.xml.router with parameters of type Message | |
---|---|
protected String |
XmlPayloadValidatingRouter.determineTargetChannelName(Message<?> message)
|
List<Object> |
XPathMultiChannelRouter.getChannelIndicatorList(Message<?> message)
|
protected List<Object> |
XPathSingleChannelRouter.getChannelIndicatorList(Message<?> message)
Evaluates the payload using XPathExpression.evaluateAsString(Node) |
Uses of Message in org.springframework.integration.xml.selector |
---|
Methods in org.springframework.integration.xml.selector with parameters of type Message | |
---|---|
boolean |
BooleanTestXPathMessageSelector.accept(Message<?> message)
Return true if the XPathExpression evaluates to true |
boolean |
StringValueTestXPathMessageSelector.accept(Message<?> message)
Evaluate the payload and return true if the value returned by the XPathExpression is equal to the valueToTestFor . |
Uses of Message in org.springframework.integration.xml.splitter |
---|
Methods in org.springframework.integration.xml.splitter with parameters of type Message | |
---|---|
protected Object |
XPathMessageSplitter.splitMessage(Message<?> message)
|
protected List<Node> |
XPathMessageSplitter.splitNodePayload(Node node,
Message message)
|
Uses of Message in org.springframework.integration.xml.transformer |
---|
Methods in org.springframework.integration.xml.transformer with parameters of type Message | |
---|---|
protected Transformer |
XsltPayloadTransformer.buildTransformer(Message<?> message)
|
void |
TransformerConfigurer.configureTransformer(Message<?> message,
Transformer transformer)
Callback method called by XSLT transformer implementations after transformer is created. |
void |
DefaultTransformerConfigurer.configureTransformer(Message<?> message,
Transformer transformer)
|
Object |
MarshallingTransformer.doTransform(Message<?> message)
|
protected Object |
XPathTransformer.doTransform(Message<?> message)
|
protected Object |
XsltPayloadTransformer.doTransform(Message<?> message)
|
Object |
XPathHeaderEnricher.XPathExpressionEvaluatingHeaderValueMessageProcessor.processMessage(Message<?> message)
|
Uses of Message in org.springframework.integration.xmpp.messages |
---|
Methods in org.springframework.integration.xmpp.messages with parameters of type Message | |
---|---|
void |
XmppMessageSendingMessageHandler.handleMessage(Message<?> message)
|
Uses of Message in org.springframework.integration.xmpp.presence |
---|
Methods in org.springframework.integration.xmpp.presence that return Message | |
---|---|
Message<?> |
XmppPresenceMessageMapper.toMessage(org.jivesoftware.smack.packet.Presence presence)
Returns a Message with payload Presence |
Methods in org.springframework.integration.xmpp.presence with parameters of type Message | |
---|---|
org.jivesoftware.smack.packet.Presence |
XmppPresenceMessageMapper.fromMessage(Message<?> message)
Builds a Presence object from the inbound Message headers, if possible. |
void |
XmppRosterEventMessageSendingHandler.handleMessage(Message<?> message)
|
|
Spring Integration | |||||||||
PREV NEXT | FRAMES NO FRAMES |