From 2d84c4d036f330a87b7c540153006cc32617f23c Mon Sep 17 00:00:00 2001 From: Christopher Lambert Date: Thu, 10 Jun 2021 11:14:15 +0200 Subject: [PATCH] avoid decoding msgBody twice in JmsMsgSendOp --- .../main/java/io/nosqlbench/driver/jms/ops/JmsMsgSendOp.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/driver-jms/src/main/java/io/nosqlbench/driver/jms/ops/JmsMsgSendOp.java b/driver-jms/src/main/java/io/nosqlbench/driver/jms/ops/JmsMsgSendOp.java index f23ac403e..0219124c6 100644 --- a/driver-jms/src/main/java/io/nosqlbench/driver/jms/ops/JmsMsgSendOp.java +++ b/driver-jms/src/main/java/io/nosqlbench/driver/jms/ops/JmsMsgSendOp.java @@ -108,11 +108,10 @@ public class JmsMsgSendOp extends JmsTimeTrackOp { @Override public void run() { - int messageSize; try { byte[] msgBytes = msgBody.getBytes(StandardCharsets.UTF_8); - messageSize = msgBytes.length; - jmsProducer.send(jmsDestination, msgBody.getBytes(StandardCharsets.UTF_8)); + int messageSize = msgBytes.length; + jmsProducer.send(jmsDestination, msgBytes); messagesizeHistogram.update(messageSize); bytesCounter.inc(messageSize);