ome.smuggler.providers.q

Class MessageBodyReader<T>

java.lang.Object

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

All Implemented Interfaces:

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

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

Reads the body of a message from the underlying Artemis buffer. It uses a de-serializer to convert the underlying byte buffer into the body value.

See Also:

MessageBodyWriter

Constructor Summary

Constructors

Constructor and Description
MessageBodyReader(SourceReader<java.io.InputStream,T> deserializer) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
T	read(org.apache.activemq.artemis.api.core.client.ClientMessage source) Reads a T-value from the data source.

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.SourceReader

uncheckedRead

Constructor Detail

MessageBodyReader

public MessageBodyReader(SourceReader<java.io.InputStream,T> deserializer)

Creates a new instance.

Parameters:

deserializer - the deserializer to use.

Throws:

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

Method Detail

read

public T read(org.apache.activemq.artemis.api.core.client.ClientMessage source)
       throws java.lang.Exception

Description copied from interface: SourceReader

Reads a T-value from the data source.

Specified by:

read in interface SourceReader<org.apache.activemq.artemis.api.core.client.ClientMessage,T>

Parameters:

source - the data source.

Returns:

the value read from the source.

Throws:

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

java.lang.Exception - if the value could not be read.