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 #1686

This commit is contained in:
Justin Bertram 2017-12-05 09:39:28 -06:00
parent 3124a503ca 0b5bddaab5
commit e129fc795b
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java
View File

@ -261,6 +261,11 @@ public class OpenWireConnection extends AbstractRemotingConnection implements Se
Command command = (Command) wireFormat.unmarshal(buffer);
// log the openwire command
if (logger.isTraceEnabled()) {
logger.trace("connectionID: " + connectionID + " RECEIVED: " + (command == null ? "NULL" : command));
}
boolean responseRequired = command.isResponseRequired();
int commandId = command.getCommandId();
@ -434,6 +439,12 @@ public class OpenWireConnection extends AbstractRemotingConnection implements Se
}
public void physicalSend(Command command) throws IOException {
if (logger.isTraceEnabled()) {
logger.trace("connectionID: " + (getTransportConnection() == null ? "" : getTransportConnection().getID())
+ " SENDING: " + (command == null ? "NULL" : command));
}
try {
ByteSequence bytes = wireFormat.marshal(command);
ActiveMQBuffer buffer = OpenWireUtil.toActiveMQBuffer(bytes);