Remove remaining protocol specific classes/interfaces

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6125-ProtocolRefactoring@1628339 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 14 insertions, 3 deletions

diff --git a/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/handler/ServerMethodDispatcherImpl_0_9.java b/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/handler/ServerMethodDispatcherImpl_0_9.java
index 4d66d0f999..d15d27fcd5 100644
--- a/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/handler/ServerMethodDispatcherImpl_0_9.java
+++ b/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/handler/ServerMethodDispatcherImpl_0_9.java
@@ -22,15 +22,19 @@ package org.apache.qpid.server.protocol.v0_8.handler;
 

 

 import org.apache.qpid.AMQException;

-import org.apache.qpid.framing.*;

-import org.apache.qpid.framing.amqp_0_9.MethodDispatcher_0_9;

+import org.apache.qpid.framing.BasicRecoverSyncBody;

+import org.apache.qpid.framing.BasicRecoverSyncOkBody;

+import org.apache.qpid.framing.ChannelAlertBody;

+import org.apache.qpid.framing.MethodDispatcher;

+import org.apache.qpid.framing.QueueUnbindBody;

+import org.apache.qpid.framing.QueueUnbindOkBody;

 import org.apache.qpid.server.protocol.v0_8.AMQProtocolSession;

 

 

 

 public class ServerMethodDispatcherImpl_0_9

         extends ServerMethodDispatcherImpl

-        implements MethodDispatcher_0_9

+        implements MethodDispatcher

 

 {

 

@@ -56,6 +60,13 @@ public class ServerMethodDispatcherImpl_0_9
         throw new UnexpectedMethodException(body);

     }

 

+    @Override

+    public boolean dispatchChannelAlert(final ChannelAlertBody body, final int channelId)

+            throws AMQException

+    {

+        throw new UnexpectedMethodException(body);

+    }

+

     public boolean dispatchQueueUnbindOk(QueueUnbindOkBody body, int channelId) throws AMQException

     {

         throw new UnexpectedMethodException(body);