Class MulticastSendingMessageHandler

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.MessageHandlerSupport

org.springframework.integration.handler.AbstractMessageHandler

org.springframework.integration.ip.udp.outbound.AbstractInternetProtocolSendingMessageHandler

org.springframework.integration.ip.udp.outbound.UnicastSendingMessageHandler

org.springframework.integration.ip.udp.outbound.MulticastSendingMessageHandler

org.springframework.integration.ip.udp.MulticastSendingMessageHandler

All Implemented Interfaces:

Runnable, org.reactivestreams.Subscriber<Message<?>>, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Ordered, ComponentSourceAware, ExpressionCapable, Orderable, IntegrationPattern, CommonSocketOptions, NamedComponent, IntegrationManagement, ManageableLifecycle, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>

@Deprecated(forRemoval=true,
            since="7.0")
public class MulticastSendingMessageHandler
extends MulticastSendingMessageHandler

Deprecated, for removal: This API element is subject to removal in a future version.

since 7.0 in favor or MulticastSendingMessageHandler

A MessageHandler implementation that maps a Message into a UDP datagram packet and sends that to the specified multicast address (224.0.0.0 to 239.255.255.255) and port.

The only difference between this and its super class is the ability to specify how many acknowledgments are required to determine success.

Since:

2.0

Author:

Gary Russell, Artem Bilan, Christian Tzolov

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.ip.udp.outbound.UnicastSendingMessageHandler

lock

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor	Description
MulticastSendingMessageHandler(String destinationExpression)	Deprecated, for removal: This API element is subject to removal in a future version. Construct MulticastSendingMessageHandler based on the destination SpEL expression to determine the target destination at runtime against requestMessage.
MulticastSendingMessageHandler(String address, int port)	Deprecated, for removal: This API element is subject to removal in a future version. Construct a MulticastSendingMessageHandler to send data to the multicast address/port.
MulticastSendingMessageHandler(String address, int port, boolean lengthCheck)	Deprecated, for removal: This API element is subject to removal in a future version. Construct a MulticastSendingMessageHandler to send data to the multicast address/port and enables setting the lengthCheck option (if set, a length is prepended to the packet and checked at the destination).
MulticastSendingMessageHandler(String address, int port, boolean lengthCheck, boolean acknowledge, String ackHost, int ackPort, int ackTimeout)	Deprecated, for removal: This API element is subject to removal in a future version. Construct a MulticastSendingMessageHandler to send data to the multicast address/port and enables setting the acknowledge option, where the destination sends a receipt acknowledgment.
MulticastSendingMessageHandler(String address, int port, boolean acknowledge, String ackHost, int ackPort, int ackTimeout)	Deprecated, for removal: This API element is subject to removal in a future version. Construct a MulticastSendingMessageHandler to send data to the multicast address/port and enables setting the acknowledge option, where the destination sends a receipt acknowledgment.
MulticastSendingMessageHandler(Expression destinationExpression)	Deprecated, for removal: This API element is subject to removal in a future version. Construct MulticastSendingMessageHandler based on the destination SpEL expression to determine the target destination at runtime against requestMessage.

Method Summary

Methods inherited from class org.springframework.integration.ip.udp.outbound.MulticastSendingMessageHandler

getSocket, setLocalAddress, setMinAcksForSuccess, setTimeToLive

Methods inherited from class org.springframework.integration.ip.udp.outbound.UnicastSendingMessageHandler

convertAndSend, doStart, doStop, getAckPort, getComponentType, getSoReceiveBufferSize, getTheSocket, handleMessageInternal, isAcknowledge, onInit, restartAckThread, run, setAckCounter, setLengthCheck, setReliabilityAttributes, setSocket, setSocketAttributes, setSocketCustomizer, setSocketExpression, setSocketExpressionString, setSoReceiveBufferSize, setTaskExecutor, startAckThread, updateAckAddress

