in client/src/main/java/org/apache/qpid/codec/ClientDecoder.java [83:311]
void processMethod(int channelId, ByteBuffer in) throws AMQFrameDecodingException
{
ClientMethodProcessor<? extends ClientChannelMethodProcessor> methodProcessor = getMethodProcessor();
ClientChannelMethodProcessor channelMethodProcessor = methodProcessor.getChannelMethodProcessor(channelId);
final int classAndMethod = in.getInt();
int classId = classAndMethod >> 16;
int methodId = classAndMethod & 0xFFFF;
methodProcessor.setCurrentMethod(classId, methodId);
try
{
switch (classAndMethod)
{
//CONNECTION_CLASS:
case 0x000a000a:
ConnectionStartBody.process(in, methodProcessor);
break;
case 0x000a0014:
ConnectionSecureBody.process(in, methodProcessor);
break;
case 0x000a001e:
ConnectionTuneBody.process(in, methodProcessor);
break;
case 0x000a0029:
ConnectionOpenOkBody.process(in, methodProcessor);
break;
case 0x000a002a:
ConnectionRedirectBody.process(in, methodProcessor);
break;
case 0x000a0032:
if (methodProcessor.getProtocolVersion().equals(ProtocolVersion.v0_8))
{
ConnectionRedirectBody.process(in, methodProcessor);
}
else
{
ConnectionCloseBody.process(in, methodProcessor);
}
break;
case 0x000a0033:
if (methodProcessor.getProtocolVersion().equals(ProtocolVersion.v0_8))
{
throw newUnknownMethodException(classId, methodId,
methodProcessor.getProtocolVersion());
}
else
{
methodProcessor.receiveConnectionCloseOk();
}
break;
case 0x000a003c:
if (methodProcessor.getProtocolVersion().equals(ProtocolVersion.v0_8))
{
ConnectionCloseBody.process(in, methodProcessor);
}
else
{
throw newUnknownMethodException(classId, methodId,
methodProcessor.getProtocolVersion());
}
break;
case 0x000a003d:
if (methodProcessor.getProtocolVersion().equals(ProtocolVersion.v0_8))
{
methodProcessor.receiveConnectionCloseOk();
}
else
{
throw newUnknownMethodException(classId, methodId,
methodProcessor.getProtocolVersion());
}
break;
// CHANNEL_CLASS:
case 0x0014000b:
ChannelOpenOkBody.process(in, methodProcessor.getProtocolVersion(), channelMethodProcessor);
break;
case 0x00140014:
ChannelFlowBody.process(in, channelMethodProcessor);
break;
case 0x00140015:
ChannelFlowOkBody.process(in, channelMethodProcessor);
break;
case 0x0014001e:
ChannelAlertBody.process(in, channelMethodProcessor);
break;
case 0x00140028:
ChannelCloseBody.process(in, channelMethodProcessor);
break;
case 0x00140029:
channelMethodProcessor.receiveChannelCloseOk();
break;
// ACCESS_CLASS:
case 0x001e000b:
AccessRequestOkBody.process(in, channelMethodProcessor);
break;
// EXCHANGE_CLASS:
case 0x0028000b:
if(!channelMethodProcessor.ignoreAllButCloseOk())
{
channelMethodProcessor.receiveExchangeDeclareOk();
}
break;
case 0x00280015:
if(!channelMethodProcessor.ignoreAllButCloseOk())
{
channelMethodProcessor.receiveExchangeDeleteOk();
}
break;
case 0x00280017:
ExchangeBoundOkBody.process(in, channelMethodProcessor);
break;
// QUEUE_CLASS:
case 0x0032000b:
QueueDeclareOkBody.process(in, channelMethodProcessor);
break;
case 0x00320015:
if(!channelMethodProcessor.ignoreAllButCloseOk())
{
channelMethodProcessor.receiveQueueBindOk();
}
break;
case 0x0032001f:
QueuePurgeOkBody.process(in, channelMethodProcessor);
break;
case 0x00320029:
QueueDeleteOkBody.process(in, channelMethodProcessor);
break;
case 0x00320033:
if(!channelMethodProcessor.ignoreAllButCloseOk())
{
channelMethodProcessor.receiveQueueUnbindOk();
}
break;
// BASIC_CLASS:
case 0x003c000b:
if(!channelMethodProcessor.ignoreAllButCloseOk())
{
channelMethodProcessor.receiveBasicQosOk();
}
break;
case 0x003c0015:
BasicConsumeOkBody.process(in, channelMethodProcessor);
break;
case 0x003c001f:
BasicCancelOkBody.process(in, channelMethodProcessor);
break;
case 0x003c0032:
BasicReturnBody.process(in, channelMethodProcessor);
break;
case 0x003c003c:
BasicDeliverBody.process(in, channelMethodProcessor);
break;
case 0x003c0047:
BasicGetOkBody.process(in, channelMethodProcessor);
break;
case 0x003c0048:
BasicGetEmptyBody.process(in, channelMethodProcessor);
break;
case 0x003c0050:
BasicAckBody.process(in, channelMethodProcessor);
break;
case 0x003c0065:
if(!channelMethodProcessor.ignoreAllButCloseOk())
{
channelMethodProcessor.receiveBasicRecoverSyncOk();
}
break;
case 0x003c006f:
if(!channelMethodProcessor.ignoreAllButCloseOk())
{
channelMethodProcessor.receiveBasicRecoverSyncOk();
}
break;
case 0x003c0078:
BasicNackBody.process(in, channelMethodProcessor);
break;
// CONFIRM CLASS:
case 0x0055000b:
if(!channelMethodProcessor.ignoreAllButCloseOk())
{
channelMethodProcessor.receiveConfirmSelectOk();
}
break;
// TX_CLASS:
case 0x005a000b:
if(!channelMethodProcessor.ignoreAllButCloseOk())
{
channelMethodProcessor.receiveTxSelectOk();
}
break;
case 0x005a0015:
if(!channelMethodProcessor.ignoreAllButCloseOk())
{
channelMethodProcessor.receiveTxCommitOk();
}
break;
case 0x005a001f:
if(!channelMethodProcessor.ignoreAllButCloseOk())
{
channelMethodProcessor.receiveTxRollbackOk();
}
break;
default:
throw newUnknownMethodException(classId, methodId,
methodProcessor.getProtocolVersion());
}
}
finally
{
methodProcessor.setCurrentMethod(0, 0);
}
}