ome.smuggler.providers.q

Class MessageBodyWriter<T>

java.lang.Object

ome.smuggler.providers.q.MessageBodyWriter<T>

All Implemented Interfaces:

SinkWriter<T,org.apache.activemq.artemis.api.core.client.ClientMessage>

public class MessageBodyWriter<T>
extends java.lang.Object
implements SinkWriter<T,org.apache.activemq.artemis.api.core.client.ClientMessage>

Writes the body of a message to the underlying Artemis buffer. It uses a serializer to convert the body into a byte stream.

See Also:

MessageBodyReader

Constructor Summary

Constructors

Constructor and Description
MessageBodyWriter(SinkWriter<T,java.io.OutputStream> serializer) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	write(org.apache.activemq.artemis.api.core.client.ClientMessage sink, T body) Writes a value to a data sink.

Methods inherited from class java.lang.Object

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

Methods inherited from interface ome.smuggler.core.convert.SinkWriter

uncheckedWrite

Constructor Detail

MessageBodyWriter

public MessageBodyWriter(SinkWriter<T,java.io.OutputStream> serializer)

Creates a new instance.

Parameters:

serializer - the serializer to use.

Throws:

java.lang.NullPointerException - if the argument is null.

Method Detail

write

public void write(org.apache.activemq.artemis.api.core.client.ClientMessage sink,
                  T body)
           throws java.lang.Exception

Description copied from interface: SinkWriter

Writes a value to a data sink.

Specified by:

write in interface SinkWriter<T,org.apache.activemq.artemis.api.core.client.ClientMessage>

Parameters:

sink - where to write the value to.

body - the data to write.

Throws:

java.lang.NullPointerException - if any of the arguments is null.

java.lang.Exception - if the data could not be written to the sink.