Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #776

This commit is contained in:
Clebert Suconic 2016-09-15 09:25:57 -04:00
parent afee9247ef 2c7c81ca9e
commit 6b06c08c90
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompFrame.java
View File

@ -91,19 +91,14 @@ public class StompFrame {
public ActiveMQBuffer toActiveMQBuffer() throws Exception {
if (buffer == null) {
if (bytesBody != null) {
buffer = ActiveMQBuffers.dynamicBuffer(bytesBody.length + 512);
}
else {
buffer = ActiveMQBuffers.dynamicBuffer(512);
}
if (isPing()) {
buffer.writeByte((byte) 10);
buffer = ActiveMQBuffers.fixedBuffer(1);
buffer.writeByte((byte)10);
size = buffer.writerIndex();
return buffer;
}
StringBuilder head = new StringBuilder();
StringBuilder head = new StringBuilder(512);
head.append(command);
head.append(Stomp.NEWLINE);
// Output the headers.
@ -117,7 +112,12 @@ public class StompFrame {
// Add a newline to separate the headers from the content.
head.append(Stomp.NEWLINE);
buffer.writeBytes(head.toString().getBytes(StandardCharsets.UTF_8));
byte[] headBytes = head.toString().getBytes(StandardCharsets.UTF_8);
int bodyLength = (bytesBody == null) ? 0 : bytesBody.length;
buffer = ActiveMQBuffers.fixedBuffer(headBytes.length + bodyLength + END_OF_FRAME.length);
buffer.writeBytes(headBytes);
if (bytesBody != null) {
buffer.writeBytes(bytesBody);
}