Changeset 28 for branches/multithread/src/planet/generic/commonapi/factory/RouteMessagePoolImpl.java

Timestamp:

10/02/07 12:49:26 (1 year ago)

Author:

max

Message:

 

Files:

• branches/multithread/src/planet/generic/commonapi/factory/RouteMessagePoolImpl.java (modified) (3 diffs)

branches/multithread/src/planet/generic/commonapi/factory/RouteMessagePoolImpl.java

@@ -66 +66 @@
      * @see planet.commonapi.factory.RouteMessagePool#freeMessage(planet.commonapi.RouteMessage)
      */
-    public void freeMessage(RouteMessage msg) {
+    public synchronized void freeMessage(RouteMessage msg) {
         if (msg == null) return;
         messages.push (msg);
@@ -84 +84 @@
      * @see planet.commonapi.factory.RouteMessagePool#getMessage(java.lang.String, planet.commonapi.NodeHandle, planet.commonapi.NodeHandle, int, int)
      */
-    public RouteMessage getMessage(String key, NodeHandle from, NodeHandle to,
+    public synchronized RouteMessage getMessage(String key, NodeHandle from, NodeHandle to,
             int type, int mode) throws InitializationException {
         if (messages.size() > 0) {
@@ -117 +117 @@
      * @see planet.commonapi.factory.RouteMessagePool#getMessage(String, NodeHandle, NodeHandle, NodeHandle, int, int, Message, String)
      */
-    public RouteMessage getMessage(String key, NodeHandle from, NodeHandle to,
+    public synchronized RouteMessage getMessage(String key, NodeHandle from, NodeHandle to,
             NodeHandle nextHop, int type, int mode, Message msg, String appId)
             throws InitializationException {