You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2014/07/02 15:03:05 UTC
svn commit: r1607356 -
/qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/message/impl/MessageImpl.java
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: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org