You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2007/01/05 12:48:37 UTC
svn commit: r492994 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/AtomicIntegerMarshaller.java
Author: rajdavies
Date: Fri Jan 5 03:48:37 2007
New Revision: 492994
URL: http://svn.apache.org/viewvc?view=rev&rev=492994
Log:
might as well use the generic stuff - sigh
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/AtomicIntegerMarshaller.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/AtomicIntegerMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/AtomicIntegerMarshaller.java?view=diff&rev=492994&r1=492993&r2=492994
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/AtomicIntegerMarshaller.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/AtomicIntegerMarshaller.java Fri Jan 5 03:48:37 2007
@@ -28,16 +28,15 @@
* Marshall an AtomicInteger
* @version $Revision: 1.10 $
*/
-public class AtomicIntegerMarshaller implements Marshaller{
+public class AtomicIntegerMarshaller implements Marshaller<AtomicInteger>{
- 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);
}