diff options
Diffstat (limited to 'qpid/java/management/agent/src/main/java/org/apache/qpid/agent/Agent.java')
| -rw-r--r-- | qpid/java/management/agent/src/main/java/org/apache/qpid/agent/Agent.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/java/management/agent/src/main/java/org/apache/qpid/agent/Agent.java b/qpid/java/management/agent/src/main/java/org/apache/qpid/agent/Agent.java index 40797d51f9..f6ae6adbc3 100644 --- a/qpid/java/management/agent/src/main/java/org/apache/qpid/agent/Agent.java +++ b/qpid/java/management/agent/src/main/java/org/apache/qpid/agent/Agent.java @@ -239,7 +239,7 @@ public class Agent implements MessageListener throw new AgentException(e); } byte[] magic = dec.readBytes(3); - if (magic[0] != 'A' || magic[1] != 'M' || magic[2] != '3') + if (magic[0] != 'A' || magic[1] != 'M' || magic[2] != '2') { throw new AgentException("bad magic: " + new String(magic)); } @@ -475,7 +475,7 @@ public class Agent implements MessageListener enc.init(); enc.writeUint8((short) 'A'); enc.writeUint8((short) 'M'); - enc.writeUint8((short) '3'); + enc.writeUint8((short) '2'); enc.writeUint8((short) opcode); enc.writeUint32(sequence); return enc; |