diff --git a/activemq-optional/src/main/java/org/apache/activemq/transport/util/TextWireFormat.java b/activemq-optional/src/main/java/org/apache/activemq/transport/util/TextWireFormat.java index 37b410ff4e..a79fa7d7bf 100644 --- a/activemq-optional/src/main/java/org/apache/activemq/transport/util/TextWireFormat.java +++ b/activemq-optional/src/main/java/org/apache/activemq/transport/util/TextWireFormat.java @@ -63,4 +63,9 @@ public abstract class TextWireFormat implements WireFormat { return unmarshal(dis); } + public boolean inReceive() { + // TODO Implement for inactivity monitor + return false; + } + } diff --git a/activemq-xmpp/src/main/java/org/apache/activemq/transport/xmpp/XmppWireFormat.java b/activemq-xmpp/src/main/java/org/apache/activemq/transport/xmpp/XmppWireFormat.java index 095e5e140d..221a8243bb 100644 --- a/activemq-xmpp/src/main/java/org/apache/activemq/transport/xmpp/XmppWireFormat.java +++ b/activemq-xmpp/src/main/java/org/apache/activemq/transport/xmpp/XmppWireFormat.java @@ -216,4 +216,9 @@ public class XmppWireFormat implements WireFormat { public void setVersion(int version) { this.version = version; } + + public boolean inReceive() { + // TODO Implement for inactivity monitor + return false; + } }