activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1126635 - /activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolHandler.scala
Date Mon, 23 May 2011 18:25:46 GMT
Author: tabish
Date: Mon May 23 18:25:45 2011
New Revision: 1126635

URL: http://svn.apache.org/viewvc?rev=1126635&view=rev
Log:
Fix imports to bring in the OpenwireConnectionStatusDTO instead of the Stomp one, fixes build.

Modified:
    activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolHandler.scala

Modified: activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolHandler.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolHandler.scala?rev=1126635&r1=1126634&r2=1126635&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolHandler.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolHandler.scala
Mon May 23 18:25:45 2011
@@ -41,8 +41,8 @@ import security.SecurityContext
 import tcp.TcpTransport
 import codec.OpenWireFormat
 import command._
-import org.apache.activemq.apollo.stomp.dto.StompConnectionStatusDTO
-import org.apache.activemq.apollo.dto.{TopicDestinationDTO, DurableSubscriptionDestinationDTO,
DestinationDTO, StompConnectionStatusDTO}
+import org.apache.activemq.apollo.openwire.dto.OpenwireConnectionStatusDTO
+import org.apache.activemq.apollo.dto.{TopicDestinationDTO, DurableSubscriptionDestinationDTO,
DestinationDTO}
 
 object OpenwireProtocolHandler extends Log {
 
@@ -202,7 +202,7 @@ class OpenwireProtocolHandler extends Pr
       //          }
       //      }
       //      consumers = Map()
-      trace("stomp protocol resources released")
+      trace("openwire protocol resources released")
     }
   }
 
@@ -862,7 +862,7 @@ class OpenwireProtocolHandler extends Pr
       assert( !route.full )
       route.offer(delivery)
       if( route.full ) {
-        // but once it gets full.. suspend, so that we get more stomp messages
+        // but once it gets full.. suspend, so that we get more messages
         // until it's not full anymore.
         suspendRead("blocked destination: "+route.overflowSessions.mkString(", "))
       }



Mime
View raw message