Author: davidillsley
Date: Thu Apr 10 02:36:04 2008
New Revision: 646715
URL: http://svn.apache.org/viewvc?rev=646715&view=rev
Log:
SANDESHA2-145
Use ConcurrentHashMap to protect against message loss.
Thanks Dave.
Modified:
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryStorageManager.java
Modified:
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryStorageManager.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryStorageManager.java?rev=646715&r1=646714&r2=646715&view=diff
==============================================================================
---
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryStorageManager.java
(original)
+++
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryStorageManager.java
Thu Apr 10 02:36:04 2008
@@ -23,7 +23,6 @@
import java.io.ByteArrayOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
-import java.util.HashMap;
import org.apache.axiom.soap.SOAPEnvelope;
import org.apache.axis2.Constants;
@@ -67,7 +66,7 @@
private PollingManager pollingManager = null;
private ConcurrentHashMap transactions = new ConcurrentHashMap();
private boolean useSerialization = false;
- private HashMap storageMap = new HashMap();
+ private ConcurrentHashMap storageMap = new ConcurrentHashMap();
public InMemoryStorageManager(ConfigurationContext context)
throws SandeshaException
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
