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

https://issues.apache.org/jira/browse/AMQ-3040 - ConnectionState.getTempDestinations() typo 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1061299 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Bosanac Dejan 2011-01-20 13:44:22 +00:00
parent e511e76d4f
commit 53ea4caa20
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -726,7 +726,7 @@ public class TransportConnection implements Connection, Task, CommandVisitor {
} }
} }
// Cascade the connection stop to temp destinations. // Cascade the connection stop to temp destinations.
for (Iterator iter = cs.getTempDesinations().iterator(); iter.hasNext();) { for (Iterator iter = cs.getTempDestinations().iterator(); iter.hasNext();) {
DestinationInfo di = (DestinationInfo) iter.next(); DestinationInfo di = (DestinationInfo) iter.next();
try { try {
broker.removeDestination(cs.getContext(), di.getDestination(), 0); broker.removeDestination(cs.getContext(), di.getDestination(), 0);

2
activemq-core/src/main/java/org/apache/activemq/state/ConnectionState.java
View File

@ -119,7 +119,7 @@ public class ConnectionState {
return sessions.keySet(); return sessions.keySet();
} }
public List<DestinationInfo> getTempDesinations() { public List<DestinationInfo> getTempDestinations() {
return tempDestinations; return tempDestinations;
} }

2
activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
View File

@ -302,7 +302,7 @@ public class ConnectionStateTracker extends CommandVisitorAdapter {
protected void restoreTempDestinations(Transport transport, ConnectionState connectionState) protected void restoreTempDestinations(Transport transport, ConnectionState connectionState)
throws IOException { throws IOException {
// Restore the connection's temp destinations. // Restore the connection's temp destinations.
for (Iterator iter2 = connectionState.getTempDesinations().iterator(); iter2.hasNext();) { for (Iterator iter2 = connectionState.getTempDestinations().iterator(); iter2.hasNext();) {
transport.oneway((DestinationInfo)iter2.next()); transport.oneway((DestinationInfo)iter2.next());
} }
} }