From d2bff5d8edcfe8bd378e93f4527992a714419546 Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Fri, 5 Jan 2007 11:48:37 +0000 Subject: [PATCH] might as well use the generic stuff - sigh git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@492994 13f79535-47bb-0310-9956-ffa450edef68 --- .../activemq/store/kahadaptor/AtomicIntegerMarshaller.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/AtomicIntegerMarshaller.java b/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/AtomicIntegerMarshaller.java index 226c3cf65f..4316c40beb 100644 --- a/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/AtomicIntegerMarshaller.java +++ b/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/AtomicIntegerMarshaller.java @@ -28,16 +28,15 @@ import java.util.concurrent.atomic.AtomicInteger; * Marshall an AtomicInteger * @version $Revision: 1.10 $ */ -public class AtomicIntegerMarshaller implements Marshaller{ +public class AtomicIntegerMarshaller implements Marshaller{ - public void writePayload(Object object,DataOutput dataOut) throws IOException{ - AtomicInteger ai = (AtomicInteger) object; + public void writePayload(AtomicInteger ai,DataOutput dataOut) throws IOException{ dataOut.writeInt(ai.get()); } - public Object readPayload(DataInput dataIn) throws IOException{ + public AtomicInteger readPayload(DataInput dataIn) throws IOException{ int value = dataIn.readInt(); return new AtomicInteger(value); }