activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1236537 - /activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolFactory.scala
Date Fri, 27 Jan 2012 05:46:41 GMT
Author: chirino
Date: Fri Jan 27 05:46:41 2012
New Revision: 1236537

URL: http://svn.apache.org/viewvc?rev=1236537&view=rev
Log:
Fixing the protocol matching/identification logic for openwire.

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

Modified: activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolFactory.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolFactory.scala?rev=1236537&r1=1236536&r2=1236537&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolFactory.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolFactory.scala
Fri Jan 27 05:46:41 2012
@@ -75,9 +75,9 @@ class OpenwireProtocolCodecFactory exten
 
   def isIdentifiable() = true
 
-  def maxIdentificaionLength() = 4 + MAGIC.length
+  def maxIdentificaionLength() = 5 + MAGIC.length
 
   def matchesIdentification(buffer: Buffer):Boolean = {
-    buffer.length >= 4 + MAGIC.length && buffer.containsAt(MAGIC, 4)
+    buffer.length >= 4 + MAGIC.length && buffer.containsAt(MAGIC, 5)
   }
 }



Mime
View raw message