org.apache.activemq.store.kahadb
Class MessageDatabase.MessageKeysMarshaller

java.lang.Object
  org.apache.kahadb.util.VariableMarshaller<org.apache.activemq.store.kahadb.MessageDatabase.MessageKeys>
      org.apache.activemq.store.kahadb.MessageDatabase.MessageKeysMarshaller

All Implemented Interfaces:

Marshaller<org.apache.activemq.store.kahadb.MessageDatabase.MessageKeys>

Enclosing class:

MessageDatabase

protected static class MessageDatabase.MessageKeysMarshaller
extends VariableMarshaller<org.apache.activemq.store.kahadb.MessageDatabase.MessageKeys>

Constructor Summary

protected

MessageDatabase.MessageKeysMarshaller()

Method Summary

org.apache.activemq.store.kahadb.MessageDatabase.MessageKeys	readPayload(java.io.DataInput dataIn) Read the payload of the object from the DataInput stream.
void	writePayload(org.apache.activemq.store.kahadb.MessageDatabase.MessageKeys object, java.io.DataOutput dataOut) Write the payload of the object to the DataOutput stream.

Methods inherited from class org.apache.kahadb.util.VariableMarshaller

deepCopy, getFixedSize, isDeepCopySupported

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageDatabase.MessageKeysMarshaller

protected MessageDatabase.MessageKeysMarshaller()

Method Detail

readPayload

public org.apache.activemq.store.kahadb.MessageDatabase.MessageKeys readPayload(java.io.DataInput dataIn)
                                                                         throws java.io.IOException

Description copied from interface: Marshaller

Read the payload of the object from the DataInput stream.

Returns:

unmarshalled object

Throws:

java.io.IOException

writePayload

public void writePayload(org.apache.activemq.store.kahadb.MessageDatabase.MessageKeys object,
                         java.io.DataOutput dataOut)
                  throws java.io.IOException

Description copied from interface: Marshaller

Write the payload of the object to the DataOutput stream.

Throws:

java.io.IOException