org.nuxeo.ecm.platform.importer.mqueues.mqueues

Class MQRecord<M extends Externalizable>

java.lang.Object

org.nuxeo.ecm.platform.importer.mqueues.mqueues.MQRecord<M>

public class MQRecord<M extends Externalizable>
extends Object

A MQRecord contains the message and source information.

Since:

9.2

Field Summary

Fields

Modifier and Type	Field and Description
protected M	message
protected MQOffset	offset
protected MQPartition	partition

Constructor Summary

Constructors

Constructor and Description
MQRecord(MQPartition partition, M message, MQOffset offset)

Method Summary

Modifier and Type	Method and Description
M	message() Returns the message.
MQOffset	offset() Returns the offset of the message.
MQPartition	partition() Returns the partition where the message has been read.

Methods inherited from class java.lang.Object

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

Field Detail

message

protected M extends Externalizable message

partition

protected MQPartition partition

offset

protected MQOffset offset

Constructor Detail

MQRecord

public MQRecord(MQPartition partition,
                M message,
                MQOffset offset)

Method Detail

message

public M message()

Returns the message.

partition

public MQPartition partition()

Returns the partition where the message has been read.

offset

public MQOffset offset()

Returns the offset of the message.