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

[rgodfrey]

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