You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ta...@apache.org on 2014/09/26 23:37:48 UTC
[2/3] git commit: Remove use of HawtBuf
Remove use of HawtBuf
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/10b92884
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/10b92884
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/10b92884
Branch: refs/heads/master
Commit: 10b92884b52ea16c24a83a4ecb87c80424a1b941
Parents: 0d4d9d4
Author: Timothy Bish <ta...@gmail.com>
Authored: Fri Sep 26 17:23:22 2014 -0400
Committer: Timothy Bish <ta...@gmail.com>
Committed: Fri Sep 26 17:23:22 2014 -0400
----------------------------------------------------------------------
.../org/apache/qpid/jms/provider/amqp/AmqpConsumer.java | 9 ++++-----
1 file changed, 4 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/10b92884/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java
index 790a924..d949b70 100644
--- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java
+++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java
@@ -16,6 +16,7 @@
*/
package org.apache.qpid.jms.provider.amqp;
+import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.util.HashMap;
import java.util.LinkedHashMap;
@@ -50,8 +51,6 @@ import org.apache.qpid.proton.engine.Receiver;
import org.apache.qpid.proton.jms.EncodedMessage;
import org.apache.qpid.proton.jms.InboundTransformer;
import org.apache.qpid.proton.jms.JMSMappingInboundTransformer;
-import org.fusesource.hawtbuf.Buffer;
-import org.fusesource.hawtbuf.ByteArrayOutputStream;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -422,17 +421,17 @@ public class AmqpConsumer extends AbstractAmqpResource<JmsConsumerInfo, Receiver
}
protected EncodedMessage readIncomingMessage(Delivery incoming) {
- Buffer buffer;
+ byte[] buffer;
int count;
while ((count = endpoint.recv(incomingBuffer, 0, incomingBuffer.length)) > 0) {
streamBuffer.write(incomingBuffer, 0, count);
}
- buffer = streamBuffer.toBuffer();
+ buffer = streamBuffer.toByteArray();
try {
- return new EncodedMessage(incoming.getMessageFormat(), buffer.data, buffer.offset, buffer.length);
+ return new EncodedMessage(incoming.getMessageFormat(), buffer, 0, buffer.length);
} finally {
streamBuffer.reset();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org