From 5e34c79ab85ff75a929353590cd1b90ce1b91b67 Mon Sep 17 00:00:00 2001
From: Robert Gemmell <robbie@apache.org>
Date: Fri, 4 Feb 2011 16:14:46 +0000
Subject: QPID-3021: ensure the connection actor is used for connection control
 events regardless of a particular sessions existence

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1067208 13f79535-47bb-0310-9956-ffa450edef68
---
 .../src/main/java/org/apache/qpid/transport/ProtocolError.java       | 5 +++++
 .../src/main/java/org/apache/qpid/transport/ProtocolEvent.java       | 1 +
 .../src/main/java/org/apache/qpid/transport/ProtocolHeader.java      | 5 +++++
 3 files changed, 11 insertions(+)

(limited to 'qpid/java/common/src')

diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/ProtocolError.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/ProtocolError.java
index bd6ab81997..8a5edc302e 100644
--- a/qpid/java/common/src/main/java/org/apache/qpid/transport/ProtocolError.java
+++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/ProtocolError.java
@@ -60,6 +60,11 @@ public final class ProtocolError implements NetworkEvent, ProtocolEvent
         return track;
     }
 
+    public boolean isConnectionControl()
+    {
+        return false;
+    }
+
     public String getMessage()
     {
         return String.format(format, args);
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/ProtocolEvent.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/ProtocolEvent.java
index 60234c1537..b51a540701 100644
--- a/qpid/java/common/src/main/java/org/apache/qpid/transport/ProtocolEvent.java
+++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/ProtocolEvent.java
@@ -37,4 +37,5 @@ public interface ProtocolEvent
 
     <C> void delegate(C context, ProtocolDelegate<C> delegate);
 
+    boolean isConnectionControl();
 }
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/ProtocolHeader.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/ProtocolHeader.java
index 00ea55ff96..e5b93e40a9 100644
--- a/qpid/java/common/src/main/java/org/apache/qpid/transport/ProtocolHeader.java
+++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/ProtocolHeader.java
@@ -88,6 +88,11 @@ public final class ProtocolHeader implements NetworkEvent, ProtocolEvent
         return Frame.L1;
     }
 
+    public boolean isConnectionControl()
+    {
+        return false;
+    }
+
     public ByteBuffer toByteBuffer()
     {
         ByteBuffer buf = ByteBuffer.allocate(8);
-- 
cgit v1.2.1