1 18 package org.apache.activemq.store.kahadaptor; 19 20 import java.io.DataInput ; 21 import java.io.DataOutput ; 22 import java.io.IOException ; 23 24 import org.apache.activemq.kaha.Marshaller; 25 26 27 31 public class IntegerMarshaller implements Marshaller<Integer > { 32 33 public void writePayload(Integer object,DataOutput dataOut) throws IOException { 34 dataOut.writeInt(object.intValue()); 35 } 36 37 public Integer readPayload(DataInput dataIn) throws IOException { 38 return dataIn.readInt(); 39 } 40 } 41 | Popular Tags |