@ManagedResource
public class WireTap
extends org.springframework.messaging.support.ChannelInterceptorAdapter
implements org.springframework.context.Lifecycle
ChannelInterceptor that publishes a copy of the intercepted message
to a secondary target while still sending the original message to the main channel.| Constructor and Description |
|---|
WireTap(org.springframework.messaging.MessageChannel channel)
Create a new wire tap with no
MessageSelector. |
WireTap(org.springframework.messaging.MessageChannel channel,
MessageSelector selector)
Create a new wire tap with the provided
MessageSelector. |
| Modifier and Type | Method and Description |
|---|---|
boolean |
isRunning()
Check whether the wire tap is currently running.
|
org.springframework.messaging.Message<?> |
preSend(org.springframework.messaging.Message<?> message,
org.springframework.messaging.MessageChannel channel)
Intercept the Message and, if accepted by the
MessageSelector,
send it to the secondary target. |
void |
setTimeout(long timeout)
Specify the timeout value for sending to the intercepting target.
|
void |
start()
Restart the wire tap if it has been stopped.
|
void |
stop()
Stop the wire tap.
|
public WireTap(org.springframework.messaging.MessageChannel channel)
MessageSelector.channel - the MessageChannel to which intercepted messages will be sentpublic WireTap(org.springframework.messaging.MessageChannel channel,
MessageSelector selector)
MessageSelector.channel - the channel to which intercepted messages will be sentselector - the selector that must accept a message for it to be
sent to the intercepting channelpublic void setTimeout(long timeout)
timeout - the timeout in milliseconds@ManagedAttribute public boolean isRunning()
isRunning in interface org.springframework.context.Lifecycle@ManagedOperation public void start()
start in interface org.springframework.context.Lifecycle@ManagedOperation public void stop()
start().stop in interface org.springframework.context.Lifecyclepublic org.springframework.messaging.Message<?> preSend(org.springframework.messaging.Message<?> message,
org.springframework.messaging.MessageChannel channel)
MessageSelector,
send it to the secondary target. If this wire tap's MessageSelector is
null, it will accept all messages.preSend in interface org.springframework.messaging.support.ChannelInterceptorpreSend in class org.springframework.messaging.support.ChannelInterceptorAdapter