Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-03-06 09:20:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

This closes #77 Stomp changes

Browse Source
This commit is contained in:
Clebert Suconic 2015-07-14 09:54:41 -04:00
commit f414c441f2
3 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -91,6 +91,7 @@ public class ActiveMQStompException extends Exception
if (body != null) if (body != null)
{ {
frame.addHeader(Stomp.Headers.CONTENT_TYPE, "text/plain");
frame.setByteBody(body.getBytes(StandardCharsets.UTF_8)); frame.setByteBody(body.getBytes(StandardCharsets.UTF_8));
} }
else else

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

@ -211,6 +211,7 @@ public class StompSession implements SessionCallback
if (stompSubscription != null) if (stompSubscription != null)
{ {
StompFrame frame = connection.getFrameHandler().createStompFrame(Stomp.Responses.ERROR); StompFrame frame = connection.getFrameHandler().createStompFrame(Stomp.Responses.ERROR);
frame.addHeader(Stomp.Headers.CONTENT_TYPE, "text/plain");
frame.setBody("consumer with ID " + consumerId + " disconnected by server"); frame.setBody("consumer with ID " + consumerId + " disconnected by server");
connection.sendFrame(frame); connection.sendFrame(frame);
} }

1
artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/v11/StompFrameHandlerV11.java
View File

@ -105,6 +105,7 @@ public class StompFrameHandlerV11 extends VersionedStompFrameHandler implements
// not valid // not valid
response = createStompFrame(Stomp.Responses.ERROR); response = createStompFrame(Stomp.Responses.ERROR);
response.setNeedsDisconnect(true); response.setNeedsDisconnect(true);
response.addHeader(Stomp.Headers.CONTENT_TYPE, "text/plain");
response.addHeader(Stomp.Headers.Error.MESSAGE, "Failed to connect"); response.addHeader(Stomp.Headers.Error.MESSAGE, "Failed to connect");
response.setBody("The login account is not valid."); response.setBody("The login account is not valid.");
} }