| /* |
| * |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| * |
| */ |
| |
| /* |
| * This file is auto-generated by Qpid Gentools v.0.1 - do not modify. |
| * Supported AMQP version: |
| * 0-9 |
| * 0-91 |
| * 8-0 |
| */ |
| |
| package org.apache.qpid.framing; |
| |
| import java.util.Map; |
| |
| public final class MethodRegistry |
| { |
| private ProtocolVersion _protocolVersion; |
| |
| |
| public MethodRegistry(ProtocolVersion pv) |
| { |
| _protocolVersion = pv; |
| } |
| |
| public void setProtocolVersion(final ProtocolVersion protocolVersion) |
| { |
| _protocolVersion = protocolVersion; |
| } |
| |
| public final AccessRequestBody createAccessRequestBody(final AMQShortString realm, |
| final boolean exclusive, |
| final boolean passive, |
| final boolean active, |
| final boolean write, |
| final boolean read) |
| { |
| return new AccessRequestBody(realm, |
| exclusive, |
| passive, |
| active, |
| write, |
| read); |
| } |
| |
| public final AccessRequestOkBody createAccessRequestOkBody(final int ticket) |
| { |
| return new AccessRequestOkBody(ticket); |
| } |
| |
| |
| public final BasicQosBody createBasicQosBody(final long prefetchSize, |
| final int prefetchCount, |
| final boolean global) |
| { |
| return new BasicQosBody(prefetchSize, |
| prefetchCount, |
| global); |
| } |
| |
| public final BasicQosOkBody createBasicQosOkBody() |
| { |
| return new BasicQosOkBody(); |
| } |
| |
| public final BasicConsumeBody createBasicConsumeBody(final int ticket, |
| final String queue, |
| final String consumerTag, |
| final boolean noLocal, |
| final boolean noAck, |
| final boolean exclusive, |
| final boolean nowait, |
| final Map<String,Object> arguments) |
| { |
| |
| return new BasicConsumeBody(ticket, |
| AMQShortString.valueOf(queue), |
| AMQShortString.valueOf(consumerTag), |
| noLocal, |
| noAck, |
| exclusive, |
| nowait, |
| FieldTable.convertToFieldTable(arguments)); |
| } |
| |
| public final BasicConsumeOkBody createBasicConsumeOkBody(final AMQShortString consumerTag) |
| { |
| return new BasicConsumeOkBody(consumerTag); |
| } |
| |
| public final BasicCancelBody createBasicCancelBody(final AMQShortString consumerTag, |
| final boolean nowait) |
| { |
| return new BasicCancelBody(consumerTag, |
| nowait); |
| } |
| |
| public final BasicCancelOkBody createBasicCancelOkBody(final AMQShortString consumerTag) |
| { |
| return new BasicCancelOkBody(consumerTag); |
| } |
| |
| public final BasicPublishBody createBasicPublishBody(final int ticket, |
| final String exchange, |
| final String routingKey, |
| final boolean mandatory, |
| final boolean immediate) |
| { |
| return new BasicPublishBody(ticket, |
| AMQShortString.valueOf(exchange), |
| AMQShortString.valueOf(routingKey), |
| mandatory, |
| immediate); |
| } |
| |
| public final BasicReturnBody createBasicReturnBody(final int replyCode, |
| final AMQShortString replyText, |
| final AMQShortString exchange, |
| final AMQShortString routingKey) |
| { |
| return new BasicReturnBody(replyCode, |
| replyText, |
| exchange, |
| routingKey); |
| } |
| |
| public final BasicDeliverBody createBasicDeliverBody(final AMQShortString consumerTag, |
| final long deliveryTag, |
| final boolean redelivered, |
| final AMQShortString exchange, |
| final AMQShortString routingKey) |
| { |
| return new BasicDeliverBody(consumerTag, |
| deliveryTag, |
| redelivered, |
| exchange, |
| routingKey); |
| } |
| |
| public final BasicGetBody createBasicGetBody(final int ticket, |
| final AMQShortString queue, |
| final boolean noAck) |
| { |
| return new BasicGetBody(ticket, |
| queue, |
| noAck); |
| } |
| |
| public final BasicGetOkBody createBasicGetOkBody(final long deliveryTag, |
| final boolean redelivered, |
| final AMQShortString exchange, |
| final AMQShortString routingKey, |
| final long messageCount) |
| { |
| return new BasicGetOkBody(deliveryTag, |
| redelivered, |
| exchange, |
| routingKey, |
| messageCount); |
| } |
| |
| public final BasicGetEmptyBody createBasicGetEmptyBody(final AMQShortString clusterId) |
| { |
| return new BasicGetEmptyBody(clusterId); |
| } |
| |
| public final BasicAckBody createBasicAckBody(final long deliveryTag, |
| final boolean multiple) |
| { |
| return new BasicAckBody(deliveryTag, |
| multiple); |
| } |
| |
| public final BasicRejectBody createBasicRejectBody(final long deliveryTag, |
| final boolean requeue) |
| { |
| return new BasicRejectBody(deliveryTag, |
| requeue); |
| } |
| |
| public final BasicRecoverBody createBasicRecoverBody(final boolean requeue) |
| { |
| return new BasicRecoverBody(requeue); |
| } |
| |
| |
| public final BasicRecoverSyncOkBody createBasicRecoverSyncOkBody() |
| { |
| return new BasicRecoverSyncOkBody(_protocolVersion); |
| } |
| |
| |
| public final BasicRecoverSyncBody createBasicRecoverSyncBody(final boolean requeue) |
| { |
| return new BasicRecoverSyncBody(_protocolVersion, requeue); |
| } |
| |
| public final ChannelAlertBody createChannelAlertBody(final int replyCode, |
| final AMQShortString replyText, |
| final FieldTable details) |
| { |
| return new ChannelAlertBody(replyCode, |
| replyText, |
| details); |
| } |
| |
| public final ChannelOpenBody createChannelOpenBody(final AMQShortString outOfBand) |
| { |
| return new ChannelOpenBody(); |
| } |
| |
| public final ChannelOpenOkBody createChannelOpenOkBody(byte[] channelId) |
| { |
| return createChannelOpenOkBody(); |
| } |
| |
| public final ChannelOpenOkBody createChannelOpenOkBody() |
| { |
| return _protocolVersion.equals(ProtocolVersion.v0_8) |
| ? ChannelOpenOkBody.INSTANCE_0_8 |
| : ChannelOpenOkBody.INSTANCE_0_9; |
| } |
| |
| public final ChannelFlowBody createChannelFlowBody(final boolean active) |
| { |
| return new ChannelFlowBody(active); |
| } |
| |
| public final ChannelFlowOkBody createChannelFlowOkBody(final boolean active) |
| { |
| return new ChannelFlowOkBody(active); |
| } |
| |
| public final ChannelCloseBody createChannelCloseBody(final int replyCode, final AMQShortString replyText, |
| final int classId, |
| final int methodId |
| ) |
| { |
| return new ChannelCloseBody(replyCode, |
| replyText, |
| classId, |
| methodId); |
| } |
| |
| public final ChannelCloseOkBody createChannelCloseOkBody() |
| { |
| return ChannelCloseOkBody.INSTANCE; |
| } |
| |
| |
| |
| |
| public final ConnectionStartBody createConnectionStartBody(final short versionMajor, |
| final short versionMinor, |
| final FieldTable serverProperties, |
| final byte[] mechanisms, |
| final byte[] locales) |
| { |
| return new ConnectionStartBody(versionMajor, |
| versionMinor, |
| serverProperties, |
| mechanisms, |
| locales); |
| } |
| |
| public final ConnectionStartOkBody createConnectionStartOkBody(final FieldTable clientProperties, |
| final AMQShortString mechanism, |
| final byte[] response, |
| final AMQShortString locale) |
| { |
| return new ConnectionStartOkBody(clientProperties, |
| mechanism, |
| response, |
| locale); |
| } |
| |
| public final ConnectionSecureBody createConnectionSecureBody(final byte[] challenge) |
| { |
| return new ConnectionSecureBody(challenge); |
| } |
| |
| public final ConnectionSecureOkBody createConnectionSecureOkBody(final byte[] response) |
| { |
| return new ConnectionSecureOkBody(response); |
| } |
| |
| public final ConnectionTuneBody createConnectionTuneBody(final int channelMax, |
| final long frameMax, |
| final int heartbeat) |
| { |
| return new ConnectionTuneBody(channelMax, |
| frameMax, |
| heartbeat); |
| } |
| |
| public final ConnectionTuneOkBody createConnectionTuneOkBody(final int channelMax, |
| final long frameMax, |
| final int heartbeat) |
| { |
| return new ConnectionTuneOkBody(channelMax, |
| frameMax, |
| heartbeat); |
| } |
| |
| public final ConnectionOpenBody createConnectionOpenBody(final AMQShortString virtualHost, |
| final AMQShortString capabilities, |
| final boolean insist) |
| { |
| return new ConnectionOpenBody(virtualHost, |
| capabilities, |
| insist); |
| } |
| |
| public final ConnectionOpenOkBody createConnectionOpenOkBody(final AMQShortString knownHosts) |
| { |
| return new ConnectionOpenOkBody(knownHosts); |
| } |
| |
| public final ConnectionRedirectBody createConnectionRedirectBody(final AMQShortString host, |
| final AMQShortString knownHosts) |
| { |
| return new ConnectionRedirectBody(_protocolVersion, |
| host, |
| knownHosts); |
| } |
| |
| public final ConnectionCloseBody createConnectionCloseBody(final int replyCode, |
| final AMQShortString replyText, |
| final int classId, |
| final int methodId) |
| { |
| return new ConnectionCloseBody(_protocolVersion, |
| replyCode, |
| replyText, |
| classId, |
| methodId); |
| } |
| |
| public final ConnectionCloseOkBody createConnectionCloseOkBody() |
| { |
| return ProtocolVersion.v0_8.equals(_protocolVersion) |
| ? ConnectionCloseOkBody.CONNECTION_CLOSE_OK_0_8 |
| : ConnectionCloseOkBody.CONNECTION_CLOSE_OK_0_9; |
| } |
| |
| |
| public final ExchangeDeclareBody createExchangeDeclareBody(final int ticket, |
| final String exchange, |
| final String type, |
| final boolean passive, |
| final boolean durable, |
| final boolean autoDelete, |
| final boolean internal, |
| final boolean nowait, |
| final Map<String,Object> arguments) |
| { |
| |
| return new ExchangeDeclareBody(ticket, |
| AMQShortString.valueOf(exchange), |
| AMQShortString.valueOf(type), |
| passive, |
| durable, |
| autoDelete, |
| internal, |
| nowait, |
| FieldTable.convertToFieldTable(arguments)); |
| } |
| |
| public final ExchangeDeclareOkBody createExchangeDeclareOkBody() |
| { |
| return new ExchangeDeclareOkBody(); |
| } |
| |
| public final ExchangeDeleteBody createExchangeDeleteBody(final int ticket, |
| final String exchange, |
| final boolean ifUnused, |
| final boolean nowait) |
| { |
| return new ExchangeDeleteBody(ticket, |
| AMQShortString.valueOf(exchange), |
| ifUnused, |
| nowait |
| ); |
| } |
| |
| public final ExchangeDeleteOkBody createExchangeDeleteOkBody() |
| { |
| return new ExchangeDeleteOkBody(); |
| } |
| |
| public final ExchangeBoundBody createExchangeBoundBody(final String exchange, |
| final String routingKey, |
| final String queue) |
| { |
| return new ExchangeBoundBody(AMQShortString.valueOf(exchange), |
| AMQShortString.valueOf(routingKey), |
| AMQShortString.valueOf(queue)); |
| } |
| |
| public final ExchangeBoundOkBody createExchangeBoundOkBody(final int replyCode, |
| final AMQShortString replyText) |
| { |
| return new ExchangeBoundOkBody(replyCode, |
| replyText); |
| } |
| |
| |
| public final QueueDeclareBody createQueueDeclareBody(final int ticket, |
| final String queue, |
| final boolean passive, |
| final boolean durable, |
| final boolean exclusive, |
| final boolean autoDelete, |
| final boolean nowait, |
| final Map<String,Object> arguments) |
| { |
| |
| return new QueueDeclareBody(ticket, |
| AMQShortString.valueOf(queue), |
| passive, |
| durable, |
| exclusive, |
| autoDelete, |
| nowait, |
| FieldTable.convertToFieldTable(arguments)); |
| } |
| |
| public final QueueDeclareOkBody createQueueDeclareOkBody(final AMQShortString queue, |
| final long messageCount, |
| final long consumerCount) |
| { |
| return new QueueDeclareOkBody(queue, |
| messageCount, |
| consumerCount); |
| } |
| |
| public final QueueBindBody createQueueBindBody(final int ticket, |
| final String queue, |
| final String exchange, |
| final String routingKey, |
| final boolean nowait, |
| final Map<String,Object> arguments) |
| { |
| |
| return new QueueBindBody(ticket, |
| AMQShortString.valueOf(queue), |
| AMQShortString.valueOf(exchange), |
| AMQShortString.valueOf(routingKey), |
| nowait, |
| FieldTable.convertToFieldTable(arguments)); |
| |
| } |
| |
| |
| public final QueueBindOkBody createQueueBindOkBody() |
| { |
| return new QueueBindOkBody(); |
| } |
| |
| public final QueuePurgeBody createQueuePurgeBody(final int ticket, |
| final AMQShortString queue, |
| final boolean nowait) |
| { |
| return new QueuePurgeBody(ticket, |
| queue, |
| nowait); |
| } |
| |
| public final QueuePurgeOkBody createQueuePurgeOkBody(final long messageCount) |
| { |
| return new QueuePurgeOkBody(messageCount); |
| } |
| |
| public final QueueDeleteBody createQueueDeleteBody(final int ticket, |
| final String queue, |
| final boolean ifUnused, |
| final boolean ifEmpty, |
| final boolean nowait) |
| { |
| return new QueueDeleteBody(ticket, |
| AMQShortString.valueOf(queue), |
| ifUnused, |
| ifEmpty, |
| nowait); |
| } |
| |
| public final QueueDeleteOkBody createQueueDeleteOkBody(final long messageCount) |
| { |
| return new QueueDeleteOkBody(messageCount); |
| } |
| |
| public final QueueUnbindBody createQueueUnbindBody(final int ticket, |
| final AMQShortString queue, |
| final AMQShortString exchange, |
| final AMQShortString routingKey, |
| final FieldTable arguments) |
| { |
| return new QueueUnbindBody(ticket, |
| queue, |
| exchange, |
| routingKey, |
| arguments); |
| } |
| |
| public final QueueUnbindOkBody createQueueUnbindOkBody() |
| { |
| return new QueueUnbindOkBody(); |
| } |
| |
| |
| public final TxSelectBody createTxSelectBody() |
| { |
| return TxSelectBody.INSTANCE; |
| } |
| |
| public final TxSelectOkBody createTxSelectOkBody() |
| { |
| return TxSelectOkBody.INSTANCE; |
| } |
| |
| public final TxCommitBody createTxCommitBody() |
| { |
| return TxCommitBody.INSTANCE; |
| } |
| |
| public final TxCommitOkBody createTxCommitOkBody() |
| { |
| return TxCommitOkBody.INSTANCE; |
| } |
| |
| public final TxRollbackBody createTxRollbackBody() |
| { |
| return TxRollbackBody.INSTANCE; |
| } |
| |
| public final TxRollbackOkBody createTxRollbackOkBody() |
| { |
| return TxRollbackOkBody.INSTANCE; |
| } |
| |
| public ProtocolVersion getProtocolVersion() |
| { |
| return _protocolVersion; |
| } |
| |
| |
| } |