Author: robbie
Date: Wed Jul 2 13:03:05 2014
New Revision: 1607356
URL: http://svn.apache.org/r1607356
Log:
PROTON-628: split out usage of the buffer in MessageImpl#decode() to its own
method to enable supplying the buffer directly
Appled patch from Clebert Suconic with some indentation+whitespace fixup.
Modified:
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/message/impl/MessageImpl.java
Modified:
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/message/impl/MessageImpl.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/message/impl/MessageImpl.java?rev=1607356&r1=1607355&r2=1607356&view=diff
==============================================================================
---
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/message/impl/MessageImpl.java
(original)
+++
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/message/impl/MessageImpl.java
Wed Jul 2 13:03:05 2014
@@ -573,8 +573,15 @@ public class MessageImpl implements Prot
@Override
public int decode(byte[] data, int offset, int length)
{
- DecoderImpl decoder = tlsCodec.get().decoder;
final ByteBuffer buffer = ByteBuffer.wrap(data, offset, length);
+ decode(buffer);
+
+ return length-buffer.remaining();
+ }
+
+ public void decode(ByteBuffer buffer)
+ {
+ DecoderImpl decoder = tlsCodec.get().decoder;
decoder.setByteBuffer(buffer);
_header = null;
@@ -680,9 +687,6 @@ public class MessageImpl implements Prot
}
decoder.setByteBuffer(null);
-
- return length-buffer.remaining();
-
}
@Override
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
