You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by de...@apache.org on 2011/01/20 14:44:22 UTC
svn commit: r1061299 - in
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq:
broker/TransportConnection.java state/ConnectionState.java
state/ConnectionStateTracker.java
Author: dejanb
Date: Thu Jan 20 13:44:22 2011
New Revision: 1061299
URL: http://svn.apache.org/viewvc?rev=1061299&view=rev
Log:
https://issues.apache.org/jira/browse/AMQ-3040 - ConnectionState.getTempDestinations() typo
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionState.java
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java?rev=1061299&r1=1061298&r2=1061299&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java Thu Jan 20 13:44:22 2011
@@ -726,7 +726,7 @@ public class TransportConnection impleme
}
}
// 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();
try {
broker.removeDestination(cs.getContext(), di.getDestination(), 0);
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionState.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionState.java?rev=1061299&r1=1061298&r2=1061299&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionState.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionState.java Thu Jan 20 13:44:22 2011
@@ -119,7 +119,7 @@ public class ConnectionState {
return sessions.keySet();
}
- public List<DestinationInfo> getTempDesinations() {
+ public List<DestinationInfo> getTempDestinations() {
return tempDestinations;
}
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java?rev=1061299&r1=1061298&r2=1061299&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java Thu Jan 20 13:44:22 2011
@@ -302,7 +302,7 @@ public class ConnectionStateTracker exte
protected void restoreTempDestinations(Transport transport, ConnectionState connectionState)
throws IOException {
// 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());
}
}