ServerMethodDispatcherImpl_0_9.java
001 /*
002  *
003  * Licensed to the Apache Software Foundation (ASF) under one
004  * or more contributor license agreements.  See the NOTICE file
005  * distributed with this work for additional information
006  * regarding copyright ownership.  The ASF licenses this file
007  * to you under the Apache License, Version 2.0 (the
008  * "License"); you may not use this file except in compliance
009  * with the License.  You may obtain a copy of the License at
010  *
011  *   http://www.apache.org/licenses/LICENSE-2.0
012  *
013  * Unless required by applicable law or agreed to in writing,
014  * software distributed under the License is distributed on an
015  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
016  * KIND, either express or implied.  See the License for the
017  * specific language governing permissions and limitations
018  * under the License.
019  *
020  */
021 package org.apache.qpid.server.handler;
022 
023 
024 import org.apache.qpid.framing.amqp_0_9.MethodDispatcher_0_9;
025 import org.apache.qpid.framing.*;
026 import org.apache.qpid.server.state.AMQStateManager;
027 import org.apache.qpid.AMQException;
028 
029 
030 
031 public class ServerMethodDispatcherImpl_0_9
032         extends ServerMethodDispatcherImpl
033         implements MethodDispatcher_0_9
034 
035 {
036 
037     private static final BasicRecoverSyncMethodHandler _basicRecoverSyncMethodHandler =
038             BasicRecoverSyncMethodHandler.getInstance();
039     private static final QueueUnbindHandler _queueUnbindHandler =
040             QueueUnbindHandler.getInstance();
041 
042 
043     public ServerMethodDispatcherImpl_0_9(AMQStateManager stateManager)
044     {
045         super(stateManager);
046     }
047 
048     public boolean dispatchBasicRecoverSync(BasicRecoverSyncBody body, int channelIdthrows AMQException
049     {
050         _basicRecoverSyncMethodHandler.methodReceived(getStateManager(), body, channelId);
051         return true;
052     }
053 
054     public boolean dispatchBasicRecoverSyncOk(BasicRecoverSyncOkBody body, int channelIdthrows AMQException
055     {
056         throw new UnexpectedMethodException(body);
057     }
058 
059     public boolean dispatchChannelOk(ChannelOkBody body, int channelIdthrows AMQException
060     {
061         return false;
062     }
063 
064     public boolean dispatchChannelPing(ChannelPingBody body, int channelIdthrows AMQException
065     {
066         return false;
067     }
068 
069     public boolean dispatchChannelPong(ChannelPongBody body, int channelIdthrows AMQException
070     {
071         return false;
072     }
073 
074     public boolean dispatchChannelResume(ChannelResumeBody body, int channelIdthrows AMQException
075     {
076         return false;
077     }
078 
079     public boolean dispatchMessageAppend(MessageAppendBody body, int channelIdthrows AMQException
080     {
081         return false;
082     }
083 
084     public boolean dispatchMessageCancel(MessageCancelBody body, int channelIdthrows AMQException
085     {
086         return false;
087     }
088 
089     public boolean dispatchMessageCheckpoint(MessageCheckpointBody body, int channelIdthrows AMQException
090     {
091         return false;
092     }
093 
094     public boolean dispatchMessageClose(MessageCloseBody body, int channelIdthrows AMQException
095     {
096         return false;
097     }
098 
099     public boolean dispatchMessageConsume(MessageConsumeBody body, int channelIdthrows AMQException
100     {
101         return false;
102     }
103 
104     public boolean dispatchMessageEmpty(MessageEmptyBody body, int channelIdthrows AMQException
105     {
106         return false;
107     }
108 
109     public boolean dispatchMessageGet(MessageGetBody body, int channelIdthrows AMQException
110     {
111         return false;
112     }
113 
114     public boolean dispatchMessageOffset(MessageOffsetBody body, int channelIdthrows AMQException
115     {
116         return false;
117     }
118 
119     public boolean dispatchMessageOk(MessageOkBody body, int channelIdthrows AMQException
120     {
121         return false;
122     }
123 
124     public boolean dispatchMessageOpen(MessageOpenBody body, int channelIdthrows AMQException
125     {
126         return false;
127     }
128 
129     public boolean dispatchMessageQos(MessageQosBody body, int channelIdthrows AMQException
130     {
131         return false;
132     }
133 
134     public boolean dispatchMessageRecover(MessageRecoverBody body, int channelIdthrows AMQException
135     {
136         return false;
137     }
138 
139     public boolean dispatchMessageReject(MessageRejectBody body, int channelIdthrows AMQException
140     {
141         return false;
142     }
143 
144     public boolean dispatchMessageResume(MessageResumeBody body, int channelIdthrows AMQException
145     {
146         return false;
147     }
148 
149     public boolean dispatchMessageTransfer(MessageTransferBody body, int channelIdthrows AMQException
150     {
151         return false;
152     }
153 
154     public boolean dispatchQueueUnbindOk(QueueUnbindOkBody body, int channelIdthrows AMQException
155     {
156         throw new UnexpectedMethodException(body);
157     }
158 
159     public boolean dispatchQueueUnbind(QueueUnbindBody body, int channelIdthrows AMQException
160     {
161         _queueUnbindHandler.methodReceived(getStateManager(),body,channelId);
162         return true;
163     }
164 }