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)
}
}
