1 // Autogenerated code. Do not edit.
3 // This source code is dual-licensed under the Apache License, version
4 // 2.0, and the Mozilla Public License, version 1.1.
8 //---------------------------------------------------------------------------
9 // Copyright (C) 2007-2010 LShift Ltd., Cohesive Financial
10 // Technologies LLC., and Rabbit Technologies Ltd.
12 // Licensed under the Apache License, Version 2.0 (the "License");
13 // you may not use this file except in compliance with the License.
14 // You may obtain a copy of the License at
16 // http://www.apache.org/licenses/LICENSE-2.0
18 // Unless required by applicable law or agreed to in writing, software
19 // distributed under the License is distributed on an "AS IS" BASIS,
20 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
21 // See the License for the specific language governing permissions and
22 // limitations under the License.
23 //---------------------------------------------------------------------------
27 //---------------------------------------------------------------------------
28 // The contents of this file are subject to the Mozilla Public License
29 // Version 1.1 (the "License"); you may not use this file except in
30 // compliance with the License. You may obtain a copy of the License at
31 // http://www.rabbitmq.com/mpl.html
33 // Software distributed under the License is distributed on an "AS IS"
34 // basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the
35 // License for the specific language governing rights and limitations
38 // The Original Code is The RabbitMQ .NET Client.
40 // The Initial Developers of the Original Code are LShift Ltd,
41 // Cohesive Financial Technologies LLC, and Rabbit Technologies Ltd.
43 // Portions created before 22-Nov-2008 00:00:00 GMT by LShift Ltd,
44 // Cohesive Financial Technologies LLC, or Rabbit Technologies Ltd
45 // are Copyright (C) 2007-2008 LShift Ltd, Cohesive Financial
46 // Technologies LLC, and Rabbit Technologies Ltd.
48 // Portions created by LShift Ltd are Copyright (C) 2007-2010 LShift
49 // Ltd. Portions created by Cohesive Financial Technologies LLC are
50 // Copyright (C) 2007-2010 Cohesive Financial Technologies
51 // LLC. Portions created by Rabbit Technologies Ltd are Copyright
52 // (C) 2007-2010 Rabbit Technologies Ltd.
54 // All Rights Reserved.
56 // Contributor(s): ______________________________________.
58 //---------------------------------------------------------------------------
60 using RabbitMQ.Client;
61 using RabbitMQ.Client.Exceptions;
63 namespace RabbitMQ.Client.Framing.v0_9 {
64 public class Protocol: RabbitMQ.Client.Framing.Impl.v0_9.ProtocolBase {
65 ///<summary>Protocol major version (= 0)</summary>
66 public override int MajorVersion { get { return 0; } }
67 ///<summary>Protocol minor version (= 9)</summary>
68 public override int MinorVersion { get { return 9; } }
69 ///<summary>Protocol API name (= AMQP_0_9)</summary>
70 public override string ApiName { get { return "AMQP_0_9"; } }
71 ///<summary>Default TCP port (= 5672)</summary>
72 public override int DefaultPort { get { return 5672; } }
74 public override RabbitMQ.Client.Impl.MethodBase DecodeMethodFrom(RabbitMQ.Util.NetworkBinaryReader reader) {
75 ushort classId = reader.ReadUInt16();
76 ushort methodId = reader.ReadUInt16();
82 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionStart result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionStart();
83 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
87 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionStartOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionStartOk();
88 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
92 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionSecure result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionSecure();
93 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
97 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionSecureOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionSecureOk();
98 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
102 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionTune result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionTune();
103 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
107 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionTuneOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionTuneOk();
108 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
112 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionOpen result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionOpen();
113 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
117 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionOpenOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionOpenOk();
118 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
122 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionRedirect result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionRedirect();
123 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
127 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionClose result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionClose();
128 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
132 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionCloseOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionCloseOk();
133 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
143 RabbitMQ.Client.Framing.Impl.v0_9.ChannelOpen result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelOpen();
144 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
148 RabbitMQ.Client.Framing.Impl.v0_9.ChannelOpenOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelOpenOk();
149 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
153 RabbitMQ.Client.Framing.Impl.v0_9.ChannelFlow result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelFlow();
154 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
158 RabbitMQ.Client.Framing.Impl.v0_9.ChannelFlowOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelFlowOk();
159 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
163 RabbitMQ.Client.Framing.Impl.v0_9.ChannelClose result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelClose();
164 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
168 RabbitMQ.Client.Framing.Impl.v0_9.ChannelCloseOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelCloseOk();
169 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
173 RabbitMQ.Client.Framing.Impl.v0_9.ChannelResume result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelResume();
174 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
178 RabbitMQ.Client.Framing.Impl.v0_9.ChannelPing result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelPing();
179 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
183 RabbitMQ.Client.Framing.Impl.v0_9.ChannelPong result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelPong();
184 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
188 RabbitMQ.Client.Framing.Impl.v0_9.ChannelOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelOk();
189 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
199 RabbitMQ.Client.Framing.Impl.v0_9.AccessRequest result = new RabbitMQ.Client.Framing.Impl.v0_9.AccessRequest();
200 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
204 RabbitMQ.Client.Framing.Impl.v0_9.AccessRequestOk result = new RabbitMQ.Client.Framing.Impl.v0_9.AccessRequestOk();
205 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
215 RabbitMQ.Client.Framing.Impl.v0_9.ExchangeDeclare result = new RabbitMQ.Client.Framing.Impl.v0_9.ExchangeDeclare();
216 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
220 RabbitMQ.Client.Framing.Impl.v0_9.ExchangeDeclareOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ExchangeDeclareOk();
221 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
225 RabbitMQ.Client.Framing.Impl.v0_9.ExchangeDelete result = new RabbitMQ.Client.Framing.Impl.v0_9.ExchangeDelete();
226 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
230 RabbitMQ.Client.Framing.Impl.v0_9.ExchangeDeleteOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ExchangeDeleteOk();
231 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
241 RabbitMQ.Client.Framing.Impl.v0_9.QueueDeclare result = new RabbitMQ.Client.Framing.Impl.v0_9.QueueDeclare();
242 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
246 RabbitMQ.Client.Framing.Impl.v0_9.QueueDeclareOk result = new RabbitMQ.Client.Framing.Impl.v0_9.QueueDeclareOk();
247 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
251 RabbitMQ.Client.Framing.Impl.v0_9.QueueBind result = new RabbitMQ.Client.Framing.Impl.v0_9.QueueBind();
252 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
256 RabbitMQ.Client.Framing.Impl.v0_9.QueueBindOk result = new RabbitMQ.Client.Framing.Impl.v0_9.QueueBindOk();
257 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
261 RabbitMQ.Client.Framing.Impl.v0_9.QueueUnbind result = new RabbitMQ.Client.Framing.Impl.v0_9.QueueUnbind();
262 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
266 RabbitMQ.Client.Framing.Impl.v0_9.QueueUnbindOk result = new RabbitMQ.Client.Framing.Impl.v0_9.QueueUnbindOk();
267 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
271 RabbitMQ.Client.Framing.Impl.v0_9.QueuePurge result = new RabbitMQ.Client.Framing.Impl.v0_9.QueuePurge();
272 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
276 RabbitMQ.Client.Framing.Impl.v0_9.QueuePurgeOk result = new RabbitMQ.Client.Framing.Impl.v0_9.QueuePurgeOk();
277 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
281 RabbitMQ.Client.Framing.Impl.v0_9.QueueDelete result = new RabbitMQ.Client.Framing.Impl.v0_9.QueueDelete();
282 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
286 RabbitMQ.Client.Framing.Impl.v0_9.QueueDeleteOk result = new RabbitMQ.Client.Framing.Impl.v0_9.QueueDeleteOk();
287 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
297 RabbitMQ.Client.Framing.Impl.v0_9.BasicQos result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicQos();
298 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
302 RabbitMQ.Client.Framing.Impl.v0_9.BasicQosOk result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicQosOk();
303 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
307 RabbitMQ.Client.Framing.Impl.v0_9.BasicConsume result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicConsume();
308 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
312 RabbitMQ.Client.Framing.Impl.v0_9.BasicConsumeOk result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicConsumeOk();
313 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
317 RabbitMQ.Client.Framing.Impl.v0_9.BasicCancel result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicCancel();
318 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
322 RabbitMQ.Client.Framing.Impl.v0_9.BasicCancelOk result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicCancelOk();
323 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
327 RabbitMQ.Client.Framing.Impl.v0_9.BasicPublish result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicPublish();
328 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
332 RabbitMQ.Client.Framing.Impl.v0_9.BasicReturn result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicReturn();
333 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
337 RabbitMQ.Client.Framing.Impl.v0_9.BasicDeliver result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicDeliver();
338 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
342 RabbitMQ.Client.Framing.Impl.v0_9.BasicGet result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicGet();
343 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
347 RabbitMQ.Client.Framing.Impl.v0_9.BasicGetOk result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicGetOk();
348 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
352 RabbitMQ.Client.Framing.Impl.v0_9.BasicGetEmpty result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicGetEmpty();
353 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
357 RabbitMQ.Client.Framing.Impl.v0_9.BasicAck result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicAck();
358 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
362 RabbitMQ.Client.Framing.Impl.v0_9.BasicReject result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicReject();
363 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
367 RabbitMQ.Client.Framing.Impl.v0_9.BasicRecover result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicRecover();
368 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
378 RabbitMQ.Client.Framing.Impl.v0_9.FileQos result = new RabbitMQ.Client.Framing.Impl.v0_9.FileQos();
379 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
383 RabbitMQ.Client.Framing.Impl.v0_9.FileQosOk result = new RabbitMQ.Client.Framing.Impl.v0_9.FileQosOk();
384 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
388 RabbitMQ.Client.Framing.Impl.v0_9.FileConsume result = new RabbitMQ.Client.Framing.Impl.v0_9.FileConsume();
389 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
393 RabbitMQ.Client.Framing.Impl.v0_9.FileConsumeOk result = new RabbitMQ.Client.Framing.Impl.v0_9.FileConsumeOk();
394 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
398 RabbitMQ.Client.Framing.Impl.v0_9.FileCancel result = new RabbitMQ.Client.Framing.Impl.v0_9.FileCancel();
399 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
403 RabbitMQ.Client.Framing.Impl.v0_9.FileCancelOk result = new RabbitMQ.Client.Framing.Impl.v0_9.FileCancelOk();
404 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
408 RabbitMQ.Client.Framing.Impl.v0_9.FileOpen result = new RabbitMQ.Client.Framing.Impl.v0_9.FileOpen();
409 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
413 RabbitMQ.Client.Framing.Impl.v0_9.FileOpenOk result = new RabbitMQ.Client.Framing.Impl.v0_9.FileOpenOk();
414 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
418 RabbitMQ.Client.Framing.Impl.v0_9.FileStage result = new RabbitMQ.Client.Framing.Impl.v0_9.FileStage();
419 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
423 RabbitMQ.Client.Framing.Impl.v0_9.FilePublish result = new RabbitMQ.Client.Framing.Impl.v0_9.FilePublish();
424 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
428 RabbitMQ.Client.Framing.Impl.v0_9.FileReturn result = new RabbitMQ.Client.Framing.Impl.v0_9.FileReturn();
429 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
433 RabbitMQ.Client.Framing.Impl.v0_9.FileDeliver result = new RabbitMQ.Client.Framing.Impl.v0_9.FileDeliver();
434 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
438 RabbitMQ.Client.Framing.Impl.v0_9.FileAck result = new RabbitMQ.Client.Framing.Impl.v0_9.FileAck();
439 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
443 RabbitMQ.Client.Framing.Impl.v0_9.FileReject result = new RabbitMQ.Client.Framing.Impl.v0_9.FileReject();
444 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
454 RabbitMQ.Client.Framing.Impl.v0_9.StreamQos result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamQos();
455 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
459 RabbitMQ.Client.Framing.Impl.v0_9.StreamQosOk result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamQosOk();
460 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
464 RabbitMQ.Client.Framing.Impl.v0_9.StreamConsume result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamConsume();
465 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
469 RabbitMQ.Client.Framing.Impl.v0_9.StreamConsumeOk result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamConsumeOk();
470 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
474 RabbitMQ.Client.Framing.Impl.v0_9.StreamCancel result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamCancel();
475 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
479 RabbitMQ.Client.Framing.Impl.v0_9.StreamCancelOk result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamCancelOk();
480 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
484 RabbitMQ.Client.Framing.Impl.v0_9.StreamPublish result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamPublish();
485 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
489 RabbitMQ.Client.Framing.Impl.v0_9.StreamReturn result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamReturn();
490 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
494 RabbitMQ.Client.Framing.Impl.v0_9.StreamDeliver result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamDeliver();
495 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
505 RabbitMQ.Client.Framing.Impl.v0_9.TxSelect result = new RabbitMQ.Client.Framing.Impl.v0_9.TxSelect();
506 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
510 RabbitMQ.Client.Framing.Impl.v0_9.TxSelectOk result = new RabbitMQ.Client.Framing.Impl.v0_9.TxSelectOk();
511 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
515 RabbitMQ.Client.Framing.Impl.v0_9.TxCommit result = new RabbitMQ.Client.Framing.Impl.v0_9.TxCommit();
516 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
520 RabbitMQ.Client.Framing.Impl.v0_9.TxCommitOk result = new RabbitMQ.Client.Framing.Impl.v0_9.TxCommitOk();
521 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
525 RabbitMQ.Client.Framing.Impl.v0_9.TxRollback result = new RabbitMQ.Client.Framing.Impl.v0_9.TxRollback();
526 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
530 RabbitMQ.Client.Framing.Impl.v0_9.TxRollbackOk result = new RabbitMQ.Client.Framing.Impl.v0_9.TxRollbackOk();
531 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
541 RabbitMQ.Client.Framing.Impl.v0_9.DtxSelect result = new RabbitMQ.Client.Framing.Impl.v0_9.DtxSelect();
542 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
546 RabbitMQ.Client.Framing.Impl.v0_9.DtxSelectOk result = new RabbitMQ.Client.Framing.Impl.v0_9.DtxSelectOk();
547 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
551 RabbitMQ.Client.Framing.Impl.v0_9.DtxStart result = new RabbitMQ.Client.Framing.Impl.v0_9.DtxStart();
552 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
556 RabbitMQ.Client.Framing.Impl.v0_9.DtxStartOk result = new RabbitMQ.Client.Framing.Impl.v0_9.DtxStartOk();
557 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
567 RabbitMQ.Client.Framing.Impl.v0_9.TunnelRequest result = new RabbitMQ.Client.Framing.Impl.v0_9.TunnelRequest();
568 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
578 RabbitMQ.Client.Framing.Impl.v0_9.MessageTransfer result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageTransfer();
579 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
583 RabbitMQ.Client.Framing.Impl.v0_9.MessageConsume result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageConsume();
584 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
588 RabbitMQ.Client.Framing.Impl.v0_9.MessageCancel result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageCancel();
589 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
593 RabbitMQ.Client.Framing.Impl.v0_9.MessageGet result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageGet();
594 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
598 RabbitMQ.Client.Framing.Impl.v0_9.MessageRecover result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageRecover();
599 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
603 RabbitMQ.Client.Framing.Impl.v0_9.MessageOpen result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageOpen();
604 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
608 RabbitMQ.Client.Framing.Impl.v0_9.MessageClose result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageClose();
609 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
613 RabbitMQ.Client.Framing.Impl.v0_9.MessageAppend result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageAppend();
614 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
618 RabbitMQ.Client.Framing.Impl.v0_9.MessageCheckpoint result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageCheckpoint();
619 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
623 RabbitMQ.Client.Framing.Impl.v0_9.MessageResume result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageResume();
624 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
628 RabbitMQ.Client.Framing.Impl.v0_9.MessageQos result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageQos();
629 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
633 RabbitMQ.Client.Framing.Impl.v0_9.MessageOk result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageOk();
634 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
638 RabbitMQ.Client.Framing.Impl.v0_9.MessageEmpty result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageEmpty();
639 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
643 RabbitMQ.Client.Framing.Impl.v0_9.MessageReject result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageReject();
644 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
648 RabbitMQ.Client.Framing.Impl.v0_9.MessageOffset result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageOffset();
649 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
658 throw new RabbitMQ.Client.Impl.UnknownClassOrMethodException(classId, methodId);
661 public override RabbitMQ.Client.Impl.ContentHeaderBase DecodeContentHeaderFrom(RabbitMQ.Util.NetworkBinaryReader reader) {
662 ushort classId = reader.ReadUInt16();
665 case 60: return new BasicProperties();
666 case 70: return new FileProperties();
667 case 80: return new StreamProperties();
668 case 110: return new TunnelProperties();
671 throw new RabbitMQ.Client.Impl.UnknownClassOrMethodException(classId, 0);
674 public class Constants {
675 ///<summary>(= 1)</summary>
676 public const int FrameMethod = 1;
677 ///<summary>(= 2)</summary>
678 public const int FrameHeader = 2;
679 ///<summary>(= 3)</summary>
680 public const int FrameBody = 3;
681 ///<summary>(= 4)</summary>
682 public const int FrameOobMethod = 4;
683 ///<summary>(= 5)</summary>
684 public const int FrameOobHeader = 5;
685 ///<summary>(= 6)</summary>
686 public const int FrameOobBody = 6;
687 ///<summary>(= 7)</summary>
688 public const int FrameTrace = 7;
689 ///<summary>(= 8)</summary>
690 public const int FrameHeartbeat = 8;
691 ///<summary>(= 4096)</summary>
692 public const int FrameMinSize = 4096;
693 ///<summary>(= 206)</summary>
694 public const int FrameEnd = 206;
695 ///<summary>(= 200)</summary>
696 public const int ReplySuccess = 200;
697 ///<summary>(= 310)</summary>
698 public const int NotDelivered = 310;
699 ///<summary>(= 311)</summary>
700 public const int ContentTooLarge = 311;
701 ///<summary>(= 312)</summary>
702 public const int NoRoute = 312;
703 ///<summary>(= 313)</summary>
704 public const int NoConsumers = 313;
705 ///<summary>(= 320)</summary>
706 public const int ConnectionForced = 320;
707 ///<summary>(= 402)</summary>
708 public const int InvalidPath = 402;
709 ///<summary>(= 403)</summary>
710 public const int AccessRefused = 403;
711 ///<summary>(= 404)</summary>
712 public const int NotFound = 404;
713 ///<summary>(= 405)</summary>
714 public const int ResourceLocked = 405;
715 ///<summary>(= 406)</summary>
716 public const int PreconditionFailed = 406;
717 ///<summary>(= 501)</summary>
718 public const int FrameError = 501;
719 ///<summary>(= 502)</summary>
720 public const int SyntaxError = 502;
721 ///<summary>(= 503)</summary>
722 public const int CommandInvalid = 503;
723 ///<summary>(= 504)</summary>
724 public const int ChannelError = 504;
725 ///<summary>(= 506)</summary>
726 public const int ResourceError = 506;
727 ///<summary>(= 530)</summary>
728 public const int NotAllowed = 530;
729 ///<summary>(= 540)</summary>
730 public const int NotImplemented = 540;
731 ///<summary>(= 541)</summary>
732 public const int InternalError = 541;
734 /// <summary>Autogenerated type. AMQP specification method "connection.start".</summary>
735 public interface IConnectionStart: IMethod {
736 byte VersionMajor { get; }
737 byte VersionMinor { get; }
738 System.Collections.IDictionary ServerProperties { get; }
739 byte[] Mechanisms { get; }
740 byte[] Locales { get; }
742 /// <summary>Autogenerated type. AMQP specification method "connection.start-ok".</summary>
743 public interface IConnectionStartOk: IMethod {
744 System.Collections.IDictionary ClientProperties { get; }
745 string Mechanism { get; }
746 byte[] Response { get; }
747 string Locale { get; }
749 /// <summary>Autogenerated type. AMQP specification method "connection.secure".</summary>
750 public interface IConnectionSecure: IMethod {
751 byte[] Challenge { get; }
753 /// <summary>Autogenerated type. AMQP specification method "connection.secure-ok".</summary>
754 public interface IConnectionSecureOk: IMethod {
755 byte[] Response { get; }
757 /// <summary>Autogenerated type. AMQP specification method "connection.tune".</summary>
758 public interface IConnectionTune: IMethod {
759 ushort ChannelMax { get; }
760 uint FrameMax { get; }
761 ushort Heartbeat { get; }
763 /// <summary>Autogenerated type. AMQP specification method "connection.tune-ok".</summary>
764 public interface IConnectionTuneOk: IMethod {
765 ushort ChannelMax { get; }
766 uint FrameMax { get; }
767 ushort Heartbeat { get; }
769 /// <summary>Autogenerated type. AMQP specification method "connection.open".</summary>
770 public interface IConnectionOpen: IMethod {
771 string VirtualHost { get; }
772 string Capabilities { get; }
775 /// <summary>Autogenerated type. AMQP specification method "connection.open-ok".</summary>
776 public interface IConnectionOpenOk: IMethod {
777 string KnownHosts { get; }
779 /// <summary>Autogenerated type. AMQP specification method "connection.redirect".</summary>
780 public interface IConnectionRedirect: IMethod {
782 string KnownHosts { get; }
784 /// <summary>Autogenerated type. AMQP specification method "connection.close".</summary>
785 public interface IConnectionClose: IMethod {
786 ushort ReplyCode { get; }
787 string ReplyText { get; }
788 ushort ClassId { get; }
789 ushort MethodId { get; }
791 /// <summary>Autogenerated type. AMQP specification method "connection.close-ok".</summary>
792 public interface IConnectionCloseOk: IMethod {
794 /// <summary>Autogenerated type. AMQP specification method "channel.open".</summary>
795 public interface IChannelOpen: IMethod {
796 string OutOfBand { get; }
798 /// <summary>Autogenerated type. AMQP specification method "channel.open-ok".</summary>
799 public interface IChannelOpenOk: IMethod {
800 byte[] ChannelId { get; }
802 /// <summary>Autogenerated type. AMQP specification method "channel.flow".</summary>
803 public interface IChannelFlow: IMethod {
806 /// <summary>Autogenerated type. AMQP specification method "channel.flow-ok".</summary>
807 public interface IChannelFlowOk: IMethod {
810 /// <summary>Autogenerated type. AMQP specification method "channel.close".</summary>
811 public interface IChannelClose: IMethod {
812 ushort ReplyCode { get; }
813 string ReplyText { get; }
814 ushort ClassId { get; }
815 ushort MethodId { get; }
817 /// <summary>Autogenerated type. AMQP specification method "channel.close-ok".</summary>
818 public interface IChannelCloseOk: IMethod {
820 /// <summary>Autogenerated type. AMQP specification method "channel.resume".</summary>
821 public interface IChannelResume: IMethod {
822 byte[] ChannelId { get; }
824 /// <summary>Autogenerated type. AMQP specification method "channel.ping".</summary>
825 public interface IChannelPing: IMethod {
827 /// <summary>Autogenerated type. AMQP specification method "channel.pong".</summary>
828 public interface IChannelPong: IMethod {
830 /// <summary>Autogenerated type. AMQP specification method "channel.ok".</summary>
831 public interface IChannelOk: IMethod {
833 /// <summary>Autogenerated type. AMQP specification method "access.request".</summary>
834 public interface IAccessRequest: IMethod {
835 string Realm { get; }
836 bool Exclusive { get; }
837 bool Passive { get; }
842 /// <summary>Autogenerated type. AMQP specification method "access.request-ok".</summary>
843 public interface IAccessRequestOk: IMethod {
844 ushort Ticket { get; }
846 /// <summary>Autogenerated type. AMQP specification method "exchange.declare".</summary>
847 public interface IExchangeDeclare: IMethod {
848 ushort Ticket { get; }
849 string Exchange { get; }
851 bool Passive { get; }
852 bool Durable { get; }
853 bool AutoDelete { get; }
854 bool Internal { get; }
856 System.Collections.IDictionary Arguments { get; }
858 /// <summary>Autogenerated type. AMQP specification method "exchange.declare-ok".</summary>
859 public interface IExchangeDeclareOk: IMethod {
861 /// <summary>Autogenerated type. AMQP specification method "exchange.delete".</summary>
862 public interface IExchangeDelete: IMethod {
863 ushort Ticket { get; }
864 string Exchange { get; }
865 bool IfUnused { get; }
868 /// <summary>Autogenerated type. AMQP specification method "exchange.delete-ok".</summary>
869 public interface IExchangeDeleteOk: IMethod {
871 /// <summary>Autogenerated type. AMQP specification method "queue.declare".</summary>
872 public interface IQueueDeclare: IMethod {
873 ushort Ticket { get; }
874 string Queue { get; }
875 bool Passive { get; }
876 bool Durable { get; }
877 bool Exclusive { get; }
878 bool AutoDelete { get; }
880 System.Collections.IDictionary Arguments { get; }
882 /// <summary>Autogenerated type. AMQP specification method "queue.declare-ok".</summary>
883 public interface IQueueDeclareOk: IMethod {
884 string Queue { get; }
885 uint MessageCount { get; }
886 uint ConsumerCount { get; }
888 /// <summary>Autogenerated type. AMQP specification method "queue.bind".</summary>
889 public interface IQueueBind: IMethod {
890 ushort Ticket { get; }
891 string Queue { get; }
892 string Exchange { get; }
893 string RoutingKey { get; }
895 System.Collections.IDictionary Arguments { get; }
897 /// <summary>Autogenerated type. AMQP specification method "queue.bind-ok".</summary>
898 public interface IQueueBindOk: IMethod {
900 /// <summary>Autogenerated type. AMQP specification method "queue.unbind".</summary>
901 public interface IQueueUnbind: IMethod {
902 ushort Ticket { get; }
903 string Queue { get; }
904 string Exchange { get; }
905 string RoutingKey { get; }
906 System.Collections.IDictionary Arguments { get; }
908 /// <summary>Autogenerated type. AMQP specification method "queue.unbind-ok".</summary>
909 public interface IQueueUnbindOk: IMethod {
911 /// <summary>Autogenerated type. AMQP specification method "queue.purge".</summary>
912 public interface IQueuePurge: IMethod {
913 ushort Ticket { get; }
914 string Queue { get; }
917 /// <summary>Autogenerated type. AMQP specification method "queue.purge-ok".</summary>
918 public interface IQueuePurgeOk: IMethod {
919 uint MessageCount { get; }
921 /// <summary>Autogenerated type. AMQP specification method "queue.delete".</summary>
922 public interface IQueueDelete: IMethod {
923 ushort Ticket { get; }
924 string Queue { get; }
925 bool IfUnused { get; }
926 bool IfEmpty { get; }
929 /// <summary>Autogenerated type. AMQP specification method "queue.delete-ok".</summary>
930 public interface IQueueDeleteOk: IMethod {
931 uint MessageCount { get; }
933 /// <summary>Autogenerated type. AMQP specification method "basic.qos".</summary>
934 public interface IBasicQos: IMethod {
935 uint PrefetchSize { get; }
936 ushort PrefetchCount { get; }
939 /// <summary>Autogenerated type. AMQP specification method "basic.qos-ok".</summary>
940 public interface IBasicQosOk: IMethod {
942 /// <summary>Autogenerated type. AMQP specification method "basic.consume".</summary>
943 public interface IBasicConsume: IMethod {
944 ushort Ticket { get; }
945 string Queue { get; }
946 string ConsumerTag { get; }
947 bool NoLocal { get; }
949 bool Exclusive { get; }
951 System.Collections.IDictionary Filter { get; }
953 /// <summary>Autogenerated type. AMQP specification method "basic.consume-ok".</summary>
954 public interface IBasicConsumeOk: IMethod {
955 string ConsumerTag { get; }
957 /// <summary>Autogenerated type. AMQP specification method "basic.cancel".</summary>
958 public interface IBasicCancel: IMethod {
959 string ConsumerTag { get; }
962 /// <summary>Autogenerated type. AMQP specification method "basic.cancel-ok".</summary>
963 public interface IBasicCancelOk: IMethod {
964 string ConsumerTag { get; }
966 /// <summary>Autogenerated type. AMQP specification method "basic.publish".</summary>
967 public interface IBasicPublish: IMethod {
968 ushort Ticket { get; }
969 string Exchange { get; }
970 string RoutingKey { get; }
971 bool Mandatory { get; }
972 bool Immediate { get; }
974 /// <summary>Autogenerated type. AMQP specification method "basic.return".</summary>
975 public interface IBasicReturn: IMethod {
976 ushort ReplyCode { get; }
977 string ReplyText { get; }
978 string Exchange { get; }
979 string RoutingKey { get; }
981 /// <summary>Autogenerated type. AMQP specification method "basic.deliver".</summary>
982 public interface IBasicDeliver: IMethod {
983 string ConsumerTag { get; }
984 ulong DeliveryTag { get; }
985 bool Redelivered { get; }
986 string Exchange { get; }
987 string RoutingKey { get; }
989 /// <summary>Autogenerated type. AMQP specification method "basic.get".</summary>
990 public interface IBasicGet: IMethod {
991 ushort Ticket { get; }
992 string Queue { get; }
995 /// <summary>Autogenerated type. AMQP specification method "basic.get-ok".</summary>
996 public interface IBasicGetOk: IMethod {
997 ulong DeliveryTag { get; }
998 bool Redelivered { get; }
999 string Exchange { get; }
1000 string RoutingKey { get; }
1001 uint MessageCount { get; }
1003 /// <summary>Autogenerated type. AMQP specification method "basic.get-empty".</summary>
1004 public interface IBasicGetEmpty: IMethod {
1005 string ClusterId { get; }
1007 /// <summary>Autogenerated type. AMQP specification method "basic.ack".</summary>
1008 public interface IBasicAck: IMethod {
1009 ulong DeliveryTag { get; }
1010 bool Multiple { get; }
1012 /// <summary>Autogenerated type. AMQP specification method "basic.reject".</summary>
1013 public interface IBasicReject: IMethod {
1014 ulong DeliveryTag { get; }
1015 bool Requeue { get; }
1017 /// <summary>Autogenerated type. AMQP specification method "basic.recover".</summary>
1018 public interface IBasicRecover: IMethod {
1019 bool Requeue { get; }
1021 /// <summary>Autogenerated type. AMQP specification method "file.qos".</summary>
1022 public interface IFileQos: IMethod {
1023 uint PrefetchSize { get; }
1024 ushort PrefetchCount { get; }
1025 bool Global { get; }
1027 /// <summary>Autogenerated type. AMQP specification method "file.qos-ok".</summary>
1028 public interface IFileQosOk: IMethod {
1030 /// <summary>Autogenerated type. AMQP specification method "file.consume".</summary>
1031 public interface IFileConsume: IMethod {
1032 ushort Ticket { get; }
1033 string Queue { get; }
1034 string ConsumerTag { get; }
1035 bool NoLocal { get; }
1037 bool Exclusive { get; }
1038 bool Nowait { get; }
1039 System.Collections.IDictionary Filter { get; }
1041 /// <summary>Autogenerated type. AMQP specification method "file.consume-ok".</summary>
1042 public interface IFileConsumeOk: IMethod {
1043 string ConsumerTag { get; }
1045 /// <summary>Autogenerated type. AMQP specification method "file.cancel".</summary>
1046 public interface IFileCancel: IMethod {
1047 string ConsumerTag { get; }
1048 bool Nowait { get; }
1050 /// <summary>Autogenerated type. AMQP specification method "file.cancel-ok".</summary>
1051 public interface IFileCancelOk: IMethod {
1052 string ConsumerTag { get; }
1054 /// <summary>Autogenerated type. AMQP specification method "file.open".</summary>
1055 public interface IFileOpen: IMethod {
1056 string Identifier { get; }
1057 ulong ContentSize { get; }
1059 /// <summary>Autogenerated type. AMQP specification method "file.open-ok".</summary>
1060 public interface IFileOpenOk: IMethod {
1061 ulong StagedSize { get; }
1063 /// <summary>Autogenerated type. AMQP specification method "file.stage".</summary>
1064 public interface IFileStage: IMethod {
1066 /// <summary>Autogenerated type. AMQP specification method "file.publish".</summary>
1067 public interface IFilePublish: IMethod {
1068 ushort Ticket { get; }
1069 string Exchange { get; }
1070 string RoutingKey { get; }
1071 bool Mandatory { get; }
1072 bool Immediate { get; }
1073 string Identifier { get; }
1075 /// <summary>Autogenerated type. AMQP specification method "file.return".</summary>
1076 public interface IFileReturn: IMethod {
1077 ushort ReplyCode { get; }
1078 string ReplyText { get; }
1079 string Exchange { get; }
1080 string RoutingKey { get; }
1082 /// <summary>Autogenerated type. AMQP specification method "file.deliver".</summary>
1083 public interface IFileDeliver: IMethod {
1084 string ConsumerTag { get; }
1085 ulong DeliveryTag { get; }
1086 bool Redelivered { get; }
1087 string Exchange { get; }
1088 string RoutingKey { get; }
1089 string Identifier { get; }
1091 /// <summary>Autogenerated type. AMQP specification method "file.ack".</summary>
1092 public interface IFileAck: IMethod {
1093 ulong DeliveryTag { get; }
1094 bool Multiple { get; }
1096 /// <summary>Autogenerated type. AMQP specification method "file.reject".</summary>
1097 public interface IFileReject: IMethod {
1098 ulong DeliveryTag { get; }
1099 bool Requeue { get; }
1101 /// <summary>Autogenerated type. AMQP specification method "stream.qos".</summary>
1102 public interface IStreamQos: IMethod {
1103 uint PrefetchSize { get; }
1104 ushort PrefetchCount { get; }
1105 uint ConsumeRate { get; }
1106 bool Global { get; }
1108 /// <summary>Autogenerated type. AMQP specification method "stream.qos-ok".</summary>
1109 public interface IStreamQosOk: IMethod {
1111 /// <summary>Autogenerated type. AMQP specification method "stream.consume".</summary>
1112 public interface IStreamConsume: IMethod {
1113 ushort Ticket { get; }
1114 string Queue { get; }
1115 string ConsumerTag { get; }
1116 bool NoLocal { get; }
1117 bool Exclusive { get; }
1118 bool Nowait { get; }
1119 System.Collections.IDictionary Filter { get; }
1121 /// <summary>Autogenerated type. AMQP specification method "stream.consume-ok".</summary>
1122 public interface IStreamConsumeOk: IMethod {
1123 string ConsumerTag { get; }
1125 /// <summary>Autogenerated type. AMQP specification method "stream.cancel".</summary>
1126 public interface IStreamCancel: IMethod {
1127 string ConsumerTag { get; }
1128 bool Nowait { get; }
1130 /// <summary>Autogenerated type. AMQP specification method "stream.cancel-ok".</summary>
1131 public interface IStreamCancelOk: IMethod {
1132 string ConsumerTag { get; }
1134 /// <summary>Autogenerated type. AMQP specification method "stream.publish".</summary>
1135 public interface IStreamPublish: IMethod {
1136 ushort Ticket { get; }
1137 string Exchange { get; }
1138 string RoutingKey { get; }
1139 bool Mandatory { get; }
1140 bool Immediate { get; }
1142 /// <summary>Autogenerated type. AMQP specification method "stream.return".</summary>
1143 public interface IStreamReturn: IMethod {
1144 ushort ReplyCode { get; }
1145 string ReplyText { get; }
1146 string Exchange { get; }
1147 string RoutingKey { get; }
1149 /// <summary>Autogenerated type. AMQP specification method "stream.deliver".</summary>
1150 public interface IStreamDeliver: IMethod {
1151 string ConsumerTag { get; }
1152 ulong DeliveryTag { get; }
1153 string Exchange { get; }
1154 string Queue { get; }
1156 /// <summary>Autogenerated type. AMQP specification method "tx.select".</summary>
1157 public interface ITxSelect: IMethod {
1159 /// <summary>Autogenerated type. AMQP specification method "tx.select-ok".</summary>
1160 public interface ITxSelectOk: IMethod {
1162 /// <summary>Autogenerated type. AMQP specification method "tx.commit".</summary>
1163 public interface ITxCommit: IMethod {
1165 /// <summary>Autogenerated type. AMQP specification method "tx.commit-ok".</summary>
1166 public interface ITxCommitOk: IMethod {
1168 /// <summary>Autogenerated type. AMQP specification method "tx.rollback".</summary>
1169 public interface ITxRollback: IMethod {
1171 /// <summary>Autogenerated type. AMQP specification method "tx.rollback-ok".</summary>
1172 public interface ITxRollbackOk: IMethod {
1174 /// <summary>Autogenerated type. AMQP specification method "dtx.select".</summary>
1175 public interface IDtxSelect: IMethod {
1177 /// <summary>Autogenerated type. AMQP specification method "dtx.select-ok".</summary>
1178 public interface IDtxSelectOk: IMethod {
1180 /// <summary>Autogenerated type. AMQP specification method "dtx.start".</summary>
1181 public interface IDtxStart: IMethod {
1182 string DtxIdentifier { get; }
1184 /// <summary>Autogenerated type. AMQP specification method "dtx.start-ok".</summary>
1185 public interface IDtxStartOk: IMethod {
1187 /// <summary>Autogenerated type. AMQP specification method "tunnel.request".</summary>
1188 public interface ITunnelRequest: IMethod {
1189 System.Collections.IDictionary MetaData { get; }
1191 /// <summary>Autogenerated type. AMQP specification method "message.transfer".</summary>
1192 public interface IMessageTransfer: IMethod {
1193 ushort Ticket { get; }
1194 string Destination { get; }
1195 bool Redelivered { get; }
1196 bool Immediate { get; }
1198 byte Priority { get; }
1199 AmqpTimestamp Timestamp { get; }
1200 byte DeliveryMode { get; }
1201 AmqpTimestamp Expiration { get; }
1202 string Exchange { get; }
1203 string RoutingKey { get; }
1204 string MessageId { get; }
1205 string CorrelationId { get; }
1206 string ReplyTo { get; }
1207 string ContentType { get; }
1208 string ContentEncoding { get; }
1209 string UserId { get; }
1210 string AppId { get; }
1211 string TransactionId { get; }
1212 byte[] SecurityToken { get; }
1213 System.Collections.IDictionary ApplicationHeaders { get; }
1214 byte[] Body { get; }
1216 /// <summary>Autogenerated type. AMQP specification method "message.consume".</summary>
1217 public interface IMessageConsume: IMethod {
1218 ushort Ticket { get; }
1219 string Queue { get; }
1220 string Destination { get; }
1221 bool NoLocal { get; }
1223 bool Exclusive { get; }
1224 System.Collections.IDictionary Filter { get; }
1226 /// <summary>Autogenerated type. AMQP specification method "message.cancel".</summary>
1227 public interface IMessageCancel: IMethod {
1228 string Destination { get; }
1230 /// <summary>Autogenerated type. AMQP specification method "message.get".</summary>
1231 public interface IMessageGet: IMethod {
1232 ushort Ticket { get; }
1233 string Queue { get; }
1234 string Destination { get; }
1237 /// <summary>Autogenerated type. AMQP specification method "message.recover".</summary>
1238 public interface IMessageRecover: IMethod {
1239 bool Requeue { get; }
1241 /// <summary>Autogenerated type. AMQP specification method "message.open".</summary>
1242 public interface IMessageOpen: IMethod {
1243 byte[] Reference { get; }
1245 /// <summary>Autogenerated type. AMQP specification method "message.close".</summary>
1246 public interface IMessageClose: IMethod {
1247 byte[] Reference { get; }
1249 /// <summary>Autogenerated type. AMQP specification method "message.append".</summary>
1250 public interface IMessageAppend: IMethod {
1251 byte[] Reference { get; }
1252 byte[] Bytes { get; }
1254 /// <summary>Autogenerated type. AMQP specification method "message.checkpoint".</summary>
1255 public interface IMessageCheckpoint: IMethod {
1256 byte[] Reference { get; }
1257 string Identifier { get; }
1259 /// <summary>Autogenerated type. AMQP specification method "message.resume".</summary>
1260 public interface IMessageResume: IMethod {
1261 byte[] Reference { get; }
1262 string Identifier { get; }
1264 /// <summary>Autogenerated type. AMQP specification method "message.qos".</summary>
1265 public interface IMessageQos: IMethod {
1266 uint PrefetchSize { get; }
1267 ushort PrefetchCount { get; }
1268 bool Global { get; }
1270 /// <summary>Autogenerated type. AMQP specification method "message.ok".</summary>
1271 public interface IMessageOk: IMethod {
1273 /// <summary>Autogenerated type. AMQP specification method "message.empty".</summary>
1274 public interface IMessageEmpty: IMethod {
1276 /// <summary>Autogenerated type. AMQP specification method "message.reject".</summary>
1277 public interface IMessageReject: IMethod {
1278 ushort Code { get; }
1279 string Text { get; }
1281 /// <summary>Autogenerated type. AMQP specification method "message.offset".</summary>
1282 public interface IMessageOffset: IMethod {
1283 ulong Value { get; }
1285 /// <summary>Autogenerated type. AMQP specification content header properties for content class "basic"</summary>
1286 public class BasicProperties: RabbitMQ.Client.Impl.BasicProperties {
1287 private string m_contentType;
1288 private string m_contentEncoding;
1289 private System.Collections.IDictionary m_headers;
1290 private byte m_deliveryMode;
1291 private byte m_priority;
1292 private string m_correlationId;
1293 private string m_replyTo;
1294 private string m_expiration;
1295 private string m_messageId;
1296 private AmqpTimestamp m_timestamp;
1297 private string m_type;
1298 private string m_userId;
1299 private string m_appId;
1300 private string m_clusterId;
1302 private bool m_contentType_present = false;
1303 private bool m_contentEncoding_present = false;
1304 private bool m_headers_present = false;
1305 private bool m_deliveryMode_present = false;
1306 private bool m_priority_present = false;
1307 private bool m_correlationId_present = false;
1308 private bool m_replyTo_present = false;
1309 private bool m_expiration_present = false;
1310 private bool m_messageId_present = false;
1311 private bool m_timestamp_present = false;
1312 private bool m_type_present = false;
1313 private bool m_userId_present = false;
1314 private bool m_appId_present = false;
1315 private bool m_clusterId_present = false;
1317 public override string ContentType {
1319 return m_contentType;
1322 m_contentType_present = true;
1323 m_contentType = value;
1326 public override string ContentEncoding {
1328 return m_contentEncoding;
1331 m_contentEncoding_present = true;
1332 m_contentEncoding = value;
1335 public override System.Collections.IDictionary Headers {
1340 m_headers_present = true;
1344 public override byte DeliveryMode {
1346 return m_deliveryMode;
1349 m_deliveryMode_present = true;
1350 m_deliveryMode = value;
1353 public override byte Priority {
1358 m_priority_present = true;
1362 public override string CorrelationId {
1364 return m_correlationId;
1367 m_correlationId_present = true;
1368 m_correlationId = value;
1371 public override string ReplyTo {
1376 m_replyTo_present = true;
1380 public override string Expiration {
1382 return m_expiration;
1385 m_expiration_present = true;
1386 m_expiration = value;
1389 public override string MessageId {
1394 m_messageId_present = true;
1395 m_messageId = value;
1398 public override AmqpTimestamp Timestamp {
1403 m_timestamp_present = true;
1404 m_timestamp = value;
1407 public override string Type {
1412 m_type_present = true;
1416 public override string UserId {
1421 m_userId_present = true;
1425 public override string AppId {
1430 m_appId_present = true;
1434 public override string ClusterId {
1439 m_clusterId_present = true;
1440 m_clusterId = value;
1444 public override void ClearContentType() { m_contentType_present = false; }
1445 public override void ClearContentEncoding() { m_contentEncoding_present = false; }
1446 public override void ClearHeaders() { m_headers_present = false; }
1447 public override void ClearDeliveryMode() { m_deliveryMode_present = false; }
1448 public override void ClearPriority() { m_priority_present = false; }
1449 public override void ClearCorrelationId() { m_correlationId_present = false; }
1450 public override void ClearReplyTo() { m_replyTo_present = false; }
1451 public override void ClearExpiration() { m_expiration_present = false; }
1452 public override void ClearMessageId() { m_messageId_present = false; }
1453 public override void ClearTimestamp() { m_timestamp_present = false; }
1454 public override void ClearType() { m_type_present = false; }
1455 public override void ClearUserId() { m_userId_present = false; }
1456 public override void ClearAppId() { m_appId_present = false; }
1457 public override void ClearClusterId() { m_clusterId_present = false; }
1459 public override bool IsContentTypePresent() { return m_contentType_present; }
1460 public override bool IsContentEncodingPresent() { return m_contentEncoding_present; }
1461 public override bool IsHeadersPresent() { return m_headers_present; }
1462 public override bool IsDeliveryModePresent() { return m_deliveryMode_present; }
1463 public override bool IsPriorityPresent() { return m_priority_present; }
1464 public override bool IsCorrelationIdPresent() { return m_correlationId_present; }
1465 public override bool IsReplyToPresent() { return m_replyTo_present; }
1466 public override bool IsExpirationPresent() { return m_expiration_present; }
1467 public override bool IsMessageIdPresent() { return m_messageId_present; }
1468 public override bool IsTimestampPresent() { return m_timestamp_present; }
1469 public override bool IsTypePresent() { return m_type_present; }
1470 public override bool IsUserIdPresent() { return m_userId_present; }
1471 public override bool IsAppIdPresent() { return m_appId_present; }
1472 public override bool IsClusterIdPresent() { return m_clusterId_present; }
1474 public BasicProperties() {}
1475 public override int ProtocolClassId { get { return 60; } }
1476 public override string ProtocolClassName { get { return "basic"; } }
1478 public override void ReadPropertiesFrom(RabbitMQ.Client.Impl.ContentHeaderPropertyReader reader) {
1479 m_contentType_present = reader.ReadPresence();
1480 m_contentEncoding_present = reader.ReadPresence();
1481 m_headers_present = reader.ReadPresence();
1482 m_deliveryMode_present = reader.ReadPresence();
1483 m_priority_present = reader.ReadPresence();
1484 m_correlationId_present = reader.ReadPresence();
1485 m_replyTo_present = reader.ReadPresence();
1486 m_expiration_present = reader.ReadPresence();
1487 m_messageId_present = reader.ReadPresence();
1488 m_timestamp_present = reader.ReadPresence();
1489 m_type_present = reader.ReadPresence();
1490 m_userId_present = reader.ReadPresence();
1491 m_appId_present = reader.ReadPresence();
1492 m_clusterId_present = reader.ReadPresence();
1493 reader.FinishPresence();
1494 if (m_contentType_present) { m_contentType = reader.ReadShortstr(); }
1495 if (m_contentEncoding_present) { m_contentEncoding = reader.ReadShortstr(); }
1496 if (m_headers_present) { m_headers = reader.ReadTable(); }
1497 if (m_deliveryMode_present) { m_deliveryMode = reader.ReadOctet(); }
1498 if (m_priority_present) { m_priority = reader.ReadOctet(); }
1499 if (m_correlationId_present) { m_correlationId = reader.ReadShortstr(); }
1500 if (m_replyTo_present) { m_replyTo = reader.ReadShortstr(); }
1501 if (m_expiration_present) { m_expiration = reader.ReadShortstr(); }
1502 if (m_messageId_present) { m_messageId = reader.ReadShortstr(); }
1503 if (m_timestamp_present) { m_timestamp = reader.ReadTimestamp(); }
1504 if (m_type_present) { m_type = reader.ReadShortstr(); }
1505 if (m_userId_present) { m_userId = reader.ReadShortstr(); }
1506 if (m_appId_present) { m_appId = reader.ReadShortstr(); }
1507 if (m_clusterId_present) { m_clusterId = reader.ReadShortstr(); }
1510 public override void WritePropertiesTo(RabbitMQ.Client.Impl.ContentHeaderPropertyWriter writer) {
1511 writer.WritePresence(m_contentType_present);
1512 writer.WritePresence(m_contentEncoding_present);
1513 writer.WritePresence(m_headers_present);
1514 writer.WritePresence(m_deliveryMode_present);
1515 writer.WritePresence(m_priority_present);
1516 writer.WritePresence(m_correlationId_present);
1517 writer.WritePresence(m_replyTo_present);
1518 writer.WritePresence(m_expiration_present);
1519 writer.WritePresence(m_messageId_present);
1520 writer.WritePresence(m_timestamp_present);
1521 writer.WritePresence(m_type_present);
1522 writer.WritePresence(m_userId_present);
1523 writer.WritePresence(m_appId_present);
1524 writer.WritePresence(m_clusterId_present);
1525 writer.FinishPresence();
1526 if (m_contentType_present) { writer.WriteShortstr(m_contentType); }
1527 if (m_contentEncoding_present) { writer.WriteShortstr(m_contentEncoding); }
1528 if (m_headers_present) { writer.WriteTable(m_headers); }
1529 if (m_deliveryMode_present) { writer.WriteOctet(m_deliveryMode); }
1530 if (m_priority_present) { writer.WriteOctet(m_priority); }
1531 if (m_correlationId_present) { writer.WriteShortstr(m_correlationId); }
1532 if (m_replyTo_present) { writer.WriteShortstr(m_replyTo); }
1533 if (m_expiration_present) { writer.WriteShortstr(m_expiration); }
1534 if (m_messageId_present) { writer.WriteShortstr(m_messageId); }
1535 if (m_timestamp_present) { writer.WriteTimestamp(m_timestamp); }
1536 if (m_type_present) { writer.WriteShortstr(m_type); }
1537 if (m_userId_present) { writer.WriteShortstr(m_userId); }
1538 if (m_appId_present) { writer.WriteShortstr(m_appId); }
1539 if (m_clusterId_present) { writer.WriteShortstr(m_clusterId); }
1542 public override void AppendPropertyDebugStringTo(System.Text.StringBuilder sb) {
1544 sb.Append("content-type="); sb.Append(m_contentType_present ? (m_contentType == null ? "(null)" : m_contentType.ToString()) : "_"); sb.Append(", ");
1545 sb.Append("content-encoding="); sb.Append(m_contentEncoding_present ? (m_contentEncoding == null ? "(null)" : m_contentEncoding.ToString()) : "_"); sb.Append(", ");
1546 sb.Append("headers="); sb.Append(m_headers_present ? (m_headers == null ? "(null)" : m_headers.ToString()) : "_"); sb.Append(", ");
1547 sb.Append("delivery-mode="); sb.Append(m_deliveryMode_present ? m_deliveryMode.ToString() : "_"); sb.Append(", ");
1548 sb.Append("priority="); sb.Append(m_priority_present ? m_priority.ToString() : "_"); sb.Append(", ");
1549 sb.Append("correlation-id="); sb.Append(m_correlationId_present ? (m_correlationId == null ? "(null)" : m_correlationId.ToString()) : "_"); sb.Append(", ");
1550 sb.Append("reply-to="); sb.Append(m_replyTo_present ? (m_replyTo == null ? "(null)" : m_replyTo.ToString()) : "_"); sb.Append(", ");
1551 sb.Append("expiration="); sb.Append(m_expiration_present ? (m_expiration == null ? "(null)" : m_expiration.ToString()) : "_"); sb.Append(", ");
1552 sb.Append("message-id="); sb.Append(m_messageId_present ? (m_messageId == null ? "(null)" : m_messageId.ToString()) : "_"); sb.Append(", ");
1553 sb.Append("timestamp="); sb.Append(m_timestamp_present ? m_timestamp.ToString() : "_"); sb.Append(", ");
1554 sb.Append("type="); sb.Append(m_type_present ? (m_type == null ? "(null)" : m_type.ToString()) : "_"); sb.Append(", ");
1555 sb.Append("user-id="); sb.Append(m_userId_present ? (m_userId == null ? "(null)" : m_userId.ToString()) : "_"); sb.Append(", ");
1556 sb.Append("app-id="); sb.Append(m_appId_present ? (m_appId == null ? "(null)" : m_appId.ToString()) : "_"); sb.Append(", ");
1557 sb.Append("cluster-id="); sb.Append(m_clusterId_present ? (m_clusterId == null ? "(null)" : m_clusterId.ToString()) : "_");
1561 /// <summary>Autogenerated type. AMQP specification content header properties for content class "file"</summary>
1562 public class FileProperties: RabbitMQ.Client.Impl.FileProperties {
1563 private string m_contentType;
1564 private string m_contentEncoding;
1565 private System.Collections.IDictionary m_headers;
1566 private byte m_priority;
1567 private string m_replyTo;
1568 private string m_messageId;
1569 private string m_filename;
1570 private AmqpTimestamp m_timestamp;
1571 private string m_clusterId;
1573 private bool m_contentType_present = false;
1574 private bool m_contentEncoding_present = false;
1575 private bool m_headers_present = false;
1576 private bool m_priority_present = false;
1577 private bool m_replyTo_present = false;
1578 private bool m_messageId_present = false;
1579 private bool m_filename_present = false;
1580 private bool m_timestamp_present = false;
1581 private bool m_clusterId_present = false;
1583 public override string ContentType {
1585 return m_contentType;
1588 m_contentType_present = true;
1589 m_contentType = value;
1592 public override string ContentEncoding {
1594 return m_contentEncoding;
1597 m_contentEncoding_present = true;
1598 m_contentEncoding = value;
1601 public override System.Collections.IDictionary Headers {
1606 m_headers_present = true;
1610 public override byte Priority {
1615 m_priority_present = true;
1619 public override string ReplyTo {
1624 m_replyTo_present = true;
1628 public override string MessageId {
1633 m_messageId_present = true;
1634 m_messageId = value;
1637 public override string Filename {
1642 m_filename_present = true;
1646 public override AmqpTimestamp Timestamp {
1651 m_timestamp_present = true;
1652 m_timestamp = value;
1655 public override string ClusterId {
1660 m_clusterId_present = true;
1661 m_clusterId = value;
1665 public override void ClearContentType() { m_contentType_present = false; }
1666 public override void ClearContentEncoding() { m_contentEncoding_present = false; }
1667 public override void ClearHeaders() { m_headers_present = false; }
1668 public override void ClearPriority() { m_priority_present = false; }
1669 public override void ClearReplyTo() { m_replyTo_present = false; }
1670 public override void ClearMessageId() { m_messageId_present = false; }
1671 public override void ClearFilename() { m_filename_present = false; }
1672 public override void ClearTimestamp() { m_timestamp_present = false; }
1673 public override void ClearClusterId() { m_clusterId_present = false; }
1675 public override bool IsContentTypePresent() { return m_contentType_present; }
1676 public override bool IsContentEncodingPresent() { return m_contentEncoding_present; }
1677 public override bool IsHeadersPresent() { return m_headers_present; }
1678 public override bool IsPriorityPresent() { return m_priority_present; }
1679 public override bool IsReplyToPresent() { return m_replyTo_present; }
1680 public override bool IsMessageIdPresent() { return m_messageId_present; }
1681 public override bool IsFilenamePresent() { return m_filename_present; }
1682 public override bool IsTimestampPresent() { return m_timestamp_present; }
1683 public override bool IsClusterIdPresent() { return m_clusterId_present; }
1685 public FileProperties() {}
1686 public override int ProtocolClassId { get { return 70; } }
1687 public override string ProtocolClassName { get { return "file"; } }
1689 public override void ReadPropertiesFrom(RabbitMQ.Client.Impl.ContentHeaderPropertyReader reader) {
1690 m_contentType_present = reader.ReadPresence();
1691 m_contentEncoding_present = reader.ReadPresence();
1692 m_headers_present = reader.ReadPresence();
1693 m_priority_present = reader.ReadPresence();
1694 m_replyTo_present = reader.ReadPresence();
1695 m_messageId_present = reader.ReadPresence();
1696 m_filename_present = reader.ReadPresence();
1697 m_timestamp_present = reader.ReadPresence();
1698 m_clusterId_present = reader.ReadPresence();
1699 reader.FinishPresence();
1700 if (m_contentType_present) { m_contentType = reader.ReadShortstr(); }
1701 if (m_contentEncoding_present) { m_contentEncoding = reader.ReadShortstr(); }
1702 if (m_headers_present) { m_headers = reader.ReadTable(); }
1703 if (m_priority_present) { m_priority = reader.ReadOctet(); }
1704 if (m_replyTo_present) { m_replyTo = reader.ReadShortstr(); }
1705 if (m_messageId_present) { m_messageId = reader.ReadShortstr(); }
1706 if (m_filename_present) { m_filename = reader.ReadShortstr(); }
1707 if (m_timestamp_present) { m_timestamp = reader.ReadTimestamp(); }
1708 if (m_clusterId_present) { m_clusterId = reader.ReadShortstr(); }
1711 public override void WritePropertiesTo(RabbitMQ.Client.Impl.ContentHeaderPropertyWriter writer) {
1712 writer.WritePresence(m_contentType_present);
1713 writer.WritePresence(m_contentEncoding_present);
1714 writer.WritePresence(m_headers_present);
1715 writer.WritePresence(m_priority_present);
1716 writer.WritePresence(m_replyTo_present);
1717 writer.WritePresence(m_messageId_present);
1718 writer.WritePresence(m_filename_present);
1719 writer.WritePresence(m_timestamp_present);
1720 writer.WritePresence(m_clusterId_present);
1721 writer.FinishPresence();
1722 if (m_contentType_present) { writer.WriteShortstr(m_contentType); }
1723 if (m_contentEncoding_present) { writer.WriteShortstr(m_contentEncoding); }
1724 if (m_headers_present) { writer.WriteTable(m_headers); }
1725 if (m_priority_present) { writer.WriteOctet(m_priority); }
1726 if (m_replyTo_present) { writer.WriteShortstr(m_replyTo); }
1727 if (m_messageId_present) { writer.WriteShortstr(m_messageId); }
1728 if (m_filename_present) { writer.WriteShortstr(m_filename); }
1729 if (m_timestamp_present) { writer.WriteTimestamp(m_timestamp); }
1730 if (m_clusterId_present) { writer.WriteShortstr(m_clusterId); }
1733 public override void AppendPropertyDebugStringTo(System.Text.StringBuilder sb) {
1735 sb.Append("content-type="); sb.Append(m_contentType_present ? (m_contentType == null ? "(null)" : m_contentType.ToString()) : "_"); sb.Append(", ");
1736 sb.Append("content-encoding="); sb.Append(m_contentEncoding_present ? (m_contentEncoding == null ? "(null)" : m_contentEncoding.ToString()) : "_"); sb.Append(", ");
1737 sb.Append("headers="); sb.Append(m_headers_present ? (m_headers == null ? "(null)" : m_headers.ToString()) : "_"); sb.Append(", ");
1738 sb.Append("priority="); sb.Append(m_priority_present ? m_priority.ToString() : "_"); sb.Append(", ");
1739 sb.Append("reply-to="); sb.Append(m_replyTo_present ? (m_replyTo == null ? "(null)" : m_replyTo.ToString()) : "_"); sb.Append(", ");
1740 sb.Append("message-id="); sb.Append(m_messageId_present ? (m_messageId == null ? "(null)" : m_messageId.ToString()) : "_"); sb.Append(", ");
1741 sb.Append("filename="); sb.Append(m_filename_present ? (m_filename == null ? "(null)" : m_filename.ToString()) : "_"); sb.Append(", ");
1742 sb.Append("timestamp="); sb.Append(m_timestamp_present ? m_timestamp.ToString() : "_"); sb.Append(", ");
1743 sb.Append("cluster-id="); sb.Append(m_clusterId_present ? (m_clusterId == null ? "(null)" : m_clusterId.ToString()) : "_");
1747 /// <summary>Autogenerated type. AMQP specification content header properties for content class "stream"</summary>
1748 public class StreamProperties: RabbitMQ.Client.Impl.StreamProperties {
1749 private string m_contentType;
1750 private string m_contentEncoding;
1751 private System.Collections.IDictionary m_headers;
1752 private byte m_priority;
1753 private AmqpTimestamp m_timestamp;
1755 private bool m_contentType_present = false;
1756 private bool m_contentEncoding_present = false;
1757 private bool m_headers_present = false;
1758 private bool m_priority_present = false;
1759 private bool m_timestamp_present = false;
1761 public override string ContentType {
1763 return m_contentType;
1766 m_contentType_present = true;
1767 m_contentType = value;
1770 public override string ContentEncoding {
1772 return m_contentEncoding;
1775 m_contentEncoding_present = true;
1776 m_contentEncoding = value;
1779 public override System.Collections.IDictionary Headers {
1784 m_headers_present = true;
1788 public override byte Priority {
1793 m_priority_present = true;
1797 public override AmqpTimestamp Timestamp {
1802 m_timestamp_present = true;
1803 m_timestamp = value;
1807 public override void ClearContentType() { m_contentType_present = false; }
1808 public override void ClearContentEncoding() { m_contentEncoding_present = false; }
1809 public override void ClearHeaders() { m_headers_present = false; }
1810 public override void ClearPriority() { m_priority_present = false; }
1811 public override void ClearTimestamp() { m_timestamp_present = false; }
1813 public override bool IsContentTypePresent() { return m_contentType_present; }
1814 public override bool IsContentEncodingPresent() { return m_contentEncoding_present; }
1815 public override bool IsHeadersPresent() { return m_headers_present; }
1816 public override bool IsPriorityPresent() { return m_priority_present; }
1817 public override bool IsTimestampPresent() { return m_timestamp_present; }
1819 public StreamProperties() {}
1820 public override int ProtocolClassId { get { return 80; } }
1821 public override string ProtocolClassName { get { return "stream"; } }
1823 public override void ReadPropertiesFrom(RabbitMQ.Client.Impl.ContentHeaderPropertyReader reader) {
1824 m_contentType_present = reader.ReadPresence();
1825 m_contentEncoding_present = reader.ReadPresence();
1826 m_headers_present = reader.ReadPresence();
1827 m_priority_present = reader.ReadPresence();
1828 m_timestamp_present = reader.ReadPresence();
1829 reader.FinishPresence();
1830 if (m_contentType_present) { m_contentType = reader.ReadShortstr(); }
1831 if (m_contentEncoding_present) { m_contentEncoding = reader.ReadShortstr(); }
1832 if (m_headers_present) { m_headers = reader.ReadTable(); }
1833 if (m_priority_present) { m_priority = reader.ReadOctet(); }
1834 if (m_timestamp_present) { m_timestamp = reader.ReadTimestamp(); }
1837 public override void WritePropertiesTo(RabbitMQ.Client.Impl.ContentHeaderPropertyWriter writer) {
1838 writer.WritePresence(m_contentType_present);
1839 writer.WritePresence(m_contentEncoding_present);
1840 writer.WritePresence(m_headers_present);
1841 writer.WritePresence(m_priority_present);
1842 writer.WritePresence(m_timestamp_present);
1843 writer.FinishPresence();
1844 if (m_contentType_present) { writer.WriteShortstr(m_contentType); }
1845 if (m_contentEncoding_present) { writer.WriteShortstr(m_contentEncoding); }
1846 if (m_headers_present) { writer.WriteTable(m_headers); }
1847 if (m_priority_present) { writer.WriteOctet(m_priority); }
1848 if (m_timestamp_present) { writer.WriteTimestamp(m_timestamp); }
1851 public override void AppendPropertyDebugStringTo(System.Text.StringBuilder sb) {
1853 sb.Append("content-type="); sb.Append(m_contentType_present ? (m_contentType == null ? "(null)" : m_contentType.ToString()) : "_"); sb.Append(", ");
1854 sb.Append("content-encoding="); sb.Append(m_contentEncoding_present ? (m_contentEncoding == null ? "(null)" : m_contentEncoding.ToString()) : "_"); sb.Append(", ");
1855 sb.Append("headers="); sb.Append(m_headers_present ? (m_headers == null ? "(null)" : m_headers.ToString()) : "_"); sb.Append(", ");
1856 sb.Append("priority="); sb.Append(m_priority_present ? m_priority.ToString() : "_"); sb.Append(", ");
1857 sb.Append("timestamp="); sb.Append(m_timestamp_present ? m_timestamp.ToString() : "_");
1861 /// <summary>Autogenerated type. AMQP specification content header properties for content class "tunnel"</summary>
1862 public class TunnelProperties: RabbitMQ.Client.Impl.ContentHeaderBase {
1863 private System.Collections.IDictionary m_headers;
1864 private string m_proxyName;
1865 private string m_dataName;
1866 private byte m_durable;
1867 private byte m_broadcast;
1869 private bool m_headers_present = false;
1870 private bool m_proxyName_present = false;
1871 private bool m_dataName_present = false;
1872 private bool m_durable_present = false;
1873 private bool m_broadcast_present = false;
1875 public System.Collections.IDictionary Headers {
1880 m_headers_present = true;
1884 public string ProxyName {
1889 m_proxyName_present = true;
1890 m_proxyName = value;
1893 public string DataName {
1898 m_dataName_present = true;
1902 public byte Durable {
1907 m_durable_present = true;
1911 public byte Broadcast {
1916 m_broadcast_present = true;
1917 m_broadcast = value;
1921 public void ClearHeaders() { m_headers_present = false; }
1922 public void ClearProxyName() { m_proxyName_present = false; }
1923 public void ClearDataName() { m_dataName_present = false; }
1924 public void ClearDurable() { m_durable_present = false; }
1925 public void ClearBroadcast() { m_broadcast_present = false; }
1927 public bool IsHeadersPresent() { return m_headers_present; }
1928 public bool IsProxyNamePresent() { return m_proxyName_present; }
1929 public bool IsDataNamePresent() { return m_dataName_present; }
1930 public bool IsDurablePresent() { return m_durable_present; }
1931 public bool IsBroadcastPresent() { return m_broadcast_present; }
1933 public TunnelProperties() {}
1934 public override int ProtocolClassId { get { return 110; } }
1935 public override string ProtocolClassName { get { return "tunnel"; } }
1937 public override void ReadPropertiesFrom(RabbitMQ.Client.Impl.ContentHeaderPropertyReader reader) {
1938 m_headers_present = reader.ReadPresence();
1939 m_proxyName_present = reader.ReadPresence();
1940 m_dataName_present = reader.ReadPresence();
1941 m_durable_present = reader.ReadPresence();
1942 m_broadcast_present = reader.ReadPresence();
1943 reader.FinishPresence();
1944 if (m_headers_present) { m_headers = reader.ReadTable(); }
1945 if (m_proxyName_present) { m_proxyName = reader.ReadShortstr(); }
1946 if (m_dataName_present) { m_dataName = reader.ReadShortstr(); }
1947 if (m_durable_present) { m_durable = reader.ReadOctet(); }
1948 if (m_broadcast_present) { m_broadcast = reader.ReadOctet(); }
1951 public override void WritePropertiesTo(RabbitMQ.Client.Impl.ContentHeaderPropertyWriter writer) {
1952 writer.WritePresence(m_headers_present);
1953 writer.WritePresence(m_proxyName_present);
1954 writer.WritePresence(m_dataName_present);
1955 writer.WritePresence(m_durable_present);
1956 writer.WritePresence(m_broadcast_present);
1957 writer.FinishPresence();
1958 if (m_headers_present) { writer.WriteTable(m_headers); }
1959 if (m_proxyName_present) { writer.WriteShortstr(m_proxyName); }
1960 if (m_dataName_present) { writer.WriteShortstr(m_dataName); }
1961 if (m_durable_present) { writer.WriteOctet(m_durable); }
1962 if (m_broadcast_present) { writer.WriteOctet(m_broadcast); }
1965 public override void AppendPropertyDebugStringTo(System.Text.StringBuilder sb) {
1967 sb.Append("headers="); sb.Append(m_headers_present ? (m_headers == null ? "(null)" : m_headers.ToString()) : "_"); sb.Append(", ");
1968 sb.Append("proxy-name="); sb.Append(m_proxyName_present ? (m_proxyName == null ? "(null)" : m_proxyName.ToString()) : "_"); sb.Append(", ");
1969 sb.Append("data-name="); sb.Append(m_dataName_present ? (m_dataName == null ? "(null)" : m_dataName.ToString()) : "_"); sb.Append(", ");
1970 sb.Append("durable="); sb.Append(m_durable_present ? m_durable.ToString() : "_"); sb.Append(", ");
1971 sb.Append("broadcast="); sb.Append(m_broadcast_present ? m_broadcast.ToString() : "_");
1976 namespace RabbitMQ.Client.Framing.Impl.v0_9 {
1977 using RabbitMQ.Client.Framing.v0_9;
1978 public enum ClassId {
1993 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
1994 public class ConnectionStart: RabbitMQ.Client.Impl.MethodBase, IConnectionStart {
1995 public const int ClassId = 10;
1996 public const int MethodId = 10;
1998 public byte m_versionMajor;
1999 public byte m_versionMinor;
2000 public System.Collections.IDictionary m_serverProperties;
2001 public byte[] m_mechanisms;
2002 public byte[] m_locales;
2004 byte IConnectionStart.VersionMajor { get { return m_versionMajor; } }
2005 byte IConnectionStart.VersionMinor { get { return m_versionMinor; } }
2006 System.Collections.IDictionary IConnectionStart.ServerProperties { get { return m_serverProperties; } }
2007 byte[] IConnectionStart.Mechanisms { get { return m_mechanisms; } }
2008 byte[] IConnectionStart.Locales { get { return m_locales; } }
2010 public ConnectionStart() {}
2011 public ConnectionStart(
2012 byte initVersionMajor,
2013 byte initVersionMinor,
2014 System.Collections.IDictionary initServerProperties,
2015 byte[] initMechanisms,
2018 m_versionMajor = initVersionMajor;
2019 m_versionMinor = initVersionMinor;
2020 m_serverProperties = initServerProperties;
2021 m_mechanisms = initMechanisms;
2022 m_locales = initLocales;
2025 public override int ProtocolClassId { get { return 10; } }
2026 public override int ProtocolMethodId { get { return 10; } }
2027 public override string ProtocolMethodName { get { return "connection.start"; } }
2028 public override bool HasContent { get { return false; } }
2030 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2031 m_versionMajor = reader.ReadOctet();
2032 m_versionMinor = reader.ReadOctet();
2033 m_serverProperties = reader.ReadTable();
2034 m_mechanisms = reader.ReadLongstr();
2035 m_locales = reader.ReadLongstr();
2038 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2039 writer.WriteOctet(m_versionMajor);
2040 writer.WriteOctet(m_versionMinor);
2041 writer.WriteTable(m_serverProperties);
2042 writer.WriteLongstr(m_mechanisms);
2043 writer.WriteLongstr(m_locales);
2046 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2048 sb.Append(m_versionMajor); sb.Append(",");
2049 sb.Append(m_versionMinor); sb.Append(",");
2050 sb.Append(m_serverProperties); sb.Append(",");
2051 sb.Append(m_mechanisms); sb.Append(",");
2052 sb.Append(m_locales);
2056 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2057 public class ConnectionStartOk: RabbitMQ.Client.Impl.MethodBase, IConnectionStartOk {
2058 public const int ClassId = 10;
2059 public const int MethodId = 11;
2061 public System.Collections.IDictionary m_clientProperties;
2062 public string m_mechanism;
2063 public byte[] m_response;
2064 public string m_locale;
2066 System.Collections.IDictionary IConnectionStartOk.ClientProperties { get { return m_clientProperties; } }
2067 string IConnectionStartOk.Mechanism { get { return m_mechanism; } }
2068 byte[] IConnectionStartOk.Response { get { return m_response; } }
2069 string IConnectionStartOk.Locale { get { return m_locale; } }
2071 public ConnectionStartOk() {}
2072 public ConnectionStartOk(
2073 System.Collections.IDictionary initClientProperties,
2074 string initMechanism,
2075 byte[] initResponse,
2078 m_clientProperties = initClientProperties;
2079 m_mechanism = initMechanism;
2080 m_response = initResponse;
2081 m_locale = initLocale;
2084 public override int ProtocolClassId { get { return 10; } }
2085 public override int ProtocolMethodId { get { return 11; } }
2086 public override string ProtocolMethodName { get { return "connection.start-ok"; } }
2087 public override bool HasContent { get { return false; } }
2089 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2090 m_clientProperties = reader.ReadTable();
2091 m_mechanism = reader.ReadShortstr();
2092 m_response = reader.ReadLongstr();
2093 m_locale = reader.ReadShortstr();
2096 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2097 writer.WriteTable(m_clientProperties);
2098 writer.WriteShortstr(m_mechanism);
2099 writer.WriteLongstr(m_response);
2100 writer.WriteShortstr(m_locale);
2103 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2105 sb.Append(m_clientProperties); sb.Append(",");
2106 sb.Append(m_mechanism); sb.Append(",");
2107 sb.Append(m_response); sb.Append(",");
2108 sb.Append(m_locale);
2112 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2113 public class ConnectionSecure: RabbitMQ.Client.Impl.MethodBase, IConnectionSecure {
2114 public const int ClassId = 10;
2115 public const int MethodId = 20;
2117 public byte[] m_challenge;
2119 byte[] IConnectionSecure.Challenge { get { return m_challenge; } }
2121 public ConnectionSecure() {}
2122 public ConnectionSecure(
2123 byte[] initChallenge)
2125 m_challenge = initChallenge;
2128 public override int ProtocolClassId { get { return 10; } }
2129 public override int ProtocolMethodId { get { return 20; } }
2130 public override string ProtocolMethodName { get { return "connection.secure"; } }
2131 public override bool HasContent { get { return false; } }
2133 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2134 m_challenge = reader.ReadLongstr();
2137 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2138 writer.WriteLongstr(m_challenge);
2141 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2143 sb.Append(m_challenge);
2147 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2148 public class ConnectionSecureOk: RabbitMQ.Client.Impl.MethodBase, IConnectionSecureOk {
2149 public const int ClassId = 10;
2150 public const int MethodId = 21;
2152 public byte[] m_response;
2154 byte[] IConnectionSecureOk.Response { get { return m_response; } }
2156 public ConnectionSecureOk() {}
2157 public ConnectionSecureOk(
2158 byte[] initResponse)
2160 m_response = initResponse;
2163 public override int ProtocolClassId { get { return 10; } }
2164 public override int ProtocolMethodId { get { return 21; } }
2165 public override string ProtocolMethodName { get { return "connection.secure-ok"; } }
2166 public override bool HasContent { get { return false; } }
2168 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2169 m_response = reader.ReadLongstr();
2172 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2173 writer.WriteLongstr(m_response);
2176 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2178 sb.Append(m_response);
2182 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2183 public class ConnectionTune: RabbitMQ.Client.Impl.MethodBase, IConnectionTune {
2184 public const int ClassId = 10;
2185 public const int MethodId = 30;
2187 public ushort m_channelMax;
2188 public uint m_frameMax;
2189 public ushort m_heartbeat;
2191 ushort IConnectionTune.ChannelMax { get { return m_channelMax; } }
2192 uint IConnectionTune.FrameMax { get { return m_frameMax; } }
2193 ushort IConnectionTune.Heartbeat { get { return m_heartbeat; } }
2195 public ConnectionTune() {}
2196 public ConnectionTune(
2197 ushort initChannelMax,
2199 ushort initHeartbeat)
2201 m_channelMax = initChannelMax;
2202 m_frameMax = initFrameMax;
2203 m_heartbeat = initHeartbeat;
2206 public override int ProtocolClassId { get { return 10; } }
2207 public override int ProtocolMethodId { get { return 30; } }
2208 public override string ProtocolMethodName { get { return "connection.tune"; } }
2209 public override bool HasContent { get { return false; } }
2211 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2212 m_channelMax = reader.ReadShort();
2213 m_frameMax = reader.ReadLong();
2214 m_heartbeat = reader.ReadShort();
2217 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2218 writer.WriteShort(m_channelMax);
2219 writer.WriteLong(m_frameMax);
2220 writer.WriteShort(m_heartbeat);
2223 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2225 sb.Append(m_channelMax); sb.Append(",");
2226 sb.Append(m_frameMax); sb.Append(",");
2227 sb.Append(m_heartbeat);
2231 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2232 public class ConnectionTuneOk: RabbitMQ.Client.Impl.MethodBase, IConnectionTuneOk {
2233 public const int ClassId = 10;
2234 public const int MethodId = 31;
2236 public ushort m_channelMax;
2237 public uint m_frameMax;
2238 public ushort m_heartbeat;
2240 ushort IConnectionTuneOk.ChannelMax { get { return m_channelMax; } }
2241 uint IConnectionTuneOk.FrameMax { get { return m_frameMax; } }
2242 ushort IConnectionTuneOk.Heartbeat { get { return m_heartbeat; } }
2244 public ConnectionTuneOk() {}
2245 public ConnectionTuneOk(
2246 ushort initChannelMax,
2248 ushort initHeartbeat)
2250 m_channelMax = initChannelMax;
2251 m_frameMax = initFrameMax;
2252 m_heartbeat = initHeartbeat;
2255 public override int ProtocolClassId { get { return 10; } }
2256 public override int ProtocolMethodId { get { return 31; } }
2257 public override string ProtocolMethodName { get { return "connection.tune-ok"; } }
2258 public override bool HasContent { get { return false; } }
2260 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2261 m_channelMax = reader.ReadShort();
2262 m_frameMax = reader.ReadLong();
2263 m_heartbeat = reader.ReadShort();
2266 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2267 writer.WriteShort(m_channelMax);
2268 writer.WriteLong(m_frameMax);
2269 writer.WriteShort(m_heartbeat);
2272 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2274 sb.Append(m_channelMax); sb.Append(",");
2275 sb.Append(m_frameMax); sb.Append(",");
2276 sb.Append(m_heartbeat);
2280 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2281 public class ConnectionOpen: RabbitMQ.Client.Impl.MethodBase, IConnectionOpen {
2282 public const int ClassId = 10;
2283 public const int MethodId = 40;
2285 public string m_virtualHost;
2286 public string m_capabilities;
2287 public bool m_insist;
2289 string IConnectionOpen.VirtualHost { get { return m_virtualHost; } }
2290 string IConnectionOpen.Capabilities { get { return m_capabilities; } }
2291 bool IConnectionOpen.Insist { get { return m_insist; } }
2293 public ConnectionOpen() {}
2294 public ConnectionOpen(
2295 string initVirtualHost,
2296 string initCapabilities,
2299 m_virtualHost = initVirtualHost;
2300 m_capabilities = initCapabilities;
2301 m_insist = initInsist;
2304 public override int ProtocolClassId { get { return 10; } }
2305 public override int ProtocolMethodId { get { return 40; } }
2306 public override string ProtocolMethodName { get { return "connection.open"; } }
2307 public override bool HasContent { get { return false; } }
2309 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2310 m_virtualHost = reader.ReadShortstr();
2311 m_capabilities = reader.ReadShortstr();
2312 m_insist = reader.ReadBit();
2315 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2316 writer.WriteShortstr(m_virtualHost);
2317 writer.WriteShortstr(m_capabilities);
2318 writer.WriteBit(m_insist);
2321 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2323 sb.Append(m_virtualHost); sb.Append(",");
2324 sb.Append(m_capabilities); sb.Append(",");
2325 sb.Append(m_insist);
2329 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2330 public class ConnectionOpenOk: RabbitMQ.Client.Impl.MethodBase, IConnectionOpenOk {
2331 public const int ClassId = 10;
2332 public const int MethodId = 41;
2334 public string m_knownHosts;
2336 string IConnectionOpenOk.KnownHosts { get { return m_knownHosts; } }
2338 public ConnectionOpenOk() {}
2339 public ConnectionOpenOk(
2340 string initKnownHosts)
2342 m_knownHosts = initKnownHosts;
2345 public override int ProtocolClassId { get { return 10; } }
2346 public override int ProtocolMethodId { get { return 41; } }
2347 public override string ProtocolMethodName { get { return "connection.open-ok"; } }
2348 public override bool HasContent { get { return false; } }
2350 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2351 m_knownHosts = reader.ReadShortstr();
2354 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2355 writer.WriteShortstr(m_knownHosts);
2358 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2360 sb.Append(m_knownHosts);
2364 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2365 public class ConnectionRedirect: RabbitMQ.Client.Impl.MethodBase, IConnectionRedirect {
2366 public const int ClassId = 10;
2367 public const int MethodId = 42;
2369 public string m_host;
2370 public string m_knownHosts;
2372 string IConnectionRedirect.Host { get { return m_host; } }
2373 string IConnectionRedirect.KnownHosts { get { return m_knownHosts; } }
2375 public ConnectionRedirect() {}
2376 public ConnectionRedirect(
2378 string initKnownHosts)
2381 m_knownHosts = initKnownHosts;
2384 public override int ProtocolClassId { get { return 10; } }
2385 public override int ProtocolMethodId { get { return 42; } }
2386 public override string ProtocolMethodName { get { return "connection.redirect"; } }
2387 public override bool HasContent { get { return false; } }
2389 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2390 m_host = reader.ReadShortstr();
2391 m_knownHosts = reader.ReadShortstr();
2394 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2395 writer.WriteShortstr(m_host);
2396 writer.WriteShortstr(m_knownHosts);
2399 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2401 sb.Append(m_host); sb.Append(",");
2402 sb.Append(m_knownHosts);
2406 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2407 public class ConnectionClose: RabbitMQ.Client.Impl.MethodBase, IConnectionClose {
2408 public const int ClassId = 10;
2409 public const int MethodId = 50;
2411 public ushort m_replyCode;
2412 public string m_replyText;
2413 public ushort m_classId;
2414 public ushort m_methodId;
2416 ushort IConnectionClose.ReplyCode { get { return m_replyCode; } }
2417 string IConnectionClose.ReplyText { get { return m_replyText; } }
2418 ushort IConnectionClose.ClassId { get { return m_classId; } }
2419 ushort IConnectionClose.MethodId { get { return m_methodId; } }
2421 public ConnectionClose() {}
2422 public ConnectionClose(
2423 ushort initReplyCode,
2424 string initReplyText,
2426 ushort initMethodId)
2428 m_replyCode = initReplyCode;
2429 m_replyText = initReplyText;
2430 m_classId = initClassId;
2431 m_methodId = initMethodId;
2434 public override int ProtocolClassId { get { return 10; } }
2435 public override int ProtocolMethodId { get { return 50; } }
2436 public override string ProtocolMethodName { get { return "connection.close"; } }
2437 public override bool HasContent { get { return false; } }
2439 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2440 m_replyCode = reader.ReadShort();
2441 m_replyText = reader.ReadShortstr();
2442 m_classId = reader.ReadShort();
2443 m_methodId = reader.ReadShort();
2446 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2447 writer.WriteShort(m_replyCode);
2448 writer.WriteShortstr(m_replyText);
2449 writer.WriteShort(m_classId);
2450 writer.WriteShort(m_methodId);
2453 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2455 sb.Append(m_replyCode); sb.Append(",");
2456 sb.Append(m_replyText); sb.Append(",");
2457 sb.Append(m_classId); sb.Append(",");
2458 sb.Append(m_methodId);
2462 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2463 public class ConnectionCloseOk: RabbitMQ.Client.Impl.MethodBase, IConnectionCloseOk {
2464 public const int ClassId = 10;
2465 public const int MethodId = 51;
2469 public ConnectionCloseOk(
2474 public override int ProtocolClassId { get { return 10; } }
2475 public override int ProtocolMethodId { get { return 51; } }
2476 public override string ProtocolMethodName { get { return "connection.close-ok"; } }
2477 public override bool HasContent { get { return false; } }
2479 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2482 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2485 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2490 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2491 public class ChannelOpen: RabbitMQ.Client.Impl.MethodBase, IChannelOpen {
2492 public const int ClassId = 20;
2493 public const int MethodId = 10;
2495 public string m_outOfBand;
2497 string IChannelOpen.OutOfBand { get { return m_outOfBand; } }
2499 public ChannelOpen() {}
2501 string initOutOfBand)
2503 m_outOfBand = initOutOfBand;
2506 public override int ProtocolClassId { get { return 20; } }
2507 public override int ProtocolMethodId { get { return 10; } }
2508 public override string ProtocolMethodName { get { return "channel.open"; } }
2509 public override bool HasContent { get { return false; } }
2511 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2512 m_outOfBand = reader.ReadShortstr();
2515 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2516 writer.WriteShortstr(m_outOfBand);
2519 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2521 sb.Append(m_outOfBand);
2525 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2526 public class ChannelOpenOk: RabbitMQ.Client.Impl.MethodBase, IChannelOpenOk {
2527 public const int ClassId = 20;
2528 public const int MethodId = 11;
2530 public byte[] m_channelId;
2532 byte[] IChannelOpenOk.ChannelId { get { return m_channelId; } }
2534 public ChannelOpenOk() {}
2535 public ChannelOpenOk(
2536 byte[] initChannelId)
2538 m_channelId = initChannelId;
2541 public override int ProtocolClassId { get { return 20; } }
2542 public override int ProtocolMethodId { get { return 11; } }
2543 public override string ProtocolMethodName { get { return "channel.open-ok"; } }
2544 public override bool HasContent { get { return false; } }
2546 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2547 m_channelId = reader.ReadLongstr();
2550 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2551 writer.WriteLongstr(m_channelId);
2554 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2556 sb.Append(m_channelId);
2560 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2561 public class ChannelFlow: RabbitMQ.Client.Impl.MethodBase, IChannelFlow {
2562 public const int ClassId = 20;
2563 public const int MethodId = 20;
2565 public bool m_active;
2567 bool IChannelFlow.Active { get { return m_active; } }
2569 public ChannelFlow() {}
2573 m_active = initActive;
2576 public override int ProtocolClassId { get { return 20; } }
2577 public override int ProtocolMethodId { get { return 20; } }
2578 public override string ProtocolMethodName { get { return "channel.flow"; } }
2579 public override bool HasContent { get { return false; } }
2581 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2582 m_active = reader.ReadBit();
2585 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2586 writer.WriteBit(m_active);
2589 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2591 sb.Append(m_active);
2595 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2596 public class ChannelFlowOk: RabbitMQ.Client.Impl.MethodBase, IChannelFlowOk {
2597 public const int ClassId = 20;
2598 public const int MethodId = 21;
2600 public bool m_active;
2602 bool IChannelFlowOk.Active { get { return m_active; } }
2604 public ChannelFlowOk() {}
2605 public ChannelFlowOk(
2608 m_active = initActive;
2611 public override int ProtocolClassId { get { return 20; } }
2612 public override int ProtocolMethodId { get { return 21; } }
2613 public override string ProtocolMethodName { get { return "channel.flow-ok"; } }
2614 public override bool HasContent { get { return false; } }
2616 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2617 m_active = reader.ReadBit();
2620 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2621 writer.WriteBit(m_active);
2624 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2626 sb.Append(m_active);
2630 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2631 public class ChannelClose: RabbitMQ.Client.Impl.MethodBase, IChannelClose {
2632 public const int ClassId = 20;
2633 public const int MethodId = 40;
2635 public ushort m_replyCode;
2636 public string m_replyText;
2637 public ushort m_classId;
2638 public ushort m_methodId;
2640 ushort IChannelClose.ReplyCode { get { return m_replyCode; } }
2641 string IChannelClose.ReplyText { get { return m_replyText; } }
2642 ushort IChannelClose.ClassId { get { return m_classId; } }
2643 ushort IChannelClose.MethodId { get { return m_methodId; } }
2645 public ChannelClose() {}
2646 public ChannelClose(
2647 ushort initReplyCode,
2648 string initReplyText,
2650 ushort initMethodId)
2652 m_replyCode = initReplyCode;
2653 m_replyText = initReplyText;
2654 m_classId = initClassId;
2655 m_methodId = initMethodId;
2658 public override int ProtocolClassId { get { return 20; } }
2659 public override int ProtocolMethodId { get { return 40; } }
2660 public override string ProtocolMethodName { get { return "channel.close"; } }
2661 public override bool HasContent { get { return false; } }
2663 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2664 m_replyCode = reader.ReadShort();
2665 m_replyText = reader.ReadShortstr();
2666 m_classId = reader.ReadShort();
2667 m_methodId = reader.ReadShort();
2670 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2671 writer.WriteShort(m_replyCode);
2672 writer.WriteShortstr(m_replyText);
2673 writer.WriteShort(m_classId);
2674 writer.WriteShort(m_methodId);
2677 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2679 sb.Append(m_replyCode); sb.Append(",");
2680 sb.Append(m_replyText); sb.Append(",");
2681 sb.Append(m_classId); sb.Append(",");
2682 sb.Append(m_methodId);
2686 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2687 public class ChannelCloseOk: RabbitMQ.Client.Impl.MethodBase, IChannelCloseOk {
2688 public const int ClassId = 20;
2689 public const int MethodId = 41;
2693 public ChannelCloseOk(
2698 public override int ProtocolClassId { get { return 20; } }
2699 public override int ProtocolMethodId { get { return 41; } }
2700 public override string ProtocolMethodName { get { return "channel.close-ok"; } }
2701 public override bool HasContent { get { return false; } }
2703 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2706 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2709 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2714 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2715 public class ChannelResume: RabbitMQ.Client.Impl.MethodBase, IChannelResume {
2716 public const int ClassId = 20;
2717 public const int MethodId = 50;
2719 public byte[] m_channelId;
2721 byte[] IChannelResume.ChannelId { get { return m_channelId; } }
2723 public ChannelResume() {}
2724 public ChannelResume(
2725 byte[] initChannelId)
2727 m_channelId = initChannelId;
2730 public override int ProtocolClassId { get { return 20; } }
2731 public override int ProtocolMethodId { get { return 50; } }
2732 public override string ProtocolMethodName { get { return "channel.resume"; } }
2733 public override bool HasContent { get { return false; } }
2735 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2736 m_channelId = reader.ReadLongstr();
2739 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2740 writer.WriteLongstr(m_channelId);
2743 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2745 sb.Append(m_channelId);
2749 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2750 public class ChannelPing: RabbitMQ.Client.Impl.MethodBase, IChannelPing {
2751 public const int ClassId = 20;
2752 public const int MethodId = 60;
2761 public override int ProtocolClassId { get { return 20; } }
2762 public override int ProtocolMethodId { get { return 60; } }
2763 public override string ProtocolMethodName { get { return "channel.ping"; } }
2764 public override bool HasContent { get { return false; } }
2766 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2769 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2772 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2777 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2778 public class ChannelPong: RabbitMQ.Client.Impl.MethodBase, IChannelPong {
2779 public const int ClassId = 20;
2780 public const int MethodId = 70;
2789 public override int ProtocolClassId { get { return 20; } }
2790 public override int ProtocolMethodId { get { return 70; } }
2791 public override string ProtocolMethodName { get { return "channel.pong"; } }
2792 public override bool HasContent { get { return false; } }
2794 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2797 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2800 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2805 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2806 public class ChannelOk: RabbitMQ.Client.Impl.MethodBase, IChannelOk {
2807 public const int ClassId = 20;
2808 public const int MethodId = 80;
2817 public override int ProtocolClassId { get { return 20; } }
2818 public override int ProtocolMethodId { get { return 80; } }
2819 public override string ProtocolMethodName { get { return "channel.ok"; } }
2820 public override bool HasContent { get { return false; } }
2822 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2825 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2828 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2833 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2834 public class AccessRequest: RabbitMQ.Client.Impl.MethodBase, IAccessRequest {
2835 public const int ClassId = 30;
2836 public const int MethodId = 10;
2838 public string m_realm;
2839 public bool m_exclusive;
2840 public bool m_passive;
2841 public bool m_active;
2842 public bool m_write;
2845 string IAccessRequest.Realm { get { return m_realm; } }
2846 bool IAccessRequest.Exclusive { get { return m_exclusive; } }
2847 bool IAccessRequest.Passive { get { return m_passive; } }
2848 bool IAccessRequest.Active { get { return m_active; } }
2849 bool IAccessRequest.Write { get { return m_write; } }
2850 bool IAccessRequest.Read { get { return m_read; } }
2852 public AccessRequest() {}
2853 public AccessRequest(
2861 m_realm = initRealm;
2862 m_exclusive = initExclusive;
2863 m_passive = initPassive;
2864 m_active = initActive;
2865 m_write = initWrite;
2869 public override int ProtocolClassId { get { return 30; } }
2870 public override int ProtocolMethodId { get { return 10; } }
2871 public override string ProtocolMethodName { get { return "access.request"; } }
2872 public override bool HasContent { get { return false; } }
2874 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2875 m_realm = reader.ReadShortstr();
2876 m_exclusive = reader.ReadBit();
2877 m_passive = reader.ReadBit();
2878 m_active = reader.ReadBit();
2879 m_write = reader.ReadBit();
2880 m_read = reader.ReadBit();
2883 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2884 writer.WriteShortstr(m_realm);
2885 writer.WriteBit(m_exclusive);
2886 writer.WriteBit(m_passive);
2887 writer.WriteBit(m_active);
2888 writer.WriteBit(m_write);
2889 writer.WriteBit(m_read);
2892 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2894 sb.Append(m_realm); sb.Append(",");
2895 sb.Append(m_exclusive); sb.Append(",");
2896 sb.Append(m_passive); sb.Append(",");
2897 sb.Append(m_active); sb.Append(",");
2898 sb.Append(m_write); sb.Append(",");
2903 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2904 public class AccessRequestOk: RabbitMQ.Client.Impl.MethodBase, IAccessRequestOk {
2905 public const int ClassId = 30;
2906 public const int MethodId = 11;
2908 public ushort m_ticket;
2910 ushort IAccessRequestOk.Ticket { get { return m_ticket; } }
2912 public AccessRequestOk() {}
2913 public AccessRequestOk(
2916 m_ticket = initTicket;
2919 public override int ProtocolClassId { get { return 30; } }
2920 public override int ProtocolMethodId { get { return 11; } }
2921 public override string ProtocolMethodName { get { return "access.request-ok"; } }
2922 public override bool HasContent { get { return false; } }
2924 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2925 m_ticket = reader.ReadShort();
2928 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2929 writer.WriteShort(m_ticket);
2932 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2934 sb.Append(m_ticket);
2938 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2939 public class ExchangeDeclare: RabbitMQ.Client.Impl.MethodBase, IExchangeDeclare {
2940 public const int ClassId = 40;
2941 public const int MethodId = 10;
2943 public ushort m_ticket;
2944 public string m_exchange;
2945 public string m_type;
2946 public bool m_passive;
2947 public bool m_durable;
2948 public bool m_autoDelete;
2949 public bool m_internal;
2950 public bool m_nowait;
2951 public System.Collections.IDictionary m_arguments;
2953 ushort IExchangeDeclare.Ticket { get { return m_ticket; } }
2954 string IExchangeDeclare.Exchange { get { return m_exchange; } }
2955 string IExchangeDeclare.Type { get { return m_type; } }
2956 bool IExchangeDeclare.Passive { get { return m_passive; } }
2957 bool IExchangeDeclare.Durable { get { return m_durable; } }
2958 bool IExchangeDeclare.AutoDelete { get { return m_autoDelete; } }
2959 bool IExchangeDeclare.Internal { get { return m_internal; } }
2960 bool IExchangeDeclare.Nowait { get { return m_nowait; } }
2961 System.Collections.IDictionary IExchangeDeclare.Arguments { get { return m_arguments; } }
2963 public ExchangeDeclare() {}
2964 public ExchangeDeclare(
2966 string initExchange,
2970 bool initAutoDelete,
2973 System.Collections.IDictionary initArguments)
2975 m_ticket = initTicket;
2976 m_exchange = initExchange;
2978 m_passive = initPassive;
2979 m_durable = initDurable;
2980 m_autoDelete = initAutoDelete;
2981 m_internal = initInternal;
2982 m_nowait = initNowait;
2983 m_arguments = initArguments;
2986 public override int ProtocolClassId { get { return 40; } }
2987 public override int ProtocolMethodId { get { return 10; } }
2988 public override string ProtocolMethodName { get { return "exchange.declare"; } }
2989 public override bool HasContent { get { return false; } }
2991 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2992 m_ticket = reader.ReadShort();
2993 m_exchange = reader.ReadShortstr();
2994 m_type = reader.ReadShortstr();
2995 m_passive = reader.ReadBit();
2996 m_durable = reader.ReadBit();
2997 m_autoDelete = reader.ReadBit();
2998 m_internal = reader.ReadBit();
2999 m_nowait = reader.ReadBit();
3000 m_arguments = reader.ReadTable();
3003 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3004 writer.WriteShort(m_ticket);
3005 writer.WriteShortstr(m_exchange);
3006 writer.WriteShortstr(m_type);
3007 writer.WriteBit(m_passive);
3008 writer.WriteBit(m_durable);
3009 writer.WriteBit(m_autoDelete);
3010 writer.WriteBit(m_internal);
3011 writer.WriteBit(m_nowait);
3012 writer.WriteTable(m_arguments);
3015 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3017 sb.Append(m_ticket); sb.Append(",");
3018 sb.Append(m_exchange); sb.Append(",");
3019 sb.Append(m_type); sb.Append(",");
3020 sb.Append(m_passive); sb.Append(",");
3021 sb.Append(m_durable); sb.Append(",");
3022 sb.Append(m_autoDelete); sb.Append(",");
3023 sb.Append(m_internal); sb.Append(",");
3024 sb.Append(m_nowait); sb.Append(",");
3025 sb.Append(m_arguments);
3029 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3030 public class ExchangeDeclareOk: RabbitMQ.Client.Impl.MethodBase, IExchangeDeclareOk {
3031 public const int ClassId = 40;
3032 public const int MethodId = 11;
3036 public ExchangeDeclareOk(
3041 public override int ProtocolClassId { get { return 40; } }
3042 public override int ProtocolMethodId { get { return 11; } }
3043 public override string ProtocolMethodName { get { return "exchange.declare-ok"; } }
3044 public override bool HasContent { get { return false; } }
3046 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3049 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3052 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3057 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3058 public class ExchangeDelete: RabbitMQ.Client.Impl.MethodBase, IExchangeDelete {
3059 public const int ClassId = 40;
3060 public const int MethodId = 20;
3062 public ushort m_ticket;
3063 public string m_exchange;
3064 public bool m_ifUnused;
3065 public bool m_nowait;
3067 ushort IExchangeDelete.Ticket { get { return m_ticket; } }
3068 string IExchangeDelete.Exchange { get { return m_exchange; } }
3069 bool IExchangeDelete.IfUnused { get { return m_ifUnused; } }
3070 bool IExchangeDelete.Nowait { get { return m_nowait; } }
3072 public ExchangeDelete() {}
3073 public ExchangeDelete(
3075 string initExchange,
3079 m_ticket = initTicket;
3080 m_exchange = initExchange;
3081 m_ifUnused = initIfUnused;
3082 m_nowait = initNowait;
3085 public override int ProtocolClassId { get { return 40; } }
3086 public override int ProtocolMethodId { get { return 20; } }
3087 public override string ProtocolMethodName { get { return "exchange.delete"; } }
3088 public override bool HasContent { get { return false; } }
3090 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3091 m_ticket = reader.ReadShort();
3092 m_exchange = reader.ReadShortstr();
3093 m_ifUnused = reader.ReadBit();
3094 m_nowait = reader.ReadBit();
3097 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3098 writer.WriteShort(m_ticket);
3099 writer.WriteShortstr(m_exchange);
3100 writer.WriteBit(m_ifUnused);
3101 writer.WriteBit(m_nowait);
3104 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3106 sb.Append(m_ticket); sb.Append(",");
3107 sb.Append(m_exchange); sb.Append(",");
3108 sb.Append(m_ifUnused); sb.Append(",");
3109 sb.Append(m_nowait);
3113 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3114 public class ExchangeDeleteOk: RabbitMQ.Client.Impl.MethodBase, IExchangeDeleteOk {
3115 public const int ClassId = 40;
3116 public const int MethodId = 21;
3120 public ExchangeDeleteOk(
3125 public override int ProtocolClassId { get { return 40; } }
3126 public override int ProtocolMethodId { get { return 21; } }
3127 public override string ProtocolMethodName { get { return "exchange.delete-ok"; } }
3128 public override bool HasContent { get { return false; } }
3130 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3133 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3136 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3141 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3142 public class QueueDeclare: RabbitMQ.Client.Impl.MethodBase, IQueueDeclare {
3143 public const int ClassId = 50;
3144 public const int MethodId = 10;
3146 public ushort m_ticket;
3147 public string m_queue;
3148 public bool m_passive;
3149 public bool m_durable;
3150 public bool m_exclusive;
3151 public bool m_autoDelete;
3152 public bool m_nowait;
3153 public System.Collections.IDictionary m_arguments;
3155 ushort IQueueDeclare.Ticket { get { return m_ticket; } }
3156 string IQueueDeclare.Queue { get { return m_queue; } }
3157 bool IQueueDeclare.Passive { get { return m_passive; } }
3158 bool IQueueDeclare.Durable { get { return m_durable; } }
3159 bool IQueueDeclare.Exclusive { get { return m_exclusive; } }
3160 bool IQueueDeclare.AutoDelete { get { return m_autoDelete; } }
3161 bool IQueueDeclare.Nowait { get { return m_nowait; } }
3162 System.Collections.IDictionary IQueueDeclare.Arguments { get { return m_arguments; } }
3164 public QueueDeclare() {}
3165 public QueueDeclare(
3171 bool initAutoDelete,
3173 System.Collections.IDictionary initArguments)
3175 m_ticket = initTicket;
3176 m_queue = initQueue;
3177 m_passive = initPassive;
3178 m_durable = initDurable;
3179 m_exclusive = initExclusive;
3180 m_autoDelete = initAutoDelete;
3181 m_nowait = initNowait;
3182 m_arguments = initArguments;
3185 public override int ProtocolClassId { get { return 50; } }
3186 public override int ProtocolMethodId { get { return 10; } }
3187 public override string ProtocolMethodName { get { return "queue.declare"; } }
3188 public override bool HasContent { get { return false; } }
3190 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3191 m_ticket = reader.ReadShort();
3192 m_queue = reader.ReadShortstr();
3193 m_passive = reader.ReadBit();
3194 m_durable = reader.ReadBit();
3195 m_exclusive = reader.ReadBit();
3196 m_autoDelete = reader.ReadBit();
3197 m_nowait = reader.ReadBit();
3198 m_arguments = reader.ReadTable();
3201 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3202 writer.WriteShort(m_ticket);
3203 writer.WriteShortstr(m_queue);
3204 writer.WriteBit(m_passive);
3205 writer.WriteBit(m_durable);
3206 writer.WriteBit(m_exclusive);
3207 writer.WriteBit(m_autoDelete);
3208 writer.WriteBit(m_nowait);
3209 writer.WriteTable(m_arguments);
3212 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3214 sb.Append(m_ticket); sb.Append(",");
3215 sb.Append(m_queue); sb.Append(",");
3216 sb.Append(m_passive); sb.Append(",");
3217 sb.Append(m_durable); sb.Append(",");
3218 sb.Append(m_exclusive); sb.Append(",");
3219 sb.Append(m_autoDelete); sb.Append(",");
3220 sb.Append(m_nowait); sb.Append(",");
3221 sb.Append(m_arguments);
3225 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3226 public class QueueDeclareOk: RabbitMQ.Client.Impl.MethodBase, IQueueDeclareOk {
3227 public const int ClassId = 50;
3228 public const int MethodId = 11;
3230 public string m_queue;
3231 public uint m_messageCount;
3232 public uint m_consumerCount;
3234 string IQueueDeclareOk.Queue { get { return m_queue; } }
3235 uint IQueueDeclareOk.MessageCount { get { return m_messageCount; } }
3236 uint IQueueDeclareOk.ConsumerCount { get { return m_consumerCount; } }
3238 public QueueDeclareOk() {}
3239 public QueueDeclareOk(
3241 uint initMessageCount,
3242 uint initConsumerCount)
3244 m_queue = initQueue;
3245 m_messageCount = initMessageCount;
3246 m_consumerCount = initConsumerCount;
3249 public override int ProtocolClassId { get { return 50; } }
3250 public override int ProtocolMethodId { get { return 11; } }
3251 public override string ProtocolMethodName { get { return "queue.declare-ok"; } }
3252 public override bool HasContent { get { return false; } }
3254 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3255 m_queue = reader.ReadShortstr();
3256 m_messageCount = reader.ReadLong();
3257 m_consumerCount = reader.ReadLong();
3260 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3261 writer.WriteShortstr(m_queue);
3262 writer.WriteLong(m_messageCount);
3263 writer.WriteLong(m_consumerCount);
3266 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3268 sb.Append(m_queue); sb.Append(",");
3269 sb.Append(m_messageCount); sb.Append(",");
3270 sb.Append(m_consumerCount);
3274 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3275 public class QueueBind: RabbitMQ.Client.Impl.MethodBase, IQueueBind {
3276 public const int ClassId = 50;
3277 public const int MethodId = 20;
3279 public ushort m_ticket;
3280 public string m_queue;
3281 public string m_exchange;
3282 public string m_routingKey;
3283 public bool m_nowait;
3284 public System.Collections.IDictionary m_arguments;
3286 ushort IQueueBind.Ticket { get { return m_ticket; } }
3287 string IQueueBind.Queue { get { return m_queue; } }
3288 string IQueueBind.Exchange { get { return m_exchange; } }
3289 string IQueueBind.RoutingKey { get { return m_routingKey; } }
3290 bool IQueueBind.Nowait { get { return m_nowait; } }
3291 System.Collections.IDictionary IQueueBind.Arguments { get { return m_arguments; } }
3293 public QueueBind() {}
3297 string initExchange,
3298 string initRoutingKey,
3300 System.Collections.IDictionary initArguments)
3302 m_ticket = initTicket;
3303 m_queue = initQueue;
3304 m_exchange = initExchange;
3305 m_routingKey = initRoutingKey;
3306 m_nowait = initNowait;
3307 m_arguments = initArguments;
3310 public override int ProtocolClassId { get { return 50; } }
3311 public override int ProtocolMethodId { get { return 20; } }
3312 public override string ProtocolMethodName { get { return "queue.bind"; } }
3313 public override bool HasContent { get { return false; } }
3315 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3316 m_ticket = reader.ReadShort();
3317 m_queue = reader.ReadShortstr();
3318 m_exchange = reader.ReadShortstr();
3319 m_routingKey = reader.ReadShortstr();
3320 m_nowait = reader.ReadBit();
3321 m_arguments = reader.ReadTable();
3324 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3325 writer.WriteShort(m_ticket);
3326 writer.WriteShortstr(m_queue);
3327 writer.WriteShortstr(m_exchange);
3328 writer.WriteShortstr(m_routingKey);
3329 writer.WriteBit(m_nowait);
3330 writer.WriteTable(m_arguments);
3333 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3335 sb.Append(m_ticket); sb.Append(",");
3336 sb.Append(m_queue); sb.Append(",");
3337 sb.Append(m_exchange); sb.Append(",");
3338 sb.Append(m_routingKey); sb.Append(",");
3339 sb.Append(m_nowait); sb.Append(",");
3340 sb.Append(m_arguments);
3344 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3345 public class QueueBindOk: RabbitMQ.Client.Impl.MethodBase, IQueueBindOk {
3346 public const int ClassId = 50;
3347 public const int MethodId = 21;
3356 public override int ProtocolClassId { get { return 50; } }
3357 public override int ProtocolMethodId { get { return 21; } }
3358 public override string ProtocolMethodName { get { return "queue.bind-ok"; } }
3359 public override bool HasContent { get { return false; } }
3361 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3364 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3367 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3372 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3373 public class QueueUnbind: RabbitMQ.Client.Impl.MethodBase, IQueueUnbind {
3374 public const int ClassId = 50;
3375 public const int MethodId = 50;
3377 public ushort m_ticket;
3378 public string m_queue;
3379 public string m_exchange;
3380 public string m_routingKey;
3381 public System.Collections.IDictionary m_arguments;
3383 ushort IQueueUnbind.Ticket { get { return m_ticket; } }
3384 string IQueueUnbind.Queue { get { return m_queue; } }
3385 string IQueueUnbind.Exchange { get { return m_exchange; } }
3386 string IQueueUnbind.RoutingKey { get { return m_routingKey; } }
3387 System.Collections.IDictionary IQueueUnbind.Arguments { get { return m_arguments; } }
3389 public QueueUnbind() {}
3393 string initExchange,
3394 string initRoutingKey,
3395 System.Collections.IDictionary initArguments)
3397 m_ticket = initTicket;
3398 m_queue = initQueue;
3399 m_exchange = initExchange;
3400 m_routingKey = initRoutingKey;
3401 m_arguments = initArguments;
3404 public override int ProtocolClassId { get { return 50; } }
3405 public override int ProtocolMethodId { get { return 50; } }
3406 public override string ProtocolMethodName { get { return "queue.unbind"; } }
3407 public override bool HasContent { get { return false; } }
3409 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3410 m_ticket = reader.ReadShort();
3411 m_queue = reader.ReadShortstr();
3412 m_exchange = reader.ReadShortstr();
3413 m_routingKey = reader.ReadShortstr();
3414 m_arguments = reader.ReadTable();
3417 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3418 writer.WriteShort(m_ticket);
3419 writer.WriteShortstr(m_queue);
3420 writer.WriteShortstr(m_exchange);
3421 writer.WriteShortstr(m_routingKey);
3422 writer.WriteTable(m_arguments);
3425 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3427 sb.Append(m_ticket); sb.Append(",");
3428 sb.Append(m_queue); sb.Append(",");
3429 sb.Append(m_exchange); sb.Append(",");
3430 sb.Append(m_routingKey); sb.Append(",");
3431 sb.Append(m_arguments);
3435 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3436 public class QueueUnbindOk: RabbitMQ.Client.Impl.MethodBase, IQueueUnbindOk {
3437 public const int ClassId = 50;
3438 public const int MethodId = 51;
3442 public QueueUnbindOk(
3447 public override int ProtocolClassId { get { return 50; } }
3448 public override int ProtocolMethodId { get { return 51; } }
3449 public override string ProtocolMethodName { get { return "queue.unbind-ok"; } }
3450 public override bool HasContent { get { return false; } }
3452 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3455 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3458 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3463 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3464 public class QueuePurge: RabbitMQ.Client.Impl.MethodBase, IQueuePurge {
3465 public const int ClassId = 50;
3466 public const int MethodId = 30;
3468 public ushort m_ticket;
3469 public string m_queue;
3470 public bool m_nowait;
3472 ushort IQueuePurge.Ticket { get { return m_ticket; } }
3473 string IQueuePurge.Queue { get { return m_queue; } }
3474 bool IQueuePurge.Nowait { get { return m_nowait; } }
3476 public QueuePurge() {}
3482 m_ticket = initTicket;
3483 m_queue = initQueue;
3484 m_nowait = initNowait;
3487 public override int ProtocolClassId { get { return 50; } }
3488 public override int ProtocolMethodId { get { return 30; } }
3489 public override string ProtocolMethodName { get { return "queue.purge"; } }
3490 public override bool HasContent { get { return false; } }
3492 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3493 m_ticket = reader.ReadShort();
3494 m_queue = reader.ReadShortstr();
3495 m_nowait = reader.ReadBit();
3498 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3499 writer.WriteShort(m_ticket);
3500 writer.WriteShortstr(m_queue);
3501 writer.WriteBit(m_nowait);
3504 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3506 sb.Append(m_ticket); sb.Append(",");
3507 sb.Append(m_queue); sb.Append(",");
3508 sb.Append(m_nowait);
3512 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3513 public class QueuePurgeOk: RabbitMQ.Client.Impl.MethodBase, IQueuePurgeOk {
3514 public const int ClassId = 50;
3515 public const int MethodId = 31;
3517 public uint m_messageCount;
3519 uint IQueuePurgeOk.MessageCount { get { return m_messageCount; } }
3521 public QueuePurgeOk() {}
3522 public QueuePurgeOk(
3523 uint initMessageCount)
3525 m_messageCount = initMessageCount;
3528 public override int ProtocolClassId { get { return 50; } }
3529 public override int ProtocolMethodId { get { return 31; } }
3530 public override string ProtocolMethodName { get { return "queue.purge-ok"; } }
3531 public override bool HasContent { get { return false; } }
3533 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3534 m_messageCount = reader.ReadLong();
3537 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3538 writer.WriteLong(m_messageCount);
3541 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3543 sb.Append(m_messageCount);
3547 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3548 public class QueueDelete: RabbitMQ.Client.Impl.MethodBase, IQueueDelete {
3549 public const int ClassId = 50;
3550 public const int MethodId = 40;
3552 public ushort m_ticket;
3553 public string m_queue;
3554 public bool m_ifUnused;
3555 public bool m_ifEmpty;
3556 public bool m_nowait;
3558 ushort IQueueDelete.Ticket { get { return m_ticket; } }
3559 string IQueueDelete.Queue { get { return m_queue; } }
3560 bool IQueueDelete.IfUnused { get { return m_ifUnused; } }
3561 bool IQueueDelete.IfEmpty { get { return m_ifEmpty; } }
3562 bool IQueueDelete.Nowait { get { return m_nowait; } }
3564 public QueueDelete() {}
3572 m_ticket = initTicket;
3573 m_queue = initQueue;
3574 m_ifUnused = initIfUnused;
3575 m_ifEmpty = initIfEmpty;
3576 m_nowait = initNowait;
3579 public override int ProtocolClassId { get { return 50; } }
3580 public override int ProtocolMethodId { get { return 40; } }
3581 public override string ProtocolMethodName { get { return "queue.delete"; } }
3582 public override bool HasContent { get { return false; } }
3584 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3585 m_ticket = reader.ReadShort();
3586 m_queue = reader.ReadShortstr();
3587 m_ifUnused = reader.ReadBit();
3588 m_ifEmpty = reader.ReadBit();
3589 m_nowait = reader.ReadBit();
3592 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3593 writer.WriteShort(m_ticket);
3594 writer.WriteShortstr(m_queue);
3595 writer.WriteBit(m_ifUnused);
3596 writer.WriteBit(m_ifEmpty);
3597 writer.WriteBit(m_nowait);
3600 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3602 sb.Append(m_ticket); sb.Append(",");
3603 sb.Append(m_queue); sb.Append(",");
3604 sb.Append(m_ifUnused); sb.Append(",");
3605 sb.Append(m_ifEmpty); sb.Append(",");
3606 sb.Append(m_nowait);
3610 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3611 public class QueueDeleteOk: RabbitMQ.Client.Impl.MethodBase, IQueueDeleteOk {
3612 public const int ClassId = 50;
3613 public const int MethodId = 41;
3615 public uint m_messageCount;
3617 uint IQueueDeleteOk.MessageCount { get { return m_messageCount; } }
3619 public QueueDeleteOk() {}
3620 public QueueDeleteOk(
3621 uint initMessageCount)
3623 m_messageCount = initMessageCount;
3626 public override int ProtocolClassId { get { return 50; } }
3627 public override int ProtocolMethodId { get { return 41; } }
3628 public override string ProtocolMethodName { get { return "queue.delete-ok"; } }
3629 public override bool HasContent { get { return false; } }
3631 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3632 m_messageCount = reader.ReadLong();
3635 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3636 writer.WriteLong(m_messageCount);
3639 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3641 sb.Append(m_messageCount);
3645 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3646 public class BasicQos: RabbitMQ.Client.Impl.MethodBase, IBasicQos {
3647 public const int ClassId = 60;
3648 public const int MethodId = 10;
3650 public uint m_prefetchSize;
3651 public ushort m_prefetchCount;
3652 public bool m_global;
3654 uint IBasicQos.PrefetchSize { get { return m_prefetchSize; } }
3655 ushort IBasicQos.PrefetchCount { get { return m_prefetchCount; } }
3656 bool IBasicQos.Global { get { return m_global; } }
3658 public BasicQos() {}
3660 uint initPrefetchSize,
3661 ushort initPrefetchCount,
3664 m_prefetchSize = initPrefetchSize;
3665 m_prefetchCount = initPrefetchCount;
3666 m_global = initGlobal;
3669 public override int ProtocolClassId { get { return 60; } }
3670 public override int ProtocolMethodId { get { return 10; } }
3671 public override string ProtocolMethodName { get { return "basic.qos"; } }
3672 public override bool HasContent { get { return false; } }
3674 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3675 m_prefetchSize = reader.ReadLong();
3676 m_prefetchCount = reader.ReadShort();
3677 m_global = reader.ReadBit();
3680 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3681 writer.WriteLong(m_prefetchSize);
3682 writer.WriteShort(m_prefetchCount);
3683 writer.WriteBit(m_global);
3686 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3688 sb.Append(m_prefetchSize); sb.Append(",");
3689 sb.Append(m_prefetchCount); sb.Append(",");
3690 sb.Append(m_global);
3694 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3695 public class BasicQosOk: RabbitMQ.Client.Impl.MethodBase, IBasicQosOk {
3696 public const int ClassId = 60;
3697 public const int MethodId = 11;
3706 public override int ProtocolClassId { get { return 60; } }
3707 public override int ProtocolMethodId { get { return 11; } }
3708 public override string ProtocolMethodName { get { return "basic.qos-ok"; } }
3709 public override bool HasContent { get { return false; } }
3711 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3714 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3717 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3722 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3723 public class BasicConsume: RabbitMQ.Client.Impl.MethodBase, IBasicConsume {
3724 public const int ClassId = 60;
3725 public const int MethodId = 20;
3727 public ushort m_ticket;
3728 public string m_queue;
3729 public string m_consumerTag;
3730 public bool m_noLocal;
3731 public bool m_noAck;
3732 public bool m_exclusive;
3733 public bool m_nowait;
3734 public System.Collections.IDictionary m_filter;
3736 ushort IBasicConsume.Ticket { get { return m_ticket; } }
3737 string IBasicConsume.Queue { get { return m_queue; } }
3738 string IBasicConsume.ConsumerTag { get { return m_consumerTag; } }
3739 bool IBasicConsume.NoLocal { get { return m_noLocal; } }
3740 bool IBasicConsume.NoAck { get { return m_noAck; } }
3741 bool IBasicConsume.Exclusive { get { return m_exclusive; } }
3742 bool IBasicConsume.Nowait { get { return m_nowait; } }
3743 System.Collections.IDictionary IBasicConsume.Filter { get { return m_filter; } }
3745 public BasicConsume() {}
3746 public BasicConsume(
3749 string initConsumerTag,
3754 System.Collections.IDictionary initFilter)
3756 m_ticket = initTicket;
3757 m_queue = initQueue;
3758 m_consumerTag = initConsumerTag;
3759 m_noLocal = initNoLocal;
3760 m_noAck = initNoAck;
3761 m_exclusive = initExclusive;
3762 m_nowait = initNowait;
3763 m_filter = initFilter;
3766 public override int ProtocolClassId { get { return 60; } }
3767 public override int ProtocolMethodId { get { return 20; } }
3768 public override string ProtocolMethodName { get { return "basic.consume"; } }
3769 public override bool HasContent { get { return false; } }
3771 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3772 m_ticket = reader.ReadShort();
3773 m_queue = reader.ReadShortstr();
3774 m_consumerTag = reader.ReadShortstr();
3775 m_noLocal = reader.ReadBit();
3776 m_noAck = reader.ReadBit();
3777 m_exclusive = reader.ReadBit();
3778 m_nowait = reader.ReadBit();
3779 m_filter = reader.ReadTable();
3782 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3783 writer.WriteShort(m_ticket);
3784 writer.WriteShortstr(m_queue);
3785 writer.WriteShortstr(m_consumerTag);
3786 writer.WriteBit(m_noLocal);
3787 writer.WriteBit(m_noAck);
3788 writer.WriteBit(m_exclusive);
3789 writer.WriteBit(m_nowait);
3790 writer.WriteTable(m_filter);
3793 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3795 sb.Append(m_ticket); sb.Append(",");
3796 sb.Append(m_queue); sb.Append(",");
3797 sb.Append(m_consumerTag); sb.Append(",");
3798 sb.Append(m_noLocal); sb.Append(",");
3799 sb.Append(m_noAck); sb.Append(",");
3800 sb.Append(m_exclusive); sb.Append(",");
3801 sb.Append(m_nowait); sb.Append(",");
3802 sb.Append(m_filter);
3806 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3807 public class BasicConsumeOk: RabbitMQ.Client.Impl.MethodBase, IBasicConsumeOk {
3808 public const int ClassId = 60;
3809 public const int MethodId = 21;
3811 public string m_consumerTag;
3813 string IBasicConsumeOk.ConsumerTag { get { return m_consumerTag; } }
3815 public BasicConsumeOk() {}
3816 public BasicConsumeOk(
3817 string initConsumerTag)
3819 m_consumerTag = initConsumerTag;
3822 public override int ProtocolClassId { get { return 60; } }
3823 public override int ProtocolMethodId { get { return 21; } }
3824 public override string ProtocolMethodName { get { return "basic.consume-ok"; } }
3825 public override bool HasContent { get { return false; } }
3827 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3828 m_consumerTag = reader.ReadShortstr();
3831 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3832 writer.WriteShortstr(m_consumerTag);
3835 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3837 sb.Append(m_consumerTag);
3841 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3842 public class BasicCancel: RabbitMQ.Client.Impl.MethodBase, IBasicCancel {
3843 public const int ClassId = 60;
3844 public const int MethodId = 30;
3846 public string m_consumerTag;
3847 public bool m_nowait;
3849 string IBasicCancel.ConsumerTag { get { return m_consumerTag; } }
3850 bool IBasicCancel.Nowait { get { return m_nowait; } }
3852 public BasicCancel() {}
3854 string initConsumerTag,
3857 m_consumerTag = initConsumerTag;
3858 m_nowait = initNowait;
3861 public override int ProtocolClassId { get { return 60; } }
3862 public override int ProtocolMethodId { get { return 30; } }
3863 public override string ProtocolMethodName { get { return "basic.cancel"; } }
3864 public override bool HasContent { get { return false; } }
3866 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3867 m_consumerTag = reader.ReadShortstr();
3868 m_nowait = reader.ReadBit();
3871 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3872 writer.WriteShortstr(m_consumerTag);
3873 writer.WriteBit(m_nowait);
3876 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3878 sb.Append(m_consumerTag); sb.Append(",");
3879 sb.Append(m_nowait);
3883 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3884 public class BasicCancelOk: RabbitMQ.Client.Impl.MethodBase, IBasicCancelOk {
3885 public const int ClassId = 60;
3886 public const int MethodId = 31;
3888 public string m_consumerTag;
3890 string IBasicCancelOk.ConsumerTag { get { return m_consumerTag; } }
3892 public BasicCancelOk() {}
3893 public BasicCancelOk(
3894 string initConsumerTag)
3896 m_consumerTag = initConsumerTag;
3899 public override int ProtocolClassId { get { return 60; } }
3900 public override int ProtocolMethodId { get { return 31; } }
3901 public override string ProtocolMethodName { get { return "basic.cancel-ok"; } }
3902 public override bool HasContent { get { return false; } }
3904 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3905 m_consumerTag = reader.ReadShortstr();
3908 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3909 writer.WriteShortstr(m_consumerTag);
3912 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3914 sb.Append(m_consumerTag);
3918 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3919 public class BasicPublish: RabbitMQ.Client.Impl.MethodBase, IBasicPublish {
3920 public const int ClassId = 60;
3921 public const int MethodId = 40;
3923 public ushort m_ticket;
3924 public string m_exchange;
3925 public string m_routingKey;
3926 public bool m_mandatory;
3927 public bool m_immediate;
3929 ushort IBasicPublish.Ticket { get { return m_ticket; } }
3930 string IBasicPublish.Exchange { get { return m_exchange; } }
3931 string IBasicPublish.RoutingKey { get { return m_routingKey; } }
3932 bool IBasicPublish.Mandatory { get { return m_mandatory; } }
3933 bool IBasicPublish.Immediate { get { return m_immediate; } }
3935 public BasicPublish() {}
3936 public BasicPublish(
3938 string initExchange,
3939 string initRoutingKey,
3943 m_ticket = initTicket;
3944 m_exchange = initExchange;
3945 m_routingKey = initRoutingKey;
3946 m_mandatory = initMandatory;
3947 m_immediate = initImmediate;
3950 public override int ProtocolClassId { get { return 60; } }
3951 public override int ProtocolMethodId { get { return 40; } }
3952 public override string ProtocolMethodName { get { return "basic.publish"; } }
3953 public override bool HasContent { get { return true; } }
3955 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3956 m_ticket = reader.ReadShort();
3957 m_exchange = reader.ReadShortstr();
3958 m_routingKey = reader.ReadShortstr();
3959 m_mandatory = reader.ReadBit();
3960 m_immediate = reader.ReadBit();
3963 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3964 writer.WriteShort(m_ticket);
3965 writer.WriteShortstr(m_exchange);
3966 writer.WriteShortstr(m_routingKey);
3967 writer.WriteBit(m_mandatory);
3968 writer.WriteBit(m_immediate);
3971 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3973 sb.Append(m_ticket); sb.Append(",");
3974 sb.Append(m_exchange); sb.Append(",");
3975 sb.Append(m_routingKey); sb.Append(",");
3976 sb.Append(m_mandatory); sb.Append(",");
3977 sb.Append(m_immediate);
3981 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3982 public class BasicReturn: RabbitMQ.Client.Impl.MethodBase, IBasicReturn {
3983 public const int ClassId = 60;
3984 public const int MethodId = 50;
3986 public ushort m_replyCode;
3987 public string m_replyText;
3988 public string m_exchange;
3989 public string m_routingKey;
3991 ushort IBasicReturn.ReplyCode { get { return m_replyCode; } }
3992 string IBasicReturn.ReplyText { get { return m_replyText; } }
3993 string IBasicReturn.Exchange { get { return m_exchange; } }
3994 string IBasicReturn.RoutingKey { get { return m_routingKey; } }
3996 public BasicReturn() {}
3998 ushort initReplyCode,
3999 string initReplyText,
4000 string initExchange,
4001 string initRoutingKey)
4003 m_replyCode = initReplyCode;
4004 m_replyText = initReplyText;
4005 m_exchange = initExchange;
4006 m_routingKey = initRoutingKey;
4009 public override int ProtocolClassId { get { return 60; } }
4010 public override int ProtocolMethodId { get { return 50; } }
4011 public override string ProtocolMethodName { get { return "basic.return"; } }
4012 public override bool HasContent { get { return true; } }
4014 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4015 m_replyCode = reader.ReadShort();
4016 m_replyText = reader.ReadShortstr();
4017 m_exchange = reader.ReadShortstr();
4018 m_routingKey = reader.ReadShortstr();
4021 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4022 writer.WriteShort(m_replyCode);
4023 writer.WriteShortstr(m_replyText);
4024 writer.WriteShortstr(m_exchange);
4025 writer.WriteShortstr(m_routingKey);
4028 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4030 sb.Append(m_replyCode); sb.Append(",");
4031 sb.Append(m_replyText); sb.Append(",");
4032 sb.Append(m_exchange); sb.Append(",");
4033 sb.Append(m_routingKey);
4037 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4038 public class BasicDeliver: RabbitMQ.Client.Impl.MethodBase, IBasicDeliver {
4039 public const int ClassId = 60;
4040 public const int MethodId = 60;
4042 public string m_consumerTag;
4043 public ulong m_deliveryTag;
4044 public bool m_redelivered;
4045 public string m_exchange;
4046 public string m_routingKey;
4048 string IBasicDeliver.ConsumerTag { get { return m_consumerTag; } }
4049 ulong IBasicDeliver.DeliveryTag { get { return m_deliveryTag; } }
4050 bool IBasicDeliver.Redelivered { get { return m_redelivered; } }
4051 string IBasicDeliver.Exchange { get { return m_exchange; } }
4052 string IBasicDeliver.RoutingKey { get { return m_routingKey; } }
4054 public BasicDeliver() {}
4055 public BasicDeliver(
4056 string initConsumerTag,
4057 ulong initDeliveryTag,
4058 bool initRedelivered,
4059 string initExchange,
4060 string initRoutingKey)
4062 m_consumerTag = initConsumerTag;
4063 m_deliveryTag = initDeliveryTag;
4064 m_redelivered = initRedelivered;
4065 m_exchange = initExchange;
4066 m_routingKey = initRoutingKey;
4069 public override int ProtocolClassId { get { return 60; } }
4070 public override int ProtocolMethodId { get { return 60; } }
4071 public override string ProtocolMethodName { get { return "basic.deliver"; } }
4072 public override bool HasContent { get { return true; } }
4074 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4075 m_consumerTag = reader.ReadShortstr();
4076 m_deliveryTag = reader.ReadLonglong();
4077 m_redelivered = reader.ReadBit();
4078 m_exchange = reader.ReadShortstr();
4079 m_routingKey = reader.ReadShortstr();
4082 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4083 writer.WriteShortstr(m_consumerTag);
4084 writer.WriteLonglong(m_deliveryTag);
4085 writer.WriteBit(m_redelivered);
4086 writer.WriteShortstr(m_exchange);
4087 writer.WriteShortstr(m_routingKey);
4090 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4092 sb.Append(m_consumerTag); sb.Append(",");
4093 sb.Append(m_deliveryTag); sb.Append(",");
4094 sb.Append(m_redelivered); sb.Append(",");
4095 sb.Append(m_exchange); sb.Append(",");
4096 sb.Append(m_routingKey);
4100 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4101 public class BasicGet: RabbitMQ.Client.Impl.MethodBase, IBasicGet {
4102 public const int ClassId = 60;
4103 public const int MethodId = 70;
4105 public ushort m_ticket;
4106 public string m_queue;
4107 public bool m_noAck;
4109 ushort IBasicGet.Ticket { get { return m_ticket; } }
4110 string IBasicGet.Queue { get { return m_queue; } }
4111 bool IBasicGet.NoAck { get { return m_noAck; } }
4113 public BasicGet() {}
4119 m_ticket = initTicket;
4120 m_queue = initQueue;
4121 m_noAck = initNoAck;
4124 public override int ProtocolClassId { get { return 60; } }
4125 public override int ProtocolMethodId { get { return 70; } }
4126 public override string ProtocolMethodName { get { return "basic.get"; } }
4127 public override bool HasContent { get { return false; } }
4129 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4130 m_ticket = reader.ReadShort();
4131 m_queue = reader.ReadShortstr();
4132 m_noAck = reader.ReadBit();
4135 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4136 writer.WriteShort(m_ticket);
4137 writer.WriteShortstr(m_queue);
4138 writer.WriteBit(m_noAck);
4141 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4143 sb.Append(m_ticket); sb.Append(",");
4144 sb.Append(m_queue); sb.Append(",");
4149 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4150 public class BasicGetOk: RabbitMQ.Client.Impl.MethodBase, IBasicGetOk {
4151 public const int ClassId = 60;
4152 public const int MethodId = 71;
4154 public ulong m_deliveryTag;
4155 public bool m_redelivered;
4156 public string m_exchange;
4157 public string m_routingKey;
4158 public uint m_messageCount;
4160 ulong IBasicGetOk.DeliveryTag { get { return m_deliveryTag; } }
4161 bool IBasicGetOk.Redelivered { get { return m_redelivered; } }
4162 string IBasicGetOk.Exchange { get { return m_exchange; } }
4163 string IBasicGetOk.RoutingKey { get { return m_routingKey; } }
4164 uint IBasicGetOk.MessageCount { get { return m_messageCount; } }
4166 public BasicGetOk() {}
4168 ulong initDeliveryTag,
4169 bool initRedelivered,
4170 string initExchange,
4171 string initRoutingKey,
4172 uint initMessageCount)
4174 m_deliveryTag = initDeliveryTag;
4175 m_redelivered = initRedelivered;
4176 m_exchange = initExchange;
4177 m_routingKey = initRoutingKey;
4178 m_messageCount = initMessageCount;
4181 public override int ProtocolClassId { get { return 60; } }
4182 public override int ProtocolMethodId { get { return 71; } }
4183 public override string ProtocolMethodName { get { return "basic.get-ok"; } }
4184 public override bool HasContent { get { return true; } }
4186 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4187 m_deliveryTag = reader.ReadLonglong();
4188 m_redelivered = reader.ReadBit();
4189 m_exchange = reader.ReadShortstr();
4190 m_routingKey = reader.ReadShortstr();
4191 m_messageCount = reader.ReadLong();
4194 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4195 writer.WriteLonglong(m_deliveryTag);
4196 writer.WriteBit(m_redelivered);
4197 writer.WriteShortstr(m_exchange);
4198 writer.WriteShortstr(m_routingKey);
4199 writer.WriteLong(m_messageCount);
4202 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4204 sb.Append(m_deliveryTag); sb.Append(",");
4205 sb.Append(m_redelivered); sb.Append(",");
4206 sb.Append(m_exchange); sb.Append(",");
4207 sb.Append(m_routingKey); sb.Append(",");
4208 sb.Append(m_messageCount);
4212 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4213 public class BasicGetEmpty: RabbitMQ.Client.Impl.MethodBase, IBasicGetEmpty {
4214 public const int ClassId = 60;
4215 public const int MethodId = 72;
4217 public string m_clusterId;
4219 string IBasicGetEmpty.ClusterId { get { return m_clusterId; } }
4221 public BasicGetEmpty() {}
4222 public BasicGetEmpty(
4223 string initClusterId)
4225 m_clusterId = initClusterId;
4228 public override int ProtocolClassId { get { return 60; } }
4229 public override int ProtocolMethodId { get { return 72; } }
4230 public override string ProtocolMethodName { get { return "basic.get-empty"; } }
4231 public override bool HasContent { get { return false; } }
4233 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4234 m_clusterId = reader.ReadShortstr();
4237 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4238 writer.WriteShortstr(m_clusterId);
4241 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4243 sb.Append(m_clusterId);
4247 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4248 public class BasicAck: RabbitMQ.Client.Impl.MethodBase, IBasicAck {
4249 public const int ClassId = 60;
4250 public const int MethodId = 80;
4252 public ulong m_deliveryTag;
4253 public bool m_multiple;
4255 ulong IBasicAck.DeliveryTag { get { return m_deliveryTag; } }
4256 bool IBasicAck.Multiple { get { return m_multiple; } }
4258 public BasicAck() {}
4260 ulong initDeliveryTag,
4263 m_deliveryTag = initDeliveryTag;
4264 m_multiple = initMultiple;
4267 public override int ProtocolClassId { get { return 60; } }
4268 public override int ProtocolMethodId { get { return 80; } }
4269 public override string ProtocolMethodName { get { return "basic.ack"; } }
4270 public override bool HasContent { get { return false; } }
4272 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4273 m_deliveryTag = reader.ReadLonglong();
4274 m_multiple = reader.ReadBit();
4277 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4278 writer.WriteLonglong(m_deliveryTag);
4279 writer.WriteBit(m_multiple);
4282 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4284 sb.Append(m_deliveryTag); sb.Append(",");
4285 sb.Append(m_multiple);
4289 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4290 public class BasicReject: RabbitMQ.Client.Impl.MethodBase, IBasicReject {
4291 public const int ClassId = 60;
4292 public const int MethodId = 90;
4294 public ulong m_deliveryTag;
4295 public bool m_requeue;
4297 ulong IBasicReject.DeliveryTag { get { return m_deliveryTag; } }
4298 bool IBasicReject.Requeue { get { return m_requeue; } }
4300 public BasicReject() {}
4302 ulong initDeliveryTag,
4305 m_deliveryTag = initDeliveryTag;
4306 m_requeue = initRequeue;
4309 public override int ProtocolClassId { get { return 60; } }
4310 public override int ProtocolMethodId { get { return 90; } }
4311 public override string ProtocolMethodName { get { return "basic.reject"; } }
4312 public override bool HasContent { get { return false; } }
4314 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4315 m_deliveryTag = reader.ReadLonglong();
4316 m_requeue = reader.ReadBit();
4319 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4320 writer.WriteLonglong(m_deliveryTag);
4321 writer.WriteBit(m_requeue);
4324 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4326 sb.Append(m_deliveryTag); sb.Append(",");
4327 sb.Append(m_requeue);
4331 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4332 public class BasicRecover: RabbitMQ.Client.Impl.MethodBase, IBasicRecover {
4333 public const int ClassId = 60;
4334 public const int MethodId = 100;
4336 public bool m_requeue;
4338 bool IBasicRecover.Requeue { get { return m_requeue; } }
4340 public BasicRecover() {}
4341 public BasicRecover(
4344 m_requeue = initRequeue;
4347 public override int ProtocolClassId { get { return 60; } }
4348 public override int ProtocolMethodId { get { return 100; } }
4349 public override string ProtocolMethodName { get { return "basic.recover"; } }
4350 public override bool HasContent { get { return false; } }
4352 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4353 m_requeue = reader.ReadBit();
4356 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4357 writer.WriteBit(m_requeue);
4360 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4362 sb.Append(m_requeue);
4366 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4367 public class FileQos: RabbitMQ.Client.Impl.MethodBase, IFileQos {
4368 public const int ClassId = 70;
4369 public const int MethodId = 10;
4371 public uint m_prefetchSize;
4372 public ushort m_prefetchCount;
4373 public bool m_global;
4375 uint IFileQos.PrefetchSize { get { return m_prefetchSize; } }
4376 ushort IFileQos.PrefetchCount { get { return m_prefetchCount; } }
4377 bool IFileQos.Global { get { return m_global; } }
4381 uint initPrefetchSize,
4382 ushort initPrefetchCount,
4385 m_prefetchSize = initPrefetchSize;
4386 m_prefetchCount = initPrefetchCount;
4387 m_global = initGlobal;
4390 public override int ProtocolClassId { get { return 70; } }
4391 public override int ProtocolMethodId { get { return 10; } }
4392 public override string ProtocolMethodName { get { return "file.qos"; } }
4393 public override bool HasContent { get { return false; } }
4395 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4396 m_prefetchSize = reader.ReadLong();
4397 m_prefetchCount = reader.ReadShort();
4398 m_global = reader.ReadBit();
4401 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4402 writer.WriteLong(m_prefetchSize);
4403 writer.WriteShort(m_prefetchCount);
4404 writer.WriteBit(m_global);
4407 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4409 sb.Append(m_prefetchSize); sb.Append(",");
4410 sb.Append(m_prefetchCount); sb.Append(",");
4411 sb.Append(m_global);
4415 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4416 public class FileQosOk: RabbitMQ.Client.Impl.MethodBase, IFileQosOk {
4417 public const int ClassId = 70;
4418 public const int MethodId = 11;
4427 public override int ProtocolClassId { get { return 70; } }
4428 public override int ProtocolMethodId { get { return 11; } }
4429 public override string ProtocolMethodName { get { return "file.qos-ok"; } }
4430 public override bool HasContent { get { return false; } }
4432 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4435 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4438 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4443 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4444 public class FileConsume: RabbitMQ.Client.Impl.MethodBase, IFileConsume {
4445 public const int ClassId = 70;
4446 public const int MethodId = 20;
4448 public ushort m_ticket;
4449 public string m_queue;
4450 public string m_consumerTag;
4451 public bool m_noLocal;
4452 public bool m_noAck;
4453 public bool m_exclusive;
4454 public bool m_nowait;
4455 public System.Collections.IDictionary m_filter;
4457 ushort IFileConsume.Ticket { get { return m_ticket; } }
4458 string IFileConsume.Queue { get { return m_queue; } }
4459 string IFileConsume.ConsumerTag { get { return m_consumerTag; } }
4460 bool IFileConsume.NoLocal { get { return m_noLocal; } }
4461 bool IFileConsume.NoAck { get { return m_noAck; } }
4462 bool IFileConsume.Exclusive { get { return m_exclusive; } }
4463 bool IFileConsume.Nowait { get { return m_nowait; } }
4464 System.Collections.IDictionary IFileConsume.Filter { get { return m_filter; } }
4466 public FileConsume() {}
4470 string initConsumerTag,
4475 System.Collections.IDictionary initFilter)
4477 m_ticket = initTicket;
4478 m_queue = initQueue;
4479 m_consumerTag = initConsumerTag;
4480 m_noLocal = initNoLocal;
4481 m_noAck = initNoAck;
4482 m_exclusive = initExclusive;
4483 m_nowait = initNowait;
4484 m_filter = initFilter;
4487 public override int ProtocolClassId { get { return 70; } }
4488 public override int ProtocolMethodId { get { return 20; } }
4489 public override string ProtocolMethodName { get { return "file.consume"; } }
4490 public override bool HasContent { get { return false; } }
4492 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4493 m_ticket = reader.ReadShort();
4494 m_queue = reader.ReadShortstr();
4495 m_consumerTag = reader.ReadShortstr();
4496 m_noLocal = reader.ReadBit();
4497 m_noAck = reader.ReadBit();
4498 m_exclusive = reader.ReadBit();
4499 m_nowait = reader.ReadBit();
4500 m_filter = reader.ReadTable();
4503 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4504 writer.WriteShort(m_ticket);
4505 writer.WriteShortstr(m_queue);
4506 writer.WriteShortstr(m_consumerTag);
4507 writer.WriteBit(m_noLocal);
4508 writer.WriteBit(m_noAck);
4509 writer.WriteBit(m_exclusive);
4510 writer.WriteBit(m_nowait);
4511 writer.WriteTable(m_filter);
4514 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4516 sb.Append(m_ticket); sb.Append(",");
4517 sb.Append(m_queue); sb.Append(",");
4518 sb.Append(m_consumerTag); sb.Append(",");
4519 sb.Append(m_noLocal); sb.Append(",");
4520 sb.Append(m_noAck); sb.Append(",");
4521 sb.Append(m_exclusive); sb.Append(",");
4522 sb.Append(m_nowait); sb.Append(",");
4523 sb.Append(m_filter);
4527 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4528 public class FileConsumeOk: RabbitMQ.Client.Impl.MethodBase, IFileConsumeOk {
4529 public const int ClassId = 70;
4530 public const int MethodId = 21;
4532 public string m_consumerTag;
4534 string IFileConsumeOk.ConsumerTag { get { return m_consumerTag; } }
4536 public FileConsumeOk() {}
4537 public FileConsumeOk(
4538 string initConsumerTag)
4540 m_consumerTag = initConsumerTag;
4543 public override int ProtocolClassId { get { return 70; } }
4544 public override int ProtocolMethodId { get { return 21; } }
4545 public override string ProtocolMethodName { get { return "file.consume-ok"; } }
4546 public override bool HasContent { get { return false; } }
4548 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4549 m_consumerTag = reader.ReadShortstr();
4552 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4553 writer.WriteShortstr(m_consumerTag);
4556 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4558 sb.Append(m_consumerTag);
4562 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4563 public class FileCancel: RabbitMQ.Client.Impl.MethodBase, IFileCancel {
4564 public const int ClassId = 70;
4565 public const int MethodId = 30;
4567 public string m_consumerTag;
4568 public bool m_nowait;
4570 string IFileCancel.ConsumerTag { get { return m_consumerTag; } }
4571 bool IFileCancel.Nowait { get { return m_nowait; } }
4573 public FileCancel() {}
4575 string initConsumerTag,
4578 m_consumerTag = initConsumerTag;
4579 m_nowait = initNowait;
4582 public override int ProtocolClassId { get { return 70; } }
4583 public override int ProtocolMethodId { get { return 30; } }
4584 public override string ProtocolMethodName { get { return "file.cancel"; } }
4585 public override bool HasContent { get { return false; } }
4587 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4588 m_consumerTag = reader.ReadShortstr();
4589 m_nowait = reader.ReadBit();
4592 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4593 writer.WriteShortstr(m_consumerTag);
4594 writer.WriteBit(m_nowait);
4597 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4599 sb.Append(m_consumerTag); sb.Append(",");
4600 sb.Append(m_nowait);
4604 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4605 public class FileCancelOk: RabbitMQ.Client.Impl.MethodBase, IFileCancelOk {
4606 public const int ClassId = 70;
4607 public const int MethodId = 31;
4609 public string m_consumerTag;
4611 string IFileCancelOk.ConsumerTag { get { return m_consumerTag; } }
4613 public FileCancelOk() {}
4614 public FileCancelOk(
4615 string initConsumerTag)
4617 m_consumerTag = initConsumerTag;
4620 public override int ProtocolClassId { get { return 70; } }
4621 public override int ProtocolMethodId { get { return 31; } }
4622 public override string ProtocolMethodName { get { return "file.cancel-ok"; } }
4623 public override bool HasContent { get { return false; } }
4625 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4626 m_consumerTag = reader.ReadShortstr();
4629 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4630 writer.WriteShortstr(m_consumerTag);
4633 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4635 sb.Append(m_consumerTag);
4639 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4640 public class FileOpen: RabbitMQ.Client.Impl.MethodBase, IFileOpen {
4641 public const int ClassId = 70;
4642 public const int MethodId = 40;
4644 public string m_identifier;
4645 public ulong m_contentSize;
4647 string IFileOpen.Identifier { get { return m_identifier; } }
4648 ulong IFileOpen.ContentSize { get { return m_contentSize; } }
4650 public FileOpen() {}
4652 string initIdentifier,
4653 ulong initContentSize)
4655 m_identifier = initIdentifier;
4656 m_contentSize = initContentSize;
4659 public override int ProtocolClassId { get { return 70; } }
4660 public override int ProtocolMethodId { get { return 40; } }
4661 public override string ProtocolMethodName { get { return "file.open"; } }
4662 public override bool HasContent { get { return false; } }
4664 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4665 m_identifier = reader.ReadShortstr();
4666 m_contentSize = reader.ReadLonglong();
4669 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4670 writer.WriteShortstr(m_identifier);
4671 writer.WriteLonglong(m_contentSize);
4674 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4676 sb.Append(m_identifier); sb.Append(",");
4677 sb.Append(m_contentSize);
4681 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4682 public class FileOpenOk: RabbitMQ.Client.Impl.MethodBase, IFileOpenOk {
4683 public const int ClassId = 70;
4684 public const int MethodId = 41;
4686 public ulong m_stagedSize;
4688 ulong IFileOpenOk.StagedSize { get { return m_stagedSize; } }
4690 public FileOpenOk() {}
4692 ulong initStagedSize)
4694 m_stagedSize = initStagedSize;
4697 public override int ProtocolClassId { get { return 70; } }
4698 public override int ProtocolMethodId { get { return 41; } }
4699 public override string ProtocolMethodName { get { return "file.open-ok"; } }
4700 public override bool HasContent { get { return false; } }
4702 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4703 m_stagedSize = reader.ReadLonglong();
4706 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4707 writer.WriteLonglong(m_stagedSize);
4710 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4712 sb.Append(m_stagedSize);
4716 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4717 public class FileStage: RabbitMQ.Client.Impl.MethodBase, IFileStage {
4718 public const int ClassId = 70;
4719 public const int MethodId = 50;
4728 public override int ProtocolClassId { get { return 70; } }
4729 public override int ProtocolMethodId { get { return 50; } }
4730 public override string ProtocolMethodName { get { return "file.stage"; } }
4731 public override bool HasContent { get { return true; } }
4733 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4736 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4739 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4744 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4745 public class FilePublish: RabbitMQ.Client.Impl.MethodBase, IFilePublish {
4746 public const int ClassId = 70;
4747 public const int MethodId = 60;
4749 public ushort m_ticket;
4750 public string m_exchange;
4751 public string m_routingKey;
4752 public bool m_mandatory;
4753 public bool m_immediate;
4754 public string m_identifier;
4756 ushort IFilePublish.Ticket { get { return m_ticket; } }
4757 string IFilePublish.Exchange { get { return m_exchange; } }
4758 string IFilePublish.RoutingKey { get { return m_routingKey; } }
4759 bool IFilePublish.Mandatory { get { return m_mandatory; } }
4760 bool IFilePublish.Immediate { get { return m_immediate; } }
4761 string IFilePublish.Identifier { get { return m_identifier; } }
4763 public FilePublish() {}
4766 string initExchange,
4767 string initRoutingKey,
4770 string initIdentifier)
4772 m_ticket = initTicket;
4773 m_exchange = initExchange;
4774 m_routingKey = initRoutingKey;
4775 m_mandatory = initMandatory;
4776 m_immediate = initImmediate;
4777 m_identifier = initIdentifier;
4780 public override int ProtocolClassId { get { return 70; } }
4781 public override int ProtocolMethodId { get { return 60; } }
4782 public override string ProtocolMethodName { get { return "file.publish"; } }
4783 public override bool HasContent { get { return false; } }
4785 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4786 m_ticket = reader.ReadShort();
4787 m_exchange = reader.ReadShortstr();
4788 m_routingKey = reader.ReadShortstr();
4789 m_mandatory = reader.ReadBit();
4790 m_immediate = reader.ReadBit();
4791 m_identifier = reader.ReadShortstr();
4794 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4795 writer.WriteShort(m_ticket);
4796 writer.WriteShortstr(m_exchange);
4797 writer.WriteShortstr(m_routingKey);
4798 writer.WriteBit(m_mandatory);
4799 writer.WriteBit(m_immediate);
4800 writer.WriteShortstr(m_identifier);
4803 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4805 sb.Append(m_ticket); sb.Append(",");
4806 sb.Append(m_exchange); sb.Append(",");
4807 sb.Append(m_routingKey); sb.Append(",");
4808 sb.Append(m_mandatory); sb.Append(",");
4809 sb.Append(m_immediate); sb.Append(",");
4810 sb.Append(m_identifier);
4814 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4815 public class FileReturn: RabbitMQ.Client.Impl.MethodBase, IFileReturn {
4816 public const int ClassId = 70;
4817 public const int MethodId = 70;
4819 public ushort m_replyCode;
4820 public string m_replyText;
4821 public string m_exchange;
4822 public string m_routingKey;
4824 ushort IFileReturn.ReplyCode { get { return m_replyCode; } }
4825 string IFileReturn.ReplyText { get { return m_replyText; } }
4826 string IFileReturn.Exchange { get { return m_exchange; } }
4827 string IFileReturn.RoutingKey { get { return m_routingKey; } }
4829 public FileReturn() {}
4831 ushort initReplyCode,
4832 string initReplyText,
4833 string initExchange,
4834 string initRoutingKey)
4836 m_replyCode = initReplyCode;
4837 m_replyText = initReplyText;
4838 m_exchange = initExchange;
4839 m_routingKey = initRoutingKey;
4842 public override int ProtocolClassId { get { return 70; } }
4843 public override int ProtocolMethodId { get { return 70; } }
4844 public override string ProtocolMethodName { get { return "file.return"; } }
4845 public override bool HasContent { get { return true; } }
4847 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4848 m_replyCode = reader.ReadShort();
4849 m_replyText = reader.ReadShortstr();
4850 m_exchange = reader.ReadShortstr();
4851 m_routingKey = reader.ReadShortstr();
4854 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4855 writer.WriteShort(m_replyCode);
4856 writer.WriteShortstr(m_replyText);
4857 writer.WriteShortstr(m_exchange);
4858 writer.WriteShortstr(m_routingKey);
4861 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4863 sb.Append(m_replyCode); sb.Append(",");
4864 sb.Append(m_replyText); sb.Append(",");
4865 sb.Append(m_exchange); sb.Append(",");
4866 sb.Append(m_routingKey);
4870 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4871 public class FileDeliver: RabbitMQ.Client.Impl.MethodBase, IFileDeliver {
4872 public const int ClassId = 70;
4873 public const int MethodId = 80;
4875 public string m_consumerTag;
4876 public ulong m_deliveryTag;
4877 public bool m_redelivered;
4878 public string m_exchange;
4879 public string m_routingKey;
4880 public string m_identifier;
4882 string IFileDeliver.ConsumerTag { get { return m_consumerTag; } }
4883 ulong IFileDeliver.DeliveryTag { get { return m_deliveryTag; } }
4884 bool IFileDeliver.Redelivered { get { return m_redelivered; } }
4885 string IFileDeliver.Exchange { get { return m_exchange; } }
4886 string IFileDeliver.RoutingKey { get { return m_routingKey; } }
4887 string IFileDeliver.Identifier { get { return m_identifier; } }
4889 public FileDeliver() {}
4891 string initConsumerTag,
4892 ulong initDeliveryTag,
4893 bool initRedelivered,
4894 string initExchange,
4895 string initRoutingKey,
4896 string initIdentifier)
4898 m_consumerTag = initConsumerTag;
4899 m_deliveryTag = initDeliveryTag;
4900 m_redelivered = initRedelivered;
4901 m_exchange = initExchange;
4902 m_routingKey = initRoutingKey;
4903 m_identifier = initIdentifier;
4906 public override int ProtocolClassId { get { return 70; } }
4907 public override int ProtocolMethodId { get { return 80; } }
4908 public override string ProtocolMethodName { get { return "file.deliver"; } }
4909 public override bool HasContent { get { return false; } }
4911 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4912 m_consumerTag = reader.ReadShortstr();
4913 m_deliveryTag = reader.ReadLonglong();
4914 m_redelivered = reader.ReadBit();
4915 m_exchange = reader.ReadShortstr();
4916 m_routingKey = reader.ReadShortstr();
4917 m_identifier = reader.ReadShortstr();
4920 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4921 writer.WriteShortstr(m_consumerTag);
4922 writer.WriteLonglong(m_deliveryTag);
4923 writer.WriteBit(m_redelivered);
4924 writer.WriteShortstr(m_exchange);
4925 writer.WriteShortstr(m_routingKey);
4926 writer.WriteShortstr(m_identifier);
4929 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4931 sb.Append(m_consumerTag); sb.Append(",");
4932 sb.Append(m_deliveryTag); sb.Append(",");
4933 sb.Append(m_redelivered); sb.Append(",");
4934 sb.Append(m_exchange); sb.Append(",");
4935 sb.Append(m_routingKey); sb.Append(",");
4936 sb.Append(m_identifier);
4940 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4941 public class FileAck: RabbitMQ.Client.Impl.MethodBase, IFileAck {
4942 public const int ClassId = 70;
4943 public const int MethodId = 90;
4945 public ulong m_deliveryTag;
4946 public bool m_multiple;
4948 ulong IFileAck.DeliveryTag { get { return m_deliveryTag; } }
4949 bool IFileAck.Multiple { get { return m_multiple; } }
4953 ulong initDeliveryTag,
4956 m_deliveryTag = initDeliveryTag;
4957 m_multiple = initMultiple;
4960 public override int ProtocolClassId { get { return 70; } }
4961 public override int ProtocolMethodId { get { return 90; } }
4962 public override string ProtocolMethodName { get { return "file.ack"; } }
4963 public override bool HasContent { get { return false; } }
4965 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4966 m_deliveryTag = reader.ReadLonglong();
4967 m_multiple = reader.ReadBit();
4970 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4971 writer.WriteLonglong(m_deliveryTag);
4972 writer.WriteBit(m_multiple);
4975 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4977 sb.Append(m_deliveryTag); sb.Append(",");
4978 sb.Append(m_multiple);
4982 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4983 public class FileReject: RabbitMQ.Client.Impl.MethodBase, IFileReject {
4984 public const int ClassId = 70;
4985 public const int MethodId = 100;
4987 public ulong m_deliveryTag;
4988 public bool m_requeue;
4990 ulong IFileReject.DeliveryTag { get { return m_deliveryTag; } }
4991 bool IFileReject.Requeue { get { return m_requeue; } }
4993 public FileReject() {}
4995 ulong initDeliveryTag,
4998 m_deliveryTag = initDeliveryTag;
4999 m_requeue = initRequeue;
5002 public override int ProtocolClassId { get { return 70; } }
5003 public override int ProtocolMethodId { get { return 100; } }
5004 public override string ProtocolMethodName { get { return "file.reject"; } }
5005 public override bool HasContent { get { return false; } }
5007 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5008 m_deliveryTag = reader.ReadLonglong();
5009 m_requeue = reader.ReadBit();
5012 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5013 writer.WriteLonglong(m_deliveryTag);
5014 writer.WriteBit(m_requeue);
5017 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5019 sb.Append(m_deliveryTag); sb.Append(",");
5020 sb.Append(m_requeue);
5024 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5025 public class StreamQos: RabbitMQ.Client.Impl.MethodBase, IStreamQos {
5026 public const int ClassId = 80;
5027 public const int MethodId = 10;
5029 public uint m_prefetchSize;
5030 public ushort m_prefetchCount;
5031 public uint m_consumeRate;
5032 public bool m_global;
5034 uint IStreamQos.PrefetchSize { get { return m_prefetchSize; } }
5035 ushort IStreamQos.PrefetchCount { get { return m_prefetchCount; } }
5036 uint IStreamQos.ConsumeRate { get { return m_consumeRate; } }
5037 bool IStreamQos.Global { get { return m_global; } }
5039 public StreamQos() {}
5041 uint initPrefetchSize,
5042 ushort initPrefetchCount,
5043 uint initConsumeRate,
5046 m_prefetchSize = initPrefetchSize;
5047 m_prefetchCount = initPrefetchCount;
5048 m_consumeRate = initConsumeRate;
5049 m_global = initGlobal;
5052 public override int ProtocolClassId { get { return 80; } }
5053 public override int ProtocolMethodId { get { return 10; } }
5054 public override string ProtocolMethodName { get { return "stream.qos"; } }
5055 public override bool HasContent { get { return false; } }
5057 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5058 m_prefetchSize = reader.ReadLong();
5059 m_prefetchCount = reader.ReadShort();
5060 m_consumeRate = reader.ReadLong();
5061 m_global = reader.ReadBit();
5064 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5065 writer.WriteLong(m_prefetchSize);
5066 writer.WriteShort(m_prefetchCount);
5067 writer.WriteLong(m_consumeRate);
5068 writer.WriteBit(m_global);
5071 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5073 sb.Append(m_prefetchSize); sb.Append(",");
5074 sb.Append(m_prefetchCount); sb.Append(",");
5075 sb.Append(m_consumeRate); sb.Append(",");
5076 sb.Append(m_global);
5080 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5081 public class StreamQosOk: RabbitMQ.Client.Impl.MethodBase, IStreamQosOk {
5082 public const int ClassId = 80;
5083 public const int MethodId = 11;
5092 public override int ProtocolClassId { get { return 80; } }
5093 public override int ProtocolMethodId { get { return 11; } }
5094 public override string ProtocolMethodName { get { return "stream.qos-ok"; } }
5095 public override bool HasContent { get { return false; } }
5097 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5100 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5103 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5108 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5109 public class StreamConsume: RabbitMQ.Client.Impl.MethodBase, IStreamConsume {
5110 public const int ClassId = 80;
5111 public const int MethodId = 20;
5113 public ushort m_ticket;
5114 public string m_queue;
5115 public string m_consumerTag;
5116 public bool m_noLocal;
5117 public bool m_exclusive;
5118 public bool m_nowait;
5119 public System.Collections.IDictionary m_filter;
5121 ushort IStreamConsume.Ticket { get { return m_ticket; } }
5122 string IStreamConsume.Queue { get { return m_queue; } }
5123 string IStreamConsume.ConsumerTag { get { return m_consumerTag; } }
5124 bool IStreamConsume.NoLocal { get { return m_noLocal; } }
5125 bool IStreamConsume.Exclusive { get { return m_exclusive; } }
5126 bool IStreamConsume.Nowait { get { return m_nowait; } }
5127 System.Collections.IDictionary IStreamConsume.Filter { get { return m_filter; } }
5129 public StreamConsume() {}
5130 public StreamConsume(
5133 string initConsumerTag,
5137 System.Collections.IDictionary initFilter)
5139 m_ticket = initTicket;
5140 m_queue = initQueue;
5141 m_consumerTag = initConsumerTag;
5142 m_noLocal = initNoLocal;
5143 m_exclusive = initExclusive;
5144 m_nowait = initNowait;
5145 m_filter = initFilter;
5148 public override int ProtocolClassId { get { return 80; } }
5149 public override int ProtocolMethodId { get { return 20; } }
5150 public override string ProtocolMethodName { get { return "stream.consume"; } }
5151 public override bool HasContent { get { return false; } }
5153 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5154 m_ticket = reader.ReadShort();
5155 m_queue = reader.ReadShortstr();
5156 m_consumerTag = reader.ReadShortstr();
5157 m_noLocal = reader.ReadBit();
5158 m_exclusive = reader.ReadBit();
5159 m_nowait = reader.ReadBit();
5160 m_filter = reader.ReadTable();
5163 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5164 writer.WriteShort(m_ticket);
5165 writer.WriteShortstr(m_queue);
5166 writer.WriteShortstr(m_consumerTag);
5167 writer.WriteBit(m_noLocal);
5168 writer.WriteBit(m_exclusive);
5169 writer.WriteBit(m_nowait);
5170 writer.WriteTable(m_filter);
5173 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5175 sb.Append(m_ticket); sb.Append(",");
5176 sb.Append(m_queue); sb.Append(",");
5177 sb.Append(m_consumerTag); sb.Append(",");
5178 sb.Append(m_noLocal); sb.Append(",");
5179 sb.Append(m_exclusive); sb.Append(",");
5180 sb.Append(m_nowait); sb.Append(",");
5181 sb.Append(m_filter);
5185 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5186 public class StreamConsumeOk: RabbitMQ.Client.Impl.MethodBase, IStreamConsumeOk {
5187 public const int ClassId = 80;
5188 public const int MethodId = 21;
5190 public string m_consumerTag;
5192 string IStreamConsumeOk.ConsumerTag { get { return m_consumerTag; } }
5194 public StreamConsumeOk() {}
5195 public StreamConsumeOk(
5196 string initConsumerTag)
5198 m_consumerTag = initConsumerTag;
5201 public override int ProtocolClassId { get { return 80; } }
5202 public override int ProtocolMethodId { get { return 21; } }
5203 public override string ProtocolMethodName { get { return "stream.consume-ok"; } }
5204 public override bool HasContent { get { return false; } }
5206 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5207 m_consumerTag = reader.ReadShortstr();
5210 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5211 writer.WriteShortstr(m_consumerTag);
5214 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5216 sb.Append(m_consumerTag);
5220 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5221 public class StreamCancel: RabbitMQ.Client.Impl.MethodBase, IStreamCancel {
5222 public const int ClassId = 80;
5223 public const int MethodId = 30;
5225 public string m_consumerTag;
5226 public bool m_nowait;
5228 string IStreamCancel.ConsumerTag { get { return m_consumerTag; } }
5229 bool IStreamCancel.Nowait { get { return m_nowait; } }
5231 public StreamCancel() {}
5232 public StreamCancel(
5233 string initConsumerTag,
5236 m_consumerTag = initConsumerTag;
5237 m_nowait = initNowait;
5240 public override int ProtocolClassId { get { return 80; } }
5241 public override int ProtocolMethodId { get { return 30; } }
5242 public override string ProtocolMethodName { get { return "stream.cancel"; } }
5243 public override bool HasContent { get { return false; } }
5245 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5246 m_consumerTag = reader.ReadShortstr();
5247 m_nowait = reader.ReadBit();
5250 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5251 writer.WriteShortstr(m_consumerTag);
5252 writer.WriteBit(m_nowait);
5255 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5257 sb.Append(m_consumerTag); sb.Append(",");
5258 sb.Append(m_nowait);
5262 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5263 public class StreamCancelOk: RabbitMQ.Client.Impl.MethodBase, IStreamCancelOk {
5264 public const int ClassId = 80;
5265 public const int MethodId = 31;
5267 public string m_consumerTag;
5269 string IStreamCancelOk.ConsumerTag { get { return m_consumerTag; } }
5271 public StreamCancelOk() {}
5272 public StreamCancelOk(
5273 string initConsumerTag)
5275 m_consumerTag = initConsumerTag;
5278 public override int ProtocolClassId { get { return 80; } }
5279 public override int ProtocolMethodId { get { return 31; } }
5280 public override string ProtocolMethodName { get { return "stream.cancel-ok"; } }
5281 public override bool HasContent { get { return false; } }
5283 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5284 m_consumerTag = reader.ReadShortstr();
5287 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5288 writer.WriteShortstr(m_consumerTag);
5291 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5293 sb.Append(m_consumerTag);
5297 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5298 public class StreamPublish: RabbitMQ.Client.Impl.MethodBase, IStreamPublish {
5299 public const int ClassId = 80;
5300 public const int MethodId = 40;
5302 public ushort m_ticket;
5303 public string m_exchange;
5304 public string m_routingKey;
5305 public bool m_mandatory;
5306 public bool m_immediate;
5308 ushort IStreamPublish.Ticket { get { return m_ticket; } }
5309 string IStreamPublish.Exchange { get { return m_exchange; } }
5310 string IStreamPublish.RoutingKey { get { return m_routingKey; } }
5311 bool IStreamPublish.Mandatory { get { return m_mandatory; } }
5312 bool IStreamPublish.Immediate { get { return m_immediate; } }
5314 public StreamPublish() {}
5315 public StreamPublish(
5317 string initExchange,
5318 string initRoutingKey,
5322 m_ticket = initTicket;
5323 m_exchange = initExchange;
5324 m_routingKey = initRoutingKey;
5325 m_mandatory = initMandatory;
5326 m_immediate = initImmediate;
5329 public override int ProtocolClassId { get { return 80; } }
5330 public override int ProtocolMethodId { get { return 40; } }
5331 public override string ProtocolMethodName { get { return "stream.publish"; } }
5332 public override bool HasContent { get { return true; } }
5334 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5335 m_ticket = reader.ReadShort();
5336 m_exchange = reader.ReadShortstr();
5337 m_routingKey = reader.ReadShortstr();
5338 m_mandatory = reader.ReadBit();
5339 m_immediate = reader.ReadBit();
5342 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5343 writer.WriteShort(m_ticket);
5344 writer.WriteShortstr(m_exchange);
5345 writer.WriteShortstr(m_routingKey);
5346 writer.WriteBit(m_mandatory);
5347 writer.WriteBit(m_immediate);
5350 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5352 sb.Append(m_ticket); sb.Append(",");
5353 sb.Append(m_exchange); sb.Append(",");
5354 sb.Append(m_routingKey); sb.Append(",");
5355 sb.Append(m_mandatory); sb.Append(",");
5356 sb.Append(m_immediate);
5360 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5361 public class StreamReturn: RabbitMQ.Client.Impl.MethodBase, IStreamReturn {
5362 public const int ClassId = 80;
5363 public const int MethodId = 50;
5365 public ushort m_replyCode;
5366 public string m_replyText;
5367 public string m_exchange;
5368 public string m_routingKey;
5370 ushort IStreamReturn.ReplyCode { get { return m_replyCode; } }
5371 string IStreamReturn.ReplyText { get { return m_replyText; } }
5372 string IStreamReturn.Exchange { get { return m_exchange; } }
5373 string IStreamReturn.RoutingKey { get { return m_routingKey; } }
5375 public StreamReturn() {}
5376 public StreamReturn(
5377 ushort initReplyCode,
5378 string initReplyText,
5379 string initExchange,
5380 string initRoutingKey)
5382 m_replyCode = initReplyCode;
5383 m_replyText = initReplyText;
5384 m_exchange = initExchange;
5385 m_routingKey = initRoutingKey;
5388 public override int ProtocolClassId { get { return 80; } }
5389 public override int ProtocolMethodId { get { return 50; } }
5390 public override string ProtocolMethodName { get { return "stream.return"; } }
5391 public override bool HasContent { get { return true; } }
5393 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5394 m_replyCode = reader.ReadShort();
5395 m_replyText = reader.ReadShortstr();
5396 m_exchange = reader.ReadShortstr();
5397 m_routingKey = reader.ReadShortstr();
5400 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5401 writer.WriteShort(m_replyCode);
5402 writer.WriteShortstr(m_replyText);
5403 writer.WriteShortstr(m_exchange);
5404 writer.WriteShortstr(m_routingKey);
5407 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5409 sb.Append(m_replyCode); sb.Append(",");
5410 sb.Append(m_replyText); sb.Append(",");
5411 sb.Append(m_exchange); sb.Append(",");
5412 sb.Append(m_routingKey);
5416 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5417 public class StreamDeliver: RabbitMQ.Client.Impl.MethodBase, IStreamDeliver {
5418 public const int ClassId = 80;
5419 public const int MethodId = 60;
5421 public string m_consumerTag;
5422 public ulong m_deliveryTag;
5423 public string m_exchange;
5424 public string m_queue;
5426 string IStreamDeliver.ConsumerTag { get { return m_consumerTag; } }
5427 ulong IStreamDeliver.DeliveryTag { get { return m_deliveryTag; } }
5428 string IStreamDeliver.Exchange { get { return m_exchange; } }
5429 string IStreamDeliver.Queue { get { return m_queue; } }
5431 public StreamDeliver() {}
5432 public StreamDeliver(
5433 string initConsumerTag,
5434 ulong initDeliveryTag,
5435 string initExchange,
5438 m_consumerTag = initConsumerTag;
5439 m_deliveryTag = initDeliveryTag;
5440 m_exchange = initExchange;
5441 m_queue = initQueue;
5444 public override int ProtocolClassId { get { return 80; } }
5445 public override int ProtocolMethodId { get { return 60; } }
5446 public override string ProtocolMethodName { get { return "stream.deliver"; } }
5447 public override bool HasContent { get { return true; } }
5449 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5450 m_consumerTag = reader.ReadShortstr();
5451 m_deliveryTag = reader.ReadLonglong();
5452 m_exchange = reader.ReadShortstr();
5453 m_queue = reader.ReadShortstr();
5456 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5457 writer.WriteShortstr(m_consumerTag);
5458 writer.WriteLonglong(m_deliveryTag);
5459 writer.WriteShortstr(m_exchange);
5460 writer.WriteShortstr(m_queue);
5463 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5465 sb.Append(m_consumerTag); sb.Append(",");
5466 sb.Append(m_deliveryTag); sb.Append(",");
5467 sb.Append(m_exchange); sb.Append(",");
5472 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5473 public class TxSelect: RabbitMQ.Client.Impl.MethodBase, ITxSelect {
5474 public const int ClassId = 90;
5475 public const int MethodId = 10;
5484 public override int ProtocolClassId { get { return 90; } }
5485 public override int ProtocolMethodId { get { return 10; } }
5486 public override string ProtocolMethodName { get { return "tx.select"; } }
5487 public override bool HasContent { get { return false; } }
5489 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5492 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5495 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5500 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5501 public class TxSelectOk: RabbitMQ.Client.Impl.MethodBase, ITxSelectOk {
5502 public const int ClassId = 90;
5503 public const int MethodId = 11;
5512 public override int ProtocolClassId { get { return 90; } }
5513 public override int ProtocolMethodId { get { return 11; } }
5514 public override string ProtocolMethodName { get { return "tx.select-ok"; } }
5515 public override bool HasContent { get { return false; } }
5517 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5520 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5523 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5528 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5529 public class TxCommit: RabbitMQ.Client.Impl.MethodBase, ITxCommit {
5530 public const int ClassId = 90;
5531 public const int MethodId = 20;
5540 public override int ProtocolClassId { get { return 90; } }
5541 public override int ProtocolMethodId { get { return 20; } }
5542 public override string ProtocolMethodName { get { return "tx.commit"; } }
5543 public override bool HasContent { get { return false; } }
5545 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5548 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5551 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5556 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5557 public class TxCommitOk: RabbitMQ.Client.Impl.MethodBase, ITxCommitOk {
5558 public const int ClassId = 90;
5559 public const int MethodId = 21;
5568 public override int ProtocolClassId { get { return 90; } }
5569 public override int ProtocolMethodId { get { return 21; } }
5570 public override string ProtocolMethodName { get { return "tx.commit-ok"; } }
5571 public override bool HasContent { get { return false; } }
5573 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5576 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5579 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5584 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5585 public class TxRollback: RabbitMQ.Client.Impl.MethodBase, ITxRollback {
5586 public const int ClassId = 90;
5587 public const int MethodId = 30;
5596 public override int ProtocolClassId { get { return 90; } }
5597 public override int ProtocolMethodId { get { return 30; } }
5598 public override string ProtocolMethodName { get { return "tx.rollback"; } }
5599 public override bool HasContent { get { return false; } }
5601 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5604 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5607 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5612 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5613 public class TxRollbackOk: RabbitMQ.Client.Impl.MethodBase, ITxRollbackOk {
5614 public const int ClassId = 90;
5615 public const int MethodId = 31;
5619 public TxRollbackOk(
5624 public override int ProtocolClassId { get { return 90; } }
5625 public override int ProtocolMethodId { get { return 31; } }
5626 public override string ProtocolMethodName { get { return "tx.rollback-ok"; } }
5627 public override bool HasContent { get { return false; } }
5629 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5632 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5635 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5640 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5641 public class DtxSelect: RabbitMQ.Client.Impl.MethodBase, IDtxSelect {
5642 public const int ClassId = 100;
5643 public const int MethodId = 10;
5652 public override int ProtocolClassId { get { return 100; } }
5653 public override int ProtocolMethodId { get { return 10; } }
5654 public override string ProtocolMethodName { get { return "dtx.select"; } }
5655 public override bool HasContent { get { return false; } }
5657 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5660 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5663 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5668 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5669 public class DtxSelectOk: RabbitMQ.Client.Impl.MethodBase, IDtxSelectOk {
5670 public const int ClassId = 100;
5671 public const int MethodId = 11;
5680 public override int ProtocolClassId { get { return 100; } }
5681 public override int ProtocolMethodId { get { return 11; } }
5682 public override string ProtocolMethodName { get { return "dtx.select-ok"; } }
5683 public override bool HasContent { get { return false; } }
5685 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5688 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5691 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5696 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5697 public class DtxStart: RabbitMQ.Client.Impl.MethodBase, IDtxStart {
5698 public const int ClassId = 100;
5699 public const int MethodId = 20;
5701 public string m_dtxIdentifier;
5703 string IDtxStart.DtxIdentifier { get { return m_dtxIdentifier; } }
5705 public DtxStart() {}
5707 string initDtxIdentifier)
5709 m_dtxIdentifier = initDtxIdentifier;
5712 public override int ProtocolClassId { get { return 100; } }
5713 public override int ProtocolMethodId { get { return 20; } }
5714 public override string ProtocolMethodName { get { return "dtx.start"; } }
5715 public override bool HasContent { get { return false; } }
5717 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5718 m_dtxIdentifier = reader.ReadShortstr();
5721 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5722 writer.WriteShortstr(m_dtxIdentifier);
5725 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5727 sb.Append(m_dtxIdentifier);
5731 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5732 public class DtxStartOk: RabbitMQ.Client.Impl.MethodBase, IDtxStartOk {
5733 public const int ClassId = 100;
5734 public const int MethodId = 21;
5743 public override int ProtocolClassId { get { return 100; } }
5744 public override int ProtocolMethodId { get { return 21; } }
5745 public override string ProtocolMethodName { get { return "dtx.start-ok"; } }
5746 public override bool HasContent { get { return false; } }
5748 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5751 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5754 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5759 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5760 public class TunnelRequest: RabbitMQ.Client.Impl.MethodBase, ITunnelRequest {
5761 public const int ClassId = 110;
5762 public const int MethodId = 10;
5764 public System.Collections.IDictionary m_metaData;
5766 System.Collections.IDictionary ITunnelRequest.MetaData { get { return m_metaData; } }
5768 public TunnelRequest() {}
5769 public TunnelRequest(
5770 System.Collections.IDictionary initMetaData)
5772 m_metaData = initMetaData;
5775 public override int ProtocolClassId { get { return 110; } }
5776 public override int ProtocolMethodId { get { return 10; } }
5777 public override string ProtocolMethodName { get { return "tunnel.request"; } }
5778 public override bool HasContent { get { return true; } }
5780 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5781 m_metaData = reader.ReadTable();
5784 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5785 writer.WriteTable(m_metaData);
5788 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5790 sb.Append(m_metaData);
5794 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5795 public class MessageTransfer: RabbitMQ.Client.Impl.MethodBase, IMessageTransfer {
5796 public const int ClassId = 120;
5797 public const int MethodId = 10;
5799 public ushort m_ticket;
5800 public string m_destination;
5801 public bool m_redelivered;
5802 public bool m_immediate;
5804 public byte m_priority;
5805 public AmqpTimestamp m_timestamp;
5806 public byte m_deliveryMode;
5807 public AmqpTimestamp m_expiration;
5808 public string m_exchange;
5809 public string m_routingKey;
5810 public string m_messageId;
5811 public string m_correlationId;
5812 public string m_replyTo;
5813 public string m_contentType;
5814 public string m_contentEncoding;
5815 public string m_userId;
5816 public string m_appId;
5817 public string m_transactionId;
5818 public byte[] m_securityToken;
5819 public System.Collections.IDictionary m_applicationHeaders;
5820 public byte[] m_body;
5822 ushort IMessageTransfer.Ticket { get { return m_ticket; } }
5823 string IMessageTransfer.Destination { get { return m_destination; } }
5824 bool IMessageTransfer.Redelivered { get { return m_redelivered; } }
5825 bool IMessageTransfer.Immediate { get { return m_immediate; } }
5826 ulong IMessageTransfer.Ttl { get { return m_ttl; } }
5827 byte IMessageTransfer.Priority { get { return m_priority; } }
5828 AmqpTimestamp IMessageTransfer.Timestamp { get { return m_timestamp; } }
5829 byte IMessageTransfer.DeliveryMode { get { return m_deliveryMode; } }
5830 AmqpTimestamp IMessageTransfer.Expiration { get { return m_expiration; } }
5831 string IMessageTransfer.Exchange { get { return m_exchange; } }
5832 string IMessageTransfer.RoutingKey { get { return m_routingKey; } }
5833 string IMessageTransfer.MessageId { get { return m_messageId; } }
5834 string IMessageTransfer.CorrelationId { get { return m_correlationId; } }
5835 string IMessageTransfer.ReplyTo { get { return m_replyTo; } }
5836 string IMessageTransfer.ContentType { get { return m_contentType; } }
5837 string IMessageTransfer.ContentEncoding { get { return m_contentEncoding; } }
5838 string IMessageTransfer.UserId { get { return m_userId; } }
5839 string IMessageTransfer.AppId { get { return m_appId; } }
5840 string IMessageTransfer.TransactionId { get { return m_transactionId; } }
5841 byte[] IMessageTransfer.SecurityToken { get { return m_securityToken; } }
5842 System.Collections.IDictionary IMessageTransfer.ApplicationHeaders { get { return m_applicationHeaders; } }
5843 byte[] IMessageTransfer.Body { get { return m_body; } }
5845 public MessageTransfer() {}
5846 public MessageTransfer(
5848 string initDestination,
5849 bool initRedelivered,
5853 AmqpTimestamp initTimestamp,
5854 byte initDeliveryMode,
5855 AmqpTimestamp initExpiration,
5856 string initExchange,
5857 string initRoutingKey,
5858 string initMessageId,
5859 string initCorrelationId,
5861 string initContentType,
5862 string initContentEncoding,
5865 string initTransactionId,
5866 byte[] initSecurityToken,
5867 System.Collections.IDictionary initApplicationHeaders,
5870 m_ticket = initTicket;
5871 m_destination = initDestination;
5872 m_redelivered = initRedelivered;
5873 m_immediate = initImmediate;
5875 m_priority = initPriority;
5876 m_timestamp = initTimestamp;
5877 m_deliveryMode = initDeliveryMode;
5878 m_expiration = initExpiration;
5879 m_exchange = initExchange;
5880 m_routingKey = initRoutingKey;
5881 m_messageId = initMessageId;
5882 m_correlationId = initCorrelationId;
5883 m_replyTo = initReplyTo;
5884 m_contentType = initContentType;
5885 m_contentEncoding = initContentEncoding;
5886 m_userId = initUserId;
5887 m_appId = initAppId;
5888 m_transactionId = initTransactionId;
5889 m_securityToken = initSecurityToken;
5890 m_applicationHeaders = initApplicationHeaders;
5894 public override int ProtocolClassId { get { return 120; } }
5895 public override int ProtocolMethodId { get { return 10; } }
5896 public override string ProtocolMethodName { get { return "message.transfer"; } }
5897 public override bool HasContent { get { return false; } }
5899 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5900 m_ticket = reader.ReadShort();
5901 m_destination = reader.ReadShortstr();
5902 m_redelivered = reader.ReadBit();
5903 m_immediate = reader.ReadBit();
5904 m_ttl = reader.ReadLonglong();
5905 m_priority = reader.ReadOctet();
5906 m_timestamp = reader.ReadTimestamp();
5907 m_deliveryMode = reader.ReadOctet();
5908 m_expiration = reader.ReadTimestamp();
5909 m_exchange = reader.ReadShortstr();
5910 m_routingKey = reader.ReadShortstr();
5911 m_messageId = reader.ReadShortstr();
5912 m_correlationId = reader.ReadShortstr();
5913 m_replyTo = reader.ReadShortstr();
5914 m_contentType = reader.ReadShortstr();
5915 m_contentEncoding = reader.ReadShortstr();
5916 m_userId = reader.ReadShortstr();
5917 m_appId = reader.ReadShortstr();
5918 m_transactionId = reader.ReadShortstr();
5919 m_securityToken = reader.ReadLongstr();
5920 m_applicationHeaders = reader.ReadTable();
5921 m_body = reader.ReadContent();
5924 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5925 writer.WriteShort(m_ticket);
5926 writer.WriteShortstr(m_destination);
5927 writer.WriteBit(m_redelivered);
5928 writer.WriteBit(m_immediate);
5929 writer.WriteLonglong(m_ttl);
5930 writer.WriteOctet(m_priority);
5931 writer.WriteTimestamp(m_timestamp);
5932 writer.WriteOctet(m_deliveryMode);
5933 writer.WriteTimestamp(m_expiration);
5934 writer.WriteShortstr(m_exchange);
5935 writer.WriteShortstr(m_routingKey);
5936 writer.WriteShortstr(m_messageId);
5937 writer.WriteShortstr(m_correlationId);
5938 writer.WriteShortstr(m_replyTo);
5939 writer.WriteShortstr(m_contentType);
5940 writer.WriteShortstr(m_contentEncoding);
5941 writer.WriteShortstr(m_userId);
5942 writer.WriteShortstr(m_appId);
5943 writer.WriteShortstr(m_transactionId);
5944 writer.WriteLongstr(m_securityToken);
5945 writer.WriteTable(m_applicationHeaders);
5946 writer.WriteContent(m_body);
5949 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5951 sb.Append(m_ticket); sb.Append(",");
5952 sb.Append(m_destination); sb.Append(",");
5953 sb.Append(m_redelivered); sb.Append(",");
5954 sb.Append(m_immediate); sb.Append(",");
5955 sb.Append(m_ttl); sb.Append(",");
5956 sb.Append(m_priority); sb.Append(",");
5957 sb.Append(m_timestamp); sb.Append(",");
5958 sb.Append(m_deliveryMode); sb.Append(",");
5959 sb.Append(m_expiration); sb.Append(",");
5960 sb.Append(m_exchange); sb.Append(",");
5961 sb.Append(m_routingKey); sb.Append(",");
5962 sb.Append(m_messageId); sb.Append(",");
5963 sb.Append(m_correlationId); sb.Append(",");
5964 sb.Append(m_replyTo); sb.Append(",");
5965 sb.Append(m_contentType); sb.Append(",");
5966 sb.Append(m_contentEncoding); sb.Append(",");
5967 sb.Append(m_userId); sb.Append(",");
5968 sb.Append(m_appId); sb.Append(",");
5969 sb.Append(m_transactionId); sb.Append(",");
5970 sb.Append(m_securityToken); sb.Append(",");
5971 sb.Append(m_applicationHeaders); sb.Append(",");
5976 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5977 public class MessageConsume: RabbitMQ.Client.Impl.MethodBase, IMessageConsume {
5978 public const int ClassId = 120;
5979 public const int MethodId = 20;
5981 public ushort m_ticket;
5982 public string m_queue;
5983 public string m_destination;
5984 public bool m_noLocal;
5985 public bool m_noAck;
5986 public bool m_exclusive;
5987 public System.Collections.IDictionary m_filter;
5989 ushort IMessageConsume.Ticket { get { return m_ticket; } }
5990 string IMessageConsume.Queue { get { return m_queue; } }
5991 string IMessageConsume.Destination { get { return m_destination; } }
5992 bool IMessageConsume.NoLocal { get { return m_noLocal; } }
5993 bool IMessageConsume.NoAck { get { return m_noAck; } }
5994 bool IMessageConsume.Exclusive { get { return m_exclusive; } }
5995 System.Collections.IDictionary IMessageConsume.Filter { get { return m_filter; } }
5997 public MessageConsume() {}
5998 public MessageConsume(
6001 string initDestination,
6005 System.Collections.IDictionary initFilter)
6007 m_ticket = initTicket;
6008 m_queue = initQueue;
6009 m_destination = initDestination;
6010 m_noLocal = initNoLocal;
6011 m_noAck = initNoAck;
6012 m_exclusive = initExclusive;
6013 m_filter = initFilter;
6016 public override int ProtocolClassId { get { return 120; } }
6017 public override int ProtocolMethodId { get { return 20; } }
6018 public override string ProtocolMethodName { get { return "message.consume"; } }
6019 public override bool HasContent { get { return false; } }
6021 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6022 m_ticket = reader.ReadShort();
6023 m_queue = reader.ReadShortstr();
6024 m_destination = reader.ReadShortstr();
6025 m_noLocal = reader.ReadBit();
6026 m_noAck = reader.ReadBit();
6027 m_exclusive = reader.ReadBit();
6028 m_filter = reader.ReadTable();
6031 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6032 writer.WriteShort(m_ticket);
6033 writer.WriteShortstr(m_queue);
6034 writer.WriteShortstr(m_destination);
6035 writer.WriteBit(m_noLocal);
6036 writer.WriteBit(m_noAck);
6037 writer.WriteBit(m_exclusive);
6038 writer.WriteTable(m_filter);
6041 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6043 sb.Append(m_ticket); sb.Append(",");
6044 sb.Append(m_queue); sb.Append(",");
6045 sb.Append(m_destination); sb.Append(",");
6046 sb.Append(m_noLocal); sb.Append(",");
6047 sb.Append(m_noAck); sb.Append(",");
6048 sb.Append(m_exclusive); sb.Append(",");
6049 sb.Append(m_filter);
6053 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6054 public class MessageCancel: RabbitMQ.Client.Impl.MethodBase, IMessageCancel {
6055 public const int ClassId = 120;
6056 public const int MethodId = 30;
6058 public string m_destination;
6060 string IMessageCancel.Destination { get { return m_destination; } }
6062 public MessageCancel() {}
6063 public MessageCancel(
6064 string initDestination)
6066 m_destination = initDestination;
6069 public override int ProtocolClassId { get { return 120; } }
6070 public override int ProtocolMethodId { get { return 30; } }
6071 public override string ProtocolMethodName { get { return "message.cancel"; } }
6072 public override bool HasContent { get { return false; } }
6074 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6075 m_destination = reader.ReadShortstr();
6078 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6079 writer.WriteShortstr(m_destination);
6082 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6084 sb.Append(m_destination);
6088 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6089 public class MessageGet: RabbitMQ.Client.Impl.MethodBase, IMessageGet {
6090 public const int ClassId = 120;
6091 public const int MethodId = 40;
6093 public ushort m_ticket;
6094 public string m_queue;
6095 public string m_destination;
6096 public bool m_noAck;
6098 ushort IMessageGet.Ticket { get { return m_ticket; } }
6099 string IMessageGet.Queue { get { return m_queue; } }
6100 string IMessageGet.Destination { get { return m_destination; } }
6101 bool IMessageGet.NoAck { get { return m_noAck; } }
6103 public MessageGet() {}
6107 string initDestination,
6110 m_ticket = initTicket;
6111 m_queue = initQueue;
6112 m_destination = initDestination;
6113 m_noAck = initNoAck;
6116 public override int ProtocolClassId { get { return 120; } }
6117 public override int ProtocolMethodId { get { return 40; } }
6118 public override string ProtocolMethodName { get { return "message.get"; } }
6119 public override bool HasContent { get { return false; } }
6121 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6122 m_ticket = reader.ReadShort();
6123 m_queue = reader.ReadShortstr();
6124 m_destination = reader.ReadShortstr();
6125 m_noAck = reader.ReadBit();
6128 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6129 writer.WriteShort(m_ticket);
6130 writer.WriteShortstr(m_queue);
6131 writer.WriteShortstr(m_destination);
6132 writer.WriteBit(m_noAck);
6135 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6137 sb.Append(m_ticket); sb.Append(",");
6138 sb.Append(m_queue); sb.Append(",");
6139 sb.Append(m_destination); sb.Append(",");
6144 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6145 public class MessageRecover: RabbitMQ.Client.Impl.MethodBase, IMessageRecover {
6146 public const int ClassId = 120;
6147 public const int MethodId = 50;
6149 public bool m_requeue;
6151 bool IMessageRecover.Requeue { get { return m_requeue; } }
6153 public MessageRecover() {}
6154 public MessageRecover(
6157 m_requeue = initRequeue;
6160 public override int ProtocolClassId { get { return 120; } }
6161 public override int ProtocolMethodId { get { return 50; } }
6162 public override string ProtocolMethodName { get { return "message.recover"; } }
6163 public override bool HasContent { get { return false; } }
6165 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6166 m_requeue = reader.ReadBit();
6169 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6170 writer.WriteBit(m_requeue);
6173 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6175 sb.Append(m_requeue);
6179 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6180 public class MessageOpen: RabbitMQ.Client.Impl.MethodBase, IMessageOpen {
6181 public const int ClassId = 120;
6182 public const int MethodId = 60;
6184 public byte[] m_reference;
6186 byte[] IMessageOpen.Reference { get { return m_reference; } }
6188 public MessageOpen() {}
6190 byte[] initReference)
6192 m_reference = initReference;
6195 public override int ProtocolClassId { get { return 120; } }
6196 public override int ProtocolMethodId { get { return 60; } }
6197 public override string ProtocolMethodName { get { return "message.open"; } }
6198 public override bool HasContent { get { return false; } }
6200 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6201 m_reference = reader.ReadLongstr();
6204 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6205 writer.WriteLongstr(m_reference);
6208 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6210 sb.Append(m_reference);
6214 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6215 public class MessageClose: RabbitMQ.Client.Impl.MethodBase, IMessageClose {
6216 public const int ClassId = 120;
6217 public const int MethodId = 70;
6219 public byte[] m_reference;
6221 byte[] IMessageClose.Reference { get { return m_reference; } }
6223 public MessageClose() {}
6224 public MessageClose(
6225 byte[] initReference)
6227 m_reference = initReference;
6230 public override int ProtocolClassId { get { return 120; } }
6231 public override int ProtocolMethodId { get { return 70; } }
6232 public override string ProtocolMethodName { get { return "message.close"; } }
6233 public override bool HasContent { get { return false; } }
6235 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6236 m_reference = reader.ReadLongstr();
6239 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6240 writer.WriteLongstr(m_reference);
6243 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6245 sb.Append(m_reference);
6249 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6250 public class MessageAppend: RabbitMQ.Client.Impl.MethodBase, IMessageAppend {
6251 public const int ClassId = 120;
6252 public const int MethodId = 80;
6254 public byte[] m_reference;
6255 public byte[] m_bytes;
6257 byte[] IMessageAppend.Reference { get { return m_reference; } }
6258 byte[] IMessageAppend.Bytes { get { return m_bytes; } }
6260 public MessageAppend() {}
6261 public MessageAppend(
6262 byte[] initReference,
6265 m_reference = initReference;
6266 m_bytes = initBytes;
6269 public override int ProtocolClassId { get { return 120; } }
6270 public override int ProtocolMethodId { get { return 80; } }
6271 public override string ProtocolMethodName { get { return "message.append"; } }
6272 public override bool HasContent { get { return false; } }
6274 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6275 m_reference = reader.ReadLongstr();
6276 m_bytes = reader.ReadLongstr();
6279 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6280 writer.WriteLongstr(m_reference);
6281 writer.WriteLongstr(m_bytes);
6284 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6286 sb.Append(m_reference); sb.Append(",");
6291 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6292 public class MessageCheckpoint: RabbitMQ.Client.Impl.MethodBase, IMessageCheckpoint {
6293 public const int ClassId = 120;
6294 public const int MethodId = 90;
6296 public byte[] m_reference;
6297 public string m_identifier;
6299 byte[] IMessageCheckpoint.Reference { get { return m_reference; } }
6300 string IMessageCheckpoint.Identifier { get { return m_identifier; } }
6302 public MessageCheckpoint() {}
6303 public MessageCheckpoint(
6304 byte[] initReference,
6305 string initIdentifier)
6307 m_reference = initReference;
6308 m_identifier = initIdentifier;
6311 public override int ProtocolClassId { get { return 120; } }
6312 public override int ProtocolMethodId { get { return 90; } }
6313 public override string ProtocolMethodName { get { return "message.checkpoint"; } }
6314 public override bool HasContent { get { return false; } }
6316 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6317 m_reference = reader.ReadLongstr();
6318 m_identifier = reader.ReadShortstr();
6321 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6322 writer.WriteLongstr(m_reference);
6323 writer.WriteShortstr(m_identifier);
6326 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6328 sb.Append(m_reference); sb.Append(",");
6329 sb.Append(m_identifier);
6333 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6334 public class MessageResume: RabbitMQ.Client.Impl.MethodBase, IMessageResume {
6335 public const int ClassId = 120;
6336 public const int MethodId = 100;
6338 public byte[] m_reference;
6339 public string m_identifier;
6341 byte[] IMessageResume.Reference { get { return m_reference; } }
6342 string IMessageResume.Identifier { get { return m_identifier; } }
6344 public MessageResume() {}
6345 public MessageResume(
6346 byte[] initReference,
6347 string initIdentifier)
6349 m_reference = initReference;
6350 m_identifier = initIdentifier;
6353 public override int ProtocolClassId { get { return 120; } }
6354 public override int ProtocolMethodId { get { return 100; } }
6355 public override string ProtocolMethodName { get { return "message.resume"; } }
6356 public override bool HasContent { get { return false; } }
6358 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6359 m_reference = reader.ReadLongstr();
6360 m_identifier = reader.ReadShortstr();
6363 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6364 writer.WriteLongstr(m_reference);
6365 writer.WriteShortstr(m_identifier);
6368 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6370 sb.Append(m_reference); sb.Append(",");
6371 sb.Append(m_identifier);
6375 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6376 public class MessageQos: RabbitMQ.Client.Impl.MethodBase, IMessageQos {
6377 public const int ClassId = 120;
6378 public const int MethodId = 110;
6380 public uint m_prefetchSize;
6381 public ushort m_prefetchCount;
6382 public bool m_global;
6384 uint IMessageQos.PrefetchSize { get { return m_prefetchSize; } }
6385 ushort IMessageQos.PrefetchCount { get { return m_prefetchCount; } }
6386 bool IMessageQos.Global { get { return m_global; } }
6388 public MessageQos() {}
6390 uint initPrefetchSize,
6391 ushort initPrefetchCount,
6394 m_prefetchSize = initPrefetchSize;
6395 m_prefetchCount = initPrefetchCount;
6396 m_global = initGlobal;
6399 public override int ProtocolClassId { get { return 120; } }
6400 public override int ProtocolMethodId { get { return 110; } }
6401 public override string ProtocolMethodName { get { return "message.qos"; } }
6402 public override bool HasContent { get { return false; } }
6404 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6405 m_prefetchSize = reader.ReadLong();
6406 m_prefetchCount = reader.ReadShort();
6407 m_global = reader.ReadBit();
6410 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6411 writer.WriteLong(m_prefetchSize);
6412 writer.WriteShort(m_prefetchCount);
6413 writer.WriteBit(m_global);
6416 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6418 sb.Append(m_prefetchSize); sb.Append(",");
6419 sb.Append(m_prefetchCount); sb.Append(",");
6420 sb.Append(m_global);
6424 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6425 public class MessageOk: RabbitMQ.Client.Impl.MethodBase, IMessageOk {
6426 public const int ClassId = 120;
6427 public const int MethodId = 500;
6436 public override int ProtocolClassId { get { return 120; } }
6437 public override int ProtocolMethodId { get { return 500; } }
6438 public override string ProtocolMethodName { get { return "message.ok"; } }
6439 public override bool HasContent { get { return false; } }
6441 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6444 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6447 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6452 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6453 public class MessageEmpty: RabbitMQ.Client.Impl.MethodBase, IMessageEmpty {
6454 public const int ClassId = 120;
6455 public const int MethodId = 510;
6459 public MessageEmpty(
6464 public override int ProtocolClassId { get { return 120; } }
6465 public override int ProtocolMethodId { get { return 510; } }
6466 public override string ProtocolMethodName { get { return "message.empty"; } }
6467 public override bool HasContent { get { return false; } }
6469 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6472 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6475 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6480 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6481 public class MessageReject: RabbitMQ.Client.Impl.MethodBase, IMessageReject {
6482 public const int ClassId = 120;
6483 public const int MethodId = 520;
6485 public ushort m_code;
6486 public string m_text;
6488 ushort IMessageReject.Code { get { return m_code; } }
6489 string IMessageReject.Text { get { return m_text; } }
6491 public MessageReject() {}
6492 public MessageReject(
6500 public override int ProtocolClassId { get { return 120; } }
6501 public override int ProtocolMethodId { get { return 520; } }
6502 public override string ProtocolMethodName { get { return "message.reject"; } }
6503 public override bool HasContent { get { return false; } }
6505 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6506 m_code = reader.ReadShort();
6507 m_text = reader.ReadShortstr();
6510 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6511 writer.WriteShort(m_code);
6512 writer.WriteShortstr(m_text);
6515 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6517 sb.Append(m_code); sb.Append(",");
6522 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6523 public class MessageOffset: RabbitMQ.Client.Impl.MethodBase, IMessageOffset {
6524 public const int ClassId = 120;
6525 public const int MethodId = 530;
6527 public ulong m_value;
6529 ulong IMessageOffset.Value { get { return m_value; } }
6531 public MessageOffset() {}
6532 public MessageOffset(
6535 m_value = initValue;
6538 public override int ProtocolClassId { get { return 120; } }
6539 public override int ProtocolMethodId { get { return 530; } }
6540 public override string ProtocolMethodName { get { return "message.offset"; } }
6541 public override bool HasContent { get { return false; } }
6543 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6544 m_value = reader.ReadLonglong();
6547 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6548 writer.WriteLonglong(m_value);
6551 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6558 public class Model: RabbitMQ.Client.Impl.ModelBase {
6559 public Model(RabbitMQ.Client.Impl.ISession session): base(session) {}
6560 public override void _Private_BasicPublish(
6561 System.String @exchange,
6562 System.String @routingKey,
6563 System.Boolean @mandatory,
6564 System.Boolean @immediate,
6565 RabbitMQ.Client.IBasicProperties @basicProperties,
6566 System.Byte[] @body)
6568 BasicPublish __req = new BasicPublish();
6569 __req.m_exchange = @exchange;
6570 __req.m_routingKey = @routingKey;
6571 __req.m_mandatory = @mandatory;
6572 __req.m_immediate = @immediate;
6573 ModelSend(__req, (BasicProperties) basicProperties,body);
6575 public override void _Private_BasicConsume(
6576 System.String @queue,
6577 System.String @consumerTag,
6578 System.Boolean @noLocal,
6579 System.Boolean @noAck,
6580 System.Boolean @exclusive,
6581 System.Boolean @nowait,
6582 System.Collections.IDictionary @filter)
6584 BasicConsume __req = new BasicConsume();
6585 __req.m_queue = @queue;
6586 __req.m_consumerTag = @consumerTag;
6587 __req.m_noLocal = @noLocal;
6588 __req.m_noAck = @noAck;
6589 __req.m_exclusive = @exclusive;
6590 __req.m_nowait = @nowait;
6591 __req.m_filter = @filter;
6592 ModelSend(__req,null,null);
6594 public override void _Private_BasicCancel(
6595 System.String @consumerTag,
6596 System.Boolean @nowait)
6598 BasicCancel __req = new BasicCancel();
6599 __req.m_consumerTag = @consumerTag;
6600 __req.m_nowait = @nowait;
6601 ModelSend(__req,null,null);
6603 public override void _Private_ChannelOpen(
6604 System.String @outOfBand)
6606 ChannelOpen __req = new ChannelOpen();
6607 __req.m_outOfBand = @outOfBand;
6608 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6609 ChannelOpenOk __rep = __repBase as ChannelOpenOk;
6610 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6612 public override void _Private_ChannelCloseOk()
6614 ChannelCloseOk __req = new ChannelCloseOk();
6615 ModelSend(__req,null,null);
6617 public override void _Private_ChannelClose(
6618 System.UInt16 @replyCode,
6619 System.String @replyText,
6620 System.UInt16 @classId,
6621 System.UInt16 @methodId)
6623 ChannelClose __req = new ChannelClose();
6624 __req.m_replyCode = @replyCode;
6625 __req.m_replyText = @replyText;
6626 __req.m_classId = @classId;
6627 __req.m_methodId = @methodId;
6628 ModelSend(__req,null,null);
6630 public override void _Private_BasicGet(
6631 System.String @queue,
6632 System.Boolean @noAck)
6634 BasicGet __req = new BasicGet();
6635 __req.m_queue = @queue;
6636 __req.m_noAck = @noAck;
6637 ModelSend(__req,null,null);
6639 public override void _Private_ChannelFlowOk()
6641 ChannelFlowOk __req = new ChannelFlowOk();
6642 ModelSend(__req,null,null);
6644 public override RabbitMQ.Client.Impl.ConnectionTuneDetails ConnectionStartOk(
6645 System.Collections.IDictionary @clientProperties,
6646 System.String @mechanism,
6647 System.Byte[] @response,
6648 System.String @locale)
6650 ConnectionStartOk __req = new ConnectionStartOk();
6651 __req.m_clientProperties = @clientProperties;
6652 __req.m_mechanism = @mechanism;
6653 __req.m_response = @response;
6654 __req.m_locale = @locale;
6655 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6656 ConnectionTune __rep = __repBase as ConnectionTune;
6657 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6658 RabbitMQ.Client.Impl.ConnectionTuneDetails __result = new RabbitMQ.Client.Impl.ConnectionTuneDetails();
6659 __result.m_channelMax = __rep.m_channelMax;
6660 __result.m_frameMax = __rep.m_frameMax;
6661 __result.m_heartbeat = __rep.m_heartbeat;
6664 public override void ConnectionTuneOk(
6665 System.UInt16 @channelMax,
6666 System.UInt32 @frameMax,
6667 System.UInt16 @heartbeat)
6669 ConnectionTuneOk __req = new ConnectionTuneOk();
6670 __req.m_channelMax = @channelMax;
6671 __req.m_frameMax = @frameMax;
6672 __req.m_heartbeat = @heartbeat;
6673 ModelSend(__req,null,null);
6675 public override void _Private_ConnectionOpen(
6676 System.String @virtualHost,
6677 System.String @capabilities,
6678 System.Boolean @insist)
6680 ConnectionOpen __req = new ConnectionOpen();
6681 __req.m_virtualHost = @virtualHost;
6682 __req.m_capabilities = @capabilities;
6683 __req.m_insist = @insist;
6684 ModelSend(__req,null,null);
6686 public override void _Private_ConnectionClose(
6687 System.UInt16 @replyCode,
6688 System.String @replyText,
6689 System.UInt16 @classId,
6690 System.UInt16 @methodId)
6692 ConnectionClose __req = new ConnectionClose();
6693 __req.m_replyCode = @replyCode;
6694 __req.m_replyText = @replyText;
6695 __req.m_classId = @classId;
6696 __req.m_methodId = @methodId;
6697 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6698 ConnectionCloseOk __rep = __repBase as ConnectionCloseOk;
6699 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6701 public override void _Private_ConnectionCloseOk()
6703 ConnectionCloseOk __req = new ConnectionCloseOk();
6704 ModelSend(__req,null,null);
6706 public override RabbitMQ.Client.IBasicProperties CreateBasicProperties()
6708 return new BasicProperties();
6710 public override RabbitMQ.Client.IFileProperties CreateFileProperties()
6712 return new FileProperties();
6714 public override RabbitMQ.Client.IStreamProperties CreateStreamProperties()
6716 return new StreamProperties();
6718 public override void ChannelFlow(
6719 System.Boolean @active)
6721 ChannelFlow __req = new ChannelFlow();
6722 __req.m_active = @active;
6723 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6724 ChannelFlowOk __rep = __repBase as ChannelFlowOk;
6725 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6727 public override void ExchangeDeclare(
6728 System.String @exchange,
6729 System.String @type,
6730 System.Boolean @passive,
6731 System.Boolean @durable,
6732 System.Boolean @autoDelete,
6733 System.Boolean @internal,
6734 System.Boolean @nowait,
6735 System.Collections.IDictionary @arguments)
6737 ExchangeDeclare __req = new ExchangeDeclare();
6738 __req.m_exchange = @exchange;
6739 __req.m_type = @type;
6740 __req.m_passive = @passive;
6741 __req.m_durable = @durable;
6742 __req.m_autoDelete = @autoDelete;
6743 __req.m_internal = @internal;
6744 __req.m_nowait = @nowait;
6745 __req.m_arguments = @arguments;
6747 ModelSend(__req,null,null);
6749 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6750 ExchangeDeclareOk __rep = __repBase as ExchangeDeclareOk;
6751 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6753 public override void ExchangeDelete(
6754 System.String @exchange,
6755 System.Boolean @ifUnused,
6756 System.Boolean @nowait)
6758 ExchangeDelete __req = new ExchangeDelete();
6759 __req.m_exchange = @exchange;
6760 __req.m_ifUnused = @ifUnused;
6761 __req.m_nowait = @nowait;
6763 ModelSend(__req,null,null);
6765 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6766 ExchangeDeleteOk __rep = __repBase as ExchangeDeleteOk;
6767 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6769 public override System.String QueueDeclare(
6770 System.String @queue,
6771 System.Boolean @passive,
6772 System.Boolean @durable,
6773 System.Boolean @exclusive,
6774 System.Boolean @autoDelete,
6775 System.Boolean @nowait,
6776 System.Collections.IDictionary @arguments)
6778 QueueDeclare __req = new QueueDeclare();
6779 __req.m_queue = @queue;
6780 __req.m_passive = @passive;
6781 __req.m_durable = @durable;
6782 __req.m_exclusive = @exclusive;
6783 __req.m_autoDelete = @autoDelete;
6784 __req.m_nowait = @nowait;
6785 __req.m_arguments = @arguments;
6787 ModelSend(__req,null,null);
6790 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6791 QueueDeclareOk __rep = __repBase as QueueDeclareOk;
6792 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6793 return __rep.m_queue;
6795 public override void QueueBind(
6796 System.String @queue,
6797 System.String @exchange,
6798 System.String @routingKey,
6799 System.Boolean @nowait,
6800 System.Collections.IDictionary @arguments)
6802 QueueBind __req = new QueueBind();
6803 __req.m_queue = @queue;
6804 __req.m_exchange = @exchange;
6805 __req.m_routingKey = @routingKey;
6806 __req.m_nowait = @nowait;
6807 __req.m_arguments = @arguments;
6809 ModelSend(__req,null,null);
6811 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6812 QueueBindOk __rep = __repBase as QueueBindOk;
6813 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6815 public override void QueueUnbind(
6816 System.String @queue,
6817 System.String @exchange,
6818 System.String @routingKey,
6819 System.Collections.IDictionary @arguments)
6821 QueueUnbind __req = new QueueUnbind();
6822 __req.m_queue = @queue;
6823 __req.m_exchange = @exchange;
6824 __req.m_routingKey = @routingKey;
6825 __req.m_arguments = @arguments;
6826 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6827 QueueUnbindOk __rep = __repBase as QueueUnbindOk;
6828 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6830 public override System.UInt32 QueuePurge(
6831 System.String @queue,
6832 System.Boolean @nowait)
6834 QueuePurge __req = new QueuePurge();
6835 __req.m_queue = @queue;
6836 __req.m_nowait = @nowait;
6838 ModelSend(__req,null,null);
6841 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6842 QueuePurgeOk __rep = __repBase as QueuePurgeOk;
6843 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6844 return __rep.m_messageCount;
6846 public override System.UInt32 QueueDelete(
6847 System.String @queue,
6848 System.Boolean @ifUnused,
6849 System.Boolean @ifEmpty,
6850 System.Boolean @nowait)
6852 QueueDelete __req = new QueueDelete();
6853 __req.m_queue = @queue;
6854 __req.m_ifUnused = @ifUnused;
6855 __req.m_ifEmpty = @ifEmpty;
6856 __req.m_nowait = @nowait;
6858 ModelSend(__req,null,null);
6861 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6862 QueueDeleteOk __rep = __repBase as QueueDeleteOk;
6863 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6864 return __rep.m_messageCount;
6866 public override void BasicQos(
6867 System.UInt32 @prefetchSize,
6868 System.UInt16 @prefetchCount,
6869 System.Boolean @global)
6871 BasicQos __req = new BasicQos();
6872 __req.m_prefetchSize = @prefetchSize;
6873 __req.m_prefetchCount = @prefetchCount;
6874 __req.m_global = @global;
6875 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6876 BasicQosOk __rep = __repBase as BasicQosOk;
6877 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6879 public override void BasicAck(
6880 System.UInt64 @deliveryTag,
6881 System.Boolean @multiple)
6883 BasicAck __req = new BasicAck();
6884 __req.m_deliveryTag = @deliveryTag;
6885 __req.m_multiple = @multiple;
6886 ModelSend(__req,null,null);
6888 public override void BasicReject(
6889 System.UInt64 @deliveryTag,
6890 System.Boolean @requeue)
6892 BasicReject __req = new BasicReject();
6893 __req.m_deliveryTag = @deliveryTag;
6894 __req.m_requeue = @requeue;
6895 ModelSend(__req,null,null);
6897 public override void BasicRecover(
6898 System.Boolean @requeue)
6900 BasicRecover __req = new BasicRecover();
6901 __req.m_requeue = @requeue;
6902 ModelSend(__req,null,null);
6904 public override void TxSelect()
6906 TxSelect __req = new TxSelect();
6907 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6908 TxSelectOk __rep = __repBase as TxSelectOk;
6909 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6911 public override void TxCommit()
6913 TxCommit __req = new TxCommit();
6914 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6915 TxCommitOk __rep = __repBase as TxCommitOk;
6916 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6918 public override void TxRollback()
6920 TxRollback __req = new TxRollback();
6921 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6922 TxRollbackOk __rep = __repBase as TxRollbackOk;
6923 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6925 public override void DtxSelect()
6927 DtxSelect __req = new DtxSelect();
6928 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6929 DtxSelectOk __rep = __repBase as DtxSelectOk;
6930 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6932 public override void DtxStart(
6933 System.String @dtxIdentifier)
6935 DtxStart __req = new DtxStart();
6936 __req.m_dtxIdentifier = @dtxIdentifier;
6937 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6938 DtxStartOk __rep = __repBase as DtxStartOk;
6939 if (__rep == null) throw new UnexpectedMethodException(__repBase);
6941 public override bool DispatchAsynchronous(RabbitMQ.Client.Impl.Command cmd) {
6942 RabbitMQ.Client.Impl.MethodBase __method = (RabbitMQ.Client.Impl.MethodBase) cmd.Method;
6943 switch ((__method.ProtocolClassId << 16) | __method.ProtocolMethodId) {
6945 BasicConsumeOk __impl = (BasicConsumeOk) __method;
6946 HandleBasicConsumeOk(
6947 __impl.m_consumerTag);
6951 BasicCancelOk __impl = (BasicCancelOk) __method;
6952 HandleBasicCancelOk(
6953 __impl.m_consumerTag);
6957 BasicGetOk __impl = (BasicGetOk) __method;
6959 __impl.m_deliveryTag,
6960 __impl.m_redelivered,
6962 __impl.m_routingKey,
6963 __impl.m_messageCount,
6964 (RabbitMQ.Client.IBasicProperties) cmd.Header,
6969 HandleBasicGetEmpty();
6973 BasicDeliver __impl = (BasicDeliver) __method;
6975 __impl.m_consumerTag,
6976 __impl.m_deliveryTag,
6977 __impl.m_redelivered,
6979 __impl.m_routingKey,
6980 (RabbitMQ.Client.IBasicProperties) cmd.Header,
6985 BasicReturn __impl = (BasicReturn) __method;
6990 __impl.m_routingKey,
6991 (RabbitMQ.Client.IBasicProperties) cmd.Header,
6996 ChannelFlow __impl = (ChannelFlow) __method;
7002 ChannelClose __impl = (ChannelClose) __method;
7011 HandleChannelCloseOk();
7015 ConnectionStart __impl = (ConnectionStart) __method;
7016 HandleConnectionStart(
7017 __impl.m_versionMajor,
7018 __impl.m_versionMinor,
7019 __impl.m_serverProperties,
7020 __impl.m_mechanisms,
7025 ConnectionOpenOk __impl = (ConnectionOpenOk) __method;
7026 HandleConnectionOpenOk(
7027 __impl.m_knownHosts);
7031 ConnectionRedirect __impl = (ConnectionRedirect) __method;
7032 HandleConnectionRedirect(
7034 __impl.m_knownHosts);
7038 ConnectionClose __impl = (ConnectionClose) __method;
7039 HandleConnectionClose(
7046 default: return false;