activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject svn commit: r1061299 - in /activemq/trunk/activemq-core/src/main/java/org/apache/activemq: broker/TransportConnection.java state/ConnectionState.java state/ConnectionStateTracker.java
Date Thu, 20 Jan 2011 13:44:22 GMT
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());
         }
     }



Mime
View raw message