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