svn commit: r472421 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/OpenWireFormat.java

[rajdavies]

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