activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1134334 - /activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolHandler.scala
Date Fri, 10 Jun 2011 14:37:47 GMT
Author: tabish
Date: Fri Jun 10 14:37:47 2011
New Revision: 1134334

URL: http://svn.apache.org/viewvc?rev=1134334&view=rev
Log:
Fix build after recent changes.

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=1134334&r1=1134333&r2=1134334&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
Fri Jun 10 14:37:47 2011
@@ -114,7 +114,7 @@ class OpenwireProtocolHandler extends Pr
 
   override def create_connection_status = {
     var rc = new OpenwireConnectionStatusDTO
-    rc.protocol_version = if (wire_format == null) 0 else wire_format.getVersion
+    rc.protocol_version = if (wire_format == null) null else wire_format.getVersion.toString
     rc.user = login.map(_.toString).getOrElse(null)
     //    rc.subscription_count = consumers.size
     rc.waiting_on = waiting_on
@@ -155,7 +155,7 @@ class OpenwireProtocolHandler extends Pr
     outbound_sessions = new SinkMux[Command](connection.transport_sink.map {
       x:Command =>
         x.setCommandId(next_command_id)
-        debug("sending frame: %s", x.toString)
+        debug("sending openwire command: %s", x.toString())
         x
     }, dispatchQueue, OpenwireCodec)
     connection_session = new OverflowSink(outbound_sessions.open(dispatchQueue));



Mime
View raw message