1 18 package org.apache.activemq.kaha; 19 20 import java.io.DataInput ; 21 import java.io.DataOutput ; 22 import java.io.IOException ; 23 import org.apache.activemq.command.MessageId; 24 29 public class MessageIdMarshaller implements Marshaller<MessageId> { 30 37 public void writePayload(MessageId object,DataOutput dataOut) throws IOException { 38 dataOut.writeUTF(object.toString()); 39 } 40 41 48 public MessageId readPayload(DataInput dataIn) throws IOException { 49 return new MessageId(dataIn.readUTF()); 50 } 51 } 52 | Popular Tags |