You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2008/06/06 23:58:25 UTC

svn commit: r664153 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java

Author: rgodfrey
Date: Fri Jun  6 14:58:25 2008
New Revision: 664153

URL: http://svn.apache.org/viewvc?rev=664153&view=rev
Log:
QPID-1124 : Use thread-safe map for messageListeners

Modified:
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java?rev=664153&r1=664152&r2=664153&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java (original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java Fri Jun  6 14:58:25 2008
@@ -57,7 +57,7 @@
     @Override public void messageTransfer(Session session, MessageTransfer currentTransfer)
     {
         _currentTransfer = currentTransfer;
-        _currentMessageListener = ((ClientSession)session).getMessageListerners().get(currentTransfer.getDestination());
+        _currentMessageListener = ((ClientSession)session).getMessageListeners().get(currentTransfer.getDestination());
         _currentMessageListener.messageTransfer(currentTransfer.getId());
     }