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);
     }