1 files changed, 68 insertions, 0 deletions
diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/codec/BinaryString.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/codec/BinaryString.java
new file mode 100644
index 0000000000..76bdac8ed7
--- /dev/null
+++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/codec/BinaryString.java
@@ -0,0 +1,68 @@
+package org.apache.qpid.amqp_1_0.codec;
+
+
+final class BinaryString
+{
+
+    private byte[] _data;
+    private int _offset;
+    private int _size;
+    private int _hashCode;
+
+    BinaryString(final byte[] data, final int offset, final int size)
+    {
+
+        setData(data, offset, size);
+    }
+
+    BinaryString()
+    {
+    }
+
+    void setData(byte[] data, int offset, int size)
+    {
+        _data = data;
+        _offset = offset;
+        _size = size;
+        int hc = 0;
+        for (int i = 0; i < size; i++)
+        {
+            hc = 31*hc + (0xFF & data[offset + i]);
+        }
+        _hashCode = hc;
+    }
+
+
+    public final int hashCode()
+    {
+        return _hashCode;
+    }
+
+    public final boolean equals(Object o)
+    {
+        BinaryString buf = (BinaryString) o;
+        final int size = _size;
+        if (size != buf._size)
+        {
+            return false;
+        }
+
+        final byte[] myData = _data;
+        final byte[] theirData = buf._data;
+        int myOffset = _offset;
+        int theirOffset = buf._offset;
+        final int myLimit = myOffset + size;
+
+        while(myOffset < myLimit)
+        {
+            if (myData[myOffset++] != theirData[theirOffset++])
+            {
+                return false;
+            }
+        }
+
+        return true;
+    }
+
+
+}