Methods inherited from class org.springframework.integration.ip.udp.outbound.AbstractInternetProtocolSendingMessageHandler

getDestinationAddress, getHost, getPort, getSoSendBufferSize, getSoTimeout, isRunning, setSoSendBufferSize, setSoTimeout, start, stop

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

handleMessage, onComplete, onError, onNext, onSubscribe, setObservationConvention

Methods inherited from class org.springframework.integration.handler.MessageHandlerSupport

buildSendTimer, destroy, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getObservationRegistry, getOrder, getOverrides, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentDescription, getComponentName, getComponentSource, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentDescription, setComponentName, setComponentSource, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface reactor.core.CoreSubscriber

currentContext

Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

getThisAs

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getBeanName, getComponentName

Constructor Details

MulticastSendingMessageHandler

public MulticastSendingMessageHandler(String address,
 int port)

Deprecated, for removal: This API element is subject to removal in a future version.

Construct a MulticastSendingMessageHandler to send data to the multicast address/port.

Parameters:

address - The multicast address.

port - The port.

MulticastSendingMessageHandler

public MulticastSendingMessageHandler(String address,
 int port,
 boolean lengthCheck)

Deprecated, for removal: This API element is subject to removal in a future version.

Construct a MulticastSendingMessageHandler to send data to the multicast address/port and enables setting the lengthCheck option (if set, a length is prepended to the packet and checked at the destination).

Parameters:

address - The multicast address.

port - The port.

lengthCheck - Enable the lengthCheck option.

MulticastSendingMessageHandler

public MulticastSendingMessageHandler(String address,
 int port,
 boolean acknowledge,
 String ackHost,
 int ackPort,
 int ackTimeout)

Deprecated, for removal: This API element is subject to removal in a future version.

Construct a MulticastSendingMessageHandler to send data to the multicast address/port and enables setting the acknowledge option, where the destination sends a receipt acknowledgment.

Parameters:

address - The multicast address.

port - The port.

acknowledge - Whether acknowledgments are required.

ackHost - The host to which acknowledgments should be sent; required if acknowledge is true.

ackPort - The port to which acknowledgments should be sent; required if acknowledge is true.

ackTimeout - How long to wait (milliseconds) for an acknowledgment.

MulticastSendingMessageHandler

public MulticastSendingMessageHandler(String address,
 int port,
 boolean lengthCheck,
 boolean acknowledge,
 String ackHost,
 int ackPort,
 int ackTimeout)

Deprecated, for removal: This API element is subject to removal in a future version.

Construct a MulticastSendingMessageHandler to send data to the multicast address/port and enables setting the acknowledge option, where the destination sends a receipt acknowledgment.

Parameters:

address - The multicast address.

port - The port.

lengthCheck - Enable the lengthCheck option.

acknowledge - Whether acknowledgments are required.

ackHost - The host to which acknowledgments should be sent; required if acknowledge is true.

ackPort - The port to which acknowledgments should be sent; required if acknowledge is true.

ackTimeout - How long to wait (milliseconds) for an acknowledgment.

MulticastSendingMessageHandler

public MulticastSendingMessageHandler(Expression destinationExpression)

Deprecated, for removal: This API element is subject to removal in a future version.

Construct MulticastSendingMessageHandler based on the destination SpEL expression to determine the target destination at runtime against requestMessage.

Parameters:

destinationExpression - the SpEL expression to evaluate the target destination at runtime. Must evaluate to String, URI or SocketAddress.

Since:

5.0

MulticastSendingMessageHandler

public MulticastSendingMessageHandler(String destinationExpression)

Deprecated, for removal: This API element is subject to removal in a future version.

Construct MulticastSendingMessageHandler based on the destination SpEL expression to determine the target destination at runtime against requestMessage.

Parameters:

destinationExpression - the SpEL expression to evaluate the target destination at runtime. Must evaluate to String, URI or SocketAddress.

Since:

5.0