activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r472421 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/OpenWireFormat.java
Date Wed, 08 Nov 2006 08:23:09 GMT
Author: rajdavies
Date: Wed Nov  8 00:23:08 2006
New Revision: 472421

URL: http://svn.apache.org/viewvc?view=rev&rev=472421
Log:
added synchronization around marshal/unmarshal

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/OpenWireFormat.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/OpenWireFormat.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/OpenWireFormat.java?view=diff&rev=472421&r1=472420&r2=472421
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/OpenWireFormat.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/OpenWireFormat.java
Wed Nov  8 00:23:08 2006
@@ -115,7 +115,7 @@
         return version;
     }
     
-    public ByteSequence marshal(Object command) throws IOException {
+    public synchronized ByteSequence marshal(Object command) throws IOException {
         
         if( cacheEnabled ) {
             runMarshallCacheEvictionSweep();
@@ -190,7 +190,7 @@
         return sequence;
     }
     
-    public Object unmarshal(ByteSequence sequence) throws IOException {
+    public synchronized Object unmarshal(ByteSequence sequence) throws IOException {
         bytesIn.restart(sequence);
         //DataInputStream dis = new DataInputStream(new ByteArrayInputStream(sequence));
         
@@ -208,7 +208,7 @@
         return command;
     }
     
-    public void marshal(Object o, DataOutput dataOut) throws IOException {
+    public synchronized void marshal(Object o, DataOutput dataOut) throws IOException {
         
         if( cacheEnabled ) {
             runMarshallCacheEvictionSweep();



Mime
View raw message