public class DatagramPacketMessageMapper extends java.lang.Object implements InboundMessageMapper<java.net.DatagramPacket>, OutboundMessageMapper<java.net.DatagramPacket>, org.springframework.beans.factory.BeanFactoryAware
setCharset(String)
method.
By default, the UDP messages will be unreliable (truncation may occur on
the receiving end; packets may be lost).
Reliability can be enhanced by one or both of the following techniques:
Constructor and Description |
---|
DatagramPacketMessageMapper() |
Modifier and Type | Method and Description |
---|---|
java.net.DatagramPacket |
fromMessage(org.springframework.messaging.Message<?> message)
Raw byte[] from message, possibly with a length field up front.
|
protected MessageBuilderFactory |
getMessageBuilderFactory() |
void |
setAckAddress(java.lang.String ackAddress) |
void |
setAcknowledge(boolean acknowledge) |
void |
setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) |
void |
setCharset(java.lang.String charset) |
void |
setLengthCheck(boolean lengthCheck) |
void |
setLookupHost(boolean lookupHost) |
org.springframework.messaging.Message<byte[]> |
toMessage(java.net.DatagramPacket object)
Convert a provided object to the
Message . |
org.springframework.messaging.Message<byte[]> |
toMessage(java.net.DatagramPacket packet,
java.util.Map<java.lang.String,java.lang.Object> headers)
Convert a provided object to the
Message
and supply with headers if necessary and provided. |
public void setCharset(java.lang.String charset)
public void setAcknowledge(boolean acknowledge)
public void setAckAddress(java.lang.String ackAddress)
public void setLengthCheck(boolean lengthCheck)
public void setLookupHost(boolean lookupHost)
lookupHost
- the lookupHost to setpublic void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) throws org.springframework.beans.BeansException
setBeanFactory
in interface org.springframework.beans.factory.BeanFactoryAware
org.springframework.beans.BeansException
protected MessageBuilderFactory getMessageBuilderFactory()
public java.net.DatagramPacket fromMessage(org.springframework.messaging.Message<?> message) throws java.lang.Exception
fromMessage
in interface OutboundMessageMapper<java.net.DatagramPacket>
java.lang.Exception
public org.springframework.messaging.Message<byte[]> toMessage(java.net.DatagramPacket object) throws java.lang.Exception
InboundMessageMapper
Message
.toMessage
in interface InboundMessageMapper<java.net.DatagramPacket>
object
- the object for message payload or some other conversion logicjava.lang.Exception
- the exception thrown by the underlying mapper implementationpublic org.springframework.messaging.Message<byte[]> toMessage(java.net.DatagramPacket packet, @Nullable java.util.Map<java.lang.String,java.lang.Object> headers) throws java.lang.Exception
InboundMessageMapper
Message
and supply with headers if necessary and provided.toMessage
in interface InboundMessageMapper<java.net.DatagramPacket>
packet
- the object for message payload or some other conversion logicheaders
- additional headers for building message. Can be nulljava.lang.Exception
- the exception thrown by the underlying mapper implementation