Class TempMessageDatabase.MessageKeysMarshaller

  • All Implemented Interfaces:
    Marshaller<org.apache.activemq.store.kahadb.TempMessageDatabase.MessageRecord>
    Enclosing class:
    TempMessageDatabase

    protected static class TempMessageDatabase.MessageKeysMarshaller
    extends VariableMarshaller<org.apache.activemq.store.kahadb.TempMessageDatabase.MessageRecord>
    • Constructor Detail

      • MessageKeysMarshaller

        protected MessageKeysMarshaller()
    • Method Detail

      • readPayload

        public org.apache.activemq.store.kahadb.TempMessageDatabase.MessageRecord readPayload​(DataInput dataIn)
                                                                                       throws IOException
        Description copied from interface: Marshaller
        Read the payload of the object from the DataInput stream.
        Returns:
        unmarshalled object
        Throws:
        IOException
      • writePayload

        public void writePayload​(org.apache.activemq.store.kahadb.TempMessageDatabase.MessageRecord object,
                                 DataOutput dataOut)
                          throws IOException
        Description copied from interface: Marshaller
        Write the payload of the object to the DataOutput stream.
        Throws:
        IOException