Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix deadlock 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@553076 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-07-04 04:44:00 +00:00
parent b0538fcc66
commit 241971a133
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
View File

@ -1173,10 +1173,8 @@ public class TransportConnection implements Service,Connection,Task,CommandVisit
synchronized(consumerExchanges){
result=new ConsumerBrokerExchange();
ConnectionState state=lookupConnectionState(id);
synchronized(this){
context=state.getContext();
result.setConnectionContext(context);
}
context=state.getContext();
result.setConnectionContext(context);
SessionState ss=state.getSessionState(id.getParentId());
if(ss!=null){
ConsumerState cs=ss.getConsumerState(id);