diff options
Diffstat (limited to 'qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/ProtocolEngine_0_10.java')
| -rwxr-xr-x | qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/ProtocolEngine_0_10.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/ProtocolEngine_0_10.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/ProtocolEngine_0_10.java index 1fe4ec792e..30d506a89b 100755 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/ProtocolEngine_0_10.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/ProtocolEngine_0_10.java @@ -58,8 +58,8 @@ public class ProtocolEngine_0_10 extends InputHandler implements ProtocolEngine _appRegistry = appRegistry; // FIXME Two log messages to maintain compatinbility with earlier protocol versions - CurrentActor.get().message(ConnectionMessages.OPEN(null, null, false, false)); - CurrentActor.get().message(ConnectionMessages.OPEN(null, "0-10", false, true)); + _connection.getLogActor().message(ConnectionMessages.OPEN(null, null, false, false)); + _connection.getLogActor().message(ConnectionMessages.OPEN(null, "0-10", false, true)); } public void setNetworkDriver(NetworkDriver driver) |