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,
throw new UnsupportedMethodException("QueueUnbind");
}
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(