result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
return result;
}
+ case 50: {
+ RabbitMQ.Client.Framing.Impl.v0_8.QueueUnbind result = new RabbitMQ.Client.Framing.Impl.v0_8.QueueUnbind();
+ result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
+ return result;
+ }
+ case 51: {
+ RabbitMQ.Client.Framing.Impl.v0_8.QueueUnbindOk result = new RabbitMQ.Client.Framing.Impl.v0_8.QueueUnbindOk();
+ result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
+ return result;
+ }
case 30: {
RabbitMQ.Client.Framing.Impl.v0_8.QueuePurge result = new RabbitMQ.Client.Framing.Impl.v0_8.QueuePurge();
result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
/// </remarks>
public interface IQueueBindOk: IMethod {
}
+ /// <summary>Autogenerated type. AMQP specification method "queue.unbind".</summary>
+ /// <remarks>
+ /// This method unbinds a queue from an exchange.
+ /// </remarks>
+ public interface IQueueUnbind: IMethod {
+ /// <summary>
+ ///
+ /// The client provides a valid access ticket giving "active"
+ /// access rights to the queue's access realm.
+ ///
+ /// </summary>
+ ushort Ticket { get; }
+ /// <summary>
+ /// Specifies the name of the queue to unbind.
+ /// </summary>
+ string Queue { get; }
+ /// <summary>
+ /// The name of the exchange to unbind from.
+ /// </summary>
+ string Exchange { get; }
+ /// <summary>
+ /// Specifies the routing key of the binding to unbind.
+ /// </summary>
+ string RoutingKey { get; }
+ /// <summary>
+ /// Specifies the arguments of the binding to unbind.
+ /// </summary>
+ System.Collections.IDictionary Arguments { get; }
+ }
+ /// <summary>Autogenerated type. AMQP specification method "queue.unbind-ok".</summary>
+ /// <remarks>
+ /// This method confirms that the unbind was successful.
+ /// </remarks>
+ public interface IQueueUnbindOk: IMethod {
+ }
/// <summary>Autogenerated type. AMQP specification method "queue.purge".</summary>
/// <remarks>
///
}
}
/// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
+ public class QueueUnbind: RabbitMQ.Client.Impl.MethodBase, IQueueUnbind {
+ public const int ClassId = 50;
+ public const int MethodId = 50;
+
+ public ushort m_ticket;
+ public string m_queue;
+ public string m_exchange;
+ public string m_routingKey;
+ public System.Collections.IDictionary m_arguments;
+
+ ushort IQueueUnbind.Ticket { get { return m_ticket; } }
+ string IQueueUnbind.Queue { get { return m_queue; } }
+ string IQueueUnbind.Exchange { get { return m_exchange; } }
+ string IQueueUnbind.RoutingKey { get { return m_routingKey; } }
+ System.Collections.IDictionary IQueueUnbind.Arguments { get { return m_arguments; } }
+
+ public QueueUnbind() {}
+ public QueueUnbind(
+ ushort initTicket,
+ string initQueue,
+ string initExchange,
+ string initRoutingKey,
+ System.Collections.IDictionary initArguments)
+ {
+ m_ticket = initTicket;
+ m_queue = initQueue;
+ m_exchange = initExchange;
+ m_routingKey = initRoutingKey;
+ m_arguments = initArguments;
+ }
+
+ public override int ProtocolClassId { get { return 50; } }
+ public override int ProtocolMethodId { get { return 50; } }
+ public override string ProtocolMethodName { get { return "queue.unbind"; } }
+ public override bool HasContent { get { return false; } }
+
+ public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
+ m_ticket = reader.ReadShort();
+ m_queue = reader.ReadShortstr();
+ m_exchange = reader.ReadShortstr();
+ m_routingKey = reader.ReadShortstr();
+ m_arguments = reader.ReadTable();
+ }
+
+ public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
+ writer.WriteShort(m_ticket);
+ writer.WriteShortstr(m_queue);
+ writer.WriteShortstr(m_exchange);
+ writer.WriteShortstr(m_routingKey);
+ writer.WriteTable(m_arguments);
+ }
+
+ public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
+ sb.Append("(");
+ sb.Append(m_ticket); sb.Append(",");
+ sb.Append(m_queue); sb.Append(",");
+ sb.Append(m_exchange); sb.Append(",");
+ sb.Append(m_routingKey); sb.Append(",");
+ sb.Append(m_arguments);
+ sb.Append(")");
+ }
+ }
+ /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
+ public class QueueUnbindOk: RabbitMQ.Client.Impl.MethodBase, IQueueUnbindOk {
+ public const int ClassId = 50;
+ public const int MethodId = 51;
+
+
+
+ public QueueUnbindOk(
+)
+ {
+ }
+
+ public override int ProtocolClassId { get { return 50; } }
+ public override int ProtocolMethodId { get { return 51; } }
+ public override string ProtocolMethodName { get { return "queue.unbind-ok"; } }
+ public override bool HasContent { get { return false; } }
+
+ public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
+ }
+
+ public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
+ }
+
+ public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
+ sb.Append("(");
+ sb.Append(")");
+ }
+ }
+ /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
public class QueuePurge: RabbitMQ.Client.Impl.MethodBase, IQueuePurge {
public const int ClassId = 50;
public const int MethodId = 30;
public class Model: RabbitMQ.Client.Impl.ModelBase {
public Model(RabbitMQ.Client.Impl.ISession session): base(session) {}
- public override System.UInt16 _Private_AccessRequest(
- System.String @realm,
- System.Boolean @exclusive,
- System.Boolean @passive,
- System.Boolean @active,
- System.Boolean @write,
- System.Boolean @read)
- {
- AccessRequest __req = new AccessRequest();
- __req.m_realm = @realm;
- __req.m_exclusive = @exclusive;
- __req.m_passive = @passive;
- __req.m_active = @active;
- __req.m_write = @write;
- __req.m_read = @read;
- RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
- AccessRequestOk __rep = __repBase as AccessRequestOk;
- if (__rep == null) throw new UnexpectedMethodException(__repBase);
- return __rep.m_ticket;
- }
public override void _Private_BasicPublish(
- System.UInt16 @ticket,
System.String @exchange,
System.String @routingKey,
System.Boolean @mandatory,
System.Byte[] @body)
{
BasicPublish __req = new BasicPublish();
- __req.m_ticket = @ticket;
__req.m_exchange = @exchange;
__req.m_routingKey = @routingKey;
__req.m_mandatory = @mandatory;
ModelSend(__req, (BasicProperties) basicProperties,body);
}
public override void _Private_BasicConsume(
- System.UInt16 @ticket,
System.String @queue,
System.String @consumerTag,
System.Boolean @noLocal,
System.Collections.IDictionary @filter)
{
BasicConsume __req = new BasicConsume();
- __req.m_ticket = @ticket;
__req.m_queue = @queue;
__req.m_consumerTag = @consumerTag;
__req.m_noLocal = @noLocal;
ModelSend(__req,null,null);
}
public override void _Private_BasicGet(
- System.UInt16 @ticket,
System.String @queue,
System.Boolean @noAck)
{
BasicGet __req = new BasicGet();
- __req.m_ticket = @ticket;
__req.m_queue = @queue;
__req.m_noAck = @noAck;
ModelSend(__req,null,null);
}
+ public override void _Private_ChannelFlowOk()
+ {
+ ChannelFlowOk __req = new ChannelFlowOk();
+ ModelSend(__req,null,null);
+ }
public override RabbitMQ.Client.Impl.ConnectionTuneDetails ConnectionStartOk(
System.Collections.IDictionary @clientProperties,
System.String @mechanism,
if (__rep == null) throw new UnexpectedMethodException(__repBase);
}
public override void ExchangeDeclare(
- System.UInt16 @ticket,
System.String @exchange,
System.String @type,
System.Boolean @passive,
System.Collections.IDictionary @arguments)
{
ExchangeDeclare __req = new ExchangeDeclare();
- __req.m_ticket = @ticket;
__req.m_exchange = @exchange;
__req.m_type = @type;
__req.m_passive = @passive;
if (__rep == null) throw new UnexpectedMethodException(__repBase);
}
public override void ExchangeDelete(
- System.UInt16 @ticket,
System.String @exchange,
System.Boolean @ifUnused,
System.Boolean @nowait)
{
ExchangeDelete __req = new ExchangeDelete();
- __req.m_ticket = @ticket;
__req.m_exchange = @exchange;
__req.m_ifUnused = @ifUnused;
__req.m_nowait = @nowait;
if (__rep == null) throw new UnexpectedMethodException(__repBase);
}
public override System.String QueueDeclare(
- System.UInt16 @ticket,
System.String @queue,
System.Boolean @passive,
System.Boolean @durable,
System.Collections.IDictionary @arguments)
{
QueueDeclare __req = new QueueDeclare();
- __req.m_ticket = @ticket;
__req.m_queue = @queue;
__req.m_passive = @passive;
__req.m_durable = @durable;
return __rep.m_queue;
}
public override void QueueBind(
- System.UInt16 @ticket,
System.String @queue,
System.String @exchange,
System.String @routingKey,
System.Collections.IDictionary @arguments)
{
QueueBind __req = new QueueBind();
- __req.m_ticket = @ticket;
__req.m_queue = @queue;
__req.m_exchange = @exchange;
__req.m_routingKey = @routingKey;
if (__rep == null) throw new UnexpectedMethodException(__repBase);
}
public override void QueueUnbind(
- System.UInt16 @ticket,
System.String @queue,
System.String @exchange,
System.String @routingKey,
System.Collections.IDictionary @arguments)
{
- throw new UnsupportedMethodException("QueueUnbind");
+ QueueUnbind __req = new QueueUnbind();
+ __req.m_queue = @queue;
+ __req.m_exchange = @exchange;
+ __req.m_routingKey = @routingKey;
+ __req.m_arguments = @arguments;
+ RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
+ QueueUnbindOk __rep = __repBase as QueueUnbindOk;
+ if (__rep == null) throw new UnexpectedMethodException(__repBase);
}
public override System.UInt32 QueuePurge(
- System.UInt16 @ticket,
System.String @queue,
System.Boolean @nowait)
{
QueuePurge __req = new QueuePurge();
- __req.m_ticket = @ticket;
__req.m_queue = @queue;
__req.m_nowait = @nowait;
if (nowait) {
return __rep.m_messageCount;
}
public override System.UInt32 QueueDelete(
- System.UInt16 @ticket,
System.String @queue,
System.Boolean @ifUnused,
System.Boolean @ifEmpty,
System.Boolean @nowait)
{
QueueDelete __req = new QueueDelete();
- __req.m_ticket = @ticket;
__req.m_queue = @queue;
__req.m_ifUnused = @ifUnused;
__req.m_ifEmpty = @ifEmpty;
cmd.Body);
return true;
}
+ case 1310740: {
+ ChannelFlow __impl = (ChannelFlow) __method;
+ HandleChannelFlow(
+ __impl.m_active);
+ return true;
+ }
case 1310760: {
ChannelClose __impl = (ChannelClose) __method;
HandleChannelClose(
projects / mono.git / blobdiff