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.client.handler;
022
023 import org.apache.qpid.framing.*;
024 import org.apache.qpid.framing.amqp_0_9.MethodDispatcher_0_9;
025
026 import org.apache.qpid.AMQException;
027 import org.apache.qpid.client.state.AMQStateManager;
028 import org.apache.qpid.client.state.AMQMethodNotImplementedException;
029 import org.apache.qpid.client.protocol.AMQProtocolSession;
030
031 public class ClientMethodDispatcherImpl_0_9 extends ClientMethodDispatcherImpl implements MethodDispatcher_0_9
032 {
033 public ClientMethodDispatcherImpl_0_9(AMQProtocolSession session)
034 {
035 super(session);
036 }
037
038 public boolean dispatchBasicRecoverSyncOk(BasicRecoverSyncOkBody body, int channelId) throws AMQException
039 {
040 return false;
041 }
042
043 public boolean dispatchBasicRecoverSync(BasicRecoverSyncBody body, int channelId) throws AMQException
044 {
045 throw new AMQMethodNotImplementedException(body);
046 }
047
048 public boolean dispatchChannelOk(ChannelOkBody body, int channelId) throws AMQException
049 {
050 return false;
051 }
052
053 public boolean dispatchChannelPing(ChannelPingBody body, int channelId) throws AMQException
054 {
055 return false;
056 }
057
058 public boolean dispatchChannelPong(ChannelPongBody body, int channelId) throws AMQException
059 {
060 return false;
061 }
062
063 public boolean dispatchChannelResume(ChannelResumeBody body, int channelId) throws AMQException
064 {
065 throw new AMQMethodNotImplementedException(body);
066 }
067
068 public boolean dispatchMessageAppend(MessageAppendBody body, int channelId) throws AMQException
069 {
070 return false;
071 }
072
073 public boolean dispatchMessageCancel(MessageCancelBody body, int channelId) throws AMQException
074 {
075 throw new AMQMethodNotImplementedException(body);
076 }
077
078 public boolean dispatchMessageCheckpoint(MessageCheckpointBody body, int channelId) throws AMQException
079 {
080 return false;
081 }
082
083 public boolean dispatchMessageClose(MessageCloseBody body, int channelId) throws AMQException
084 {
085 return false;
086 }
087
088 public boolean dispatchMessageConsume(MessageConsumeBody body, int channelId) throws AMQException
089 {
090 throw new AMQMethodNotImplementedException(body);
091 }
092
093 public boolean dispatchMessageEmpty(MessageEmptyBody body, int channelId) throws AMQException
094 {
095 return false;
096 }
097
098 public boolean dispatchMessageGet(MessageGetBody body, int channelId) throws AMQException
099 {
100 throw new AMQMethodNotImplementedException(body);
101 }
102
103 public boolean dispatchMessageOffset(MessageOffsetBody body, int channelId) throws AMQException
104 {
105 return false;
106 }
107
108 public boolean dispatchMessageOk(MessageOkBody body, int channelId) throws AMQException
109 {
110 return false;
111 }
112
113 public boolean dispatchMessageOpen(MessageOpenBody body, int channelId) throws AMQException
114 {
115 return false;
116 }
117
118 public boolean dispatchMessageQos(MessageQosBody body, int channelId) throws AMQException
119 {
120 throw new AMQMethodNotImplementedException(body);
121 }
122
123 public boolean dispatchMessageRecover(MessageRecoverBody body, int channelId) throws AMQException
124 {
125 throw new AMQMethodNotImplementedException(body);
126 }
127
128 public boolean dispatchMessageReject(MessageRejectBody body, int channelId) throws AMQException
129 {
130 return false;
131 }
132
133 public boolean dispatchMessageResume(MessageResumeBody body, int channelId) throws AMQException
134 {
135 return false;
136 }
137
138 public boolean dispatchMessageTransfer(MessageTransferBody body, int channelId) throws AMQException
139 {
140 return false;
141 }
142
143 public boolean dispatchQueueUnbind(QueueUnbindBody body, int channelId) throws AMQException
144 {
145 throw new AMQMethodNotImplementedException(body);
146 }
147
148 public boolean dispatchQueueUnbindOk(QueueUnbindOkBody body, int channelId) throws AMQException
149 {
150 return false;
151 }
152
153 }
|