1 // Autogenerated code. Do not edit.
4 using RabbitMQ.Client.Exceptions;
6 namespace RabbitMQ.Client.Framing.v0_9 {
7 public class Protocol: RabbitMQ.Client.Framing.Impl.v0_9.ProtocolBase {
8 ///<summary>Protocol major version (= 0)</summary>
9 public override int MajorVersion { get { return 0; } }
10 ///<summary>Protocol minor version (= 9)</summary>
11 public override int MinorVersion { get { return 9; } }
12 ///<summary>Protocol API name (= AMQP_0_9)</summary>
13 public override string ApiName { get { return "AMQP_0_9"; } }
14 ///<summary>Default TCP port (= 5672)</summary>
15 public override int DefaultPort { get { return 5672; } }
17 public override RabbitMQ.Client.Impl.MethodBase DecodeMethodFrom(RabbitMQ.Util.NetworkBinaryReader reader) {
18 ushort classId = reader.ReadUInt16();
19 ushort methodId = reader.ReadUInt16();
25 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionStart result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionStart();
26 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
30 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionStartOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionStartOk();
31 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
35 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionSecure result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionSecure();
36 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
40 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionSecureOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionSecureOk();
41 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
45 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionTune result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionTune();
46 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
50 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionTuneOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionTuneOk();
51 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
55 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionOpen result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionOpen();
56 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
60 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionOpenOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionOpenOk();
61 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
65 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionRedirect result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionRedirect();
66 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
70 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionClose result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionClose();
71 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
75 RabbitMQ.Client.Framing.Impl.v0_9.ConnectionCloseOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ConnectionCloseOk();
76 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
86 RabbitMQ.Client.Framing.Impl.v0_9.ChannelOpen result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelOpen();
87 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
91 RabbitMQ.Client.Framing.Impl.v0_9.ChannelOpenOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelOpenOk();
92 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
96 RabbitMQ.Client.Framing.Impl.v0_9.ChannelFlow result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelFlow();
97 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
101 RabbitMQ.Client.Framing.Impl.v0_9.ChannelFlowOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelFlowOk();
102 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
106 RabbitMQ.Client.Framing.Impl.v0_9.ChannelClose result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelClose();
107 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
111 RabbitMQ.Client.Framing.Impl.v0_9.ChannelCloseOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelCloseOk();
112 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
116 RabbitMQ.Client.Framing.Impl.v0_9.ChannelResume result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelResume();
117 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
121 RabbitMQ.Client.Framing.Impl.v0_9.ChannelPing result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelPing();
122 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
126 RabbitMQ.Client.Framing.Impl.v0_9.ChannelPong result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelPong();
127 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
131 RabbitMQ.Client.Framing.Impl.v0_9.ChannelOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ChannelOk();
132 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
142 RabbitMQ.Client.Framing.Impl.v0_9.AccessRequest result = new RabbitMQ.Client.Framing.Impl.v0_9.AccessRequest();
143 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
147 RabbitMQ.Client.Framing.Impl.v0_9.AccessRequestOk result = new RabbitMQ.Client.Framing.Impl.v0_9.AccessRequestOk();
148 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
158 RabbitMQ.Client.Framing.Impl.v0_9.ExchangeDeclare result = new RabbitMQ.Client.Framing.Impl.v0_9.ExchangeDeclare();
159 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
163 RabbitMQ.Client.Framing.Impl.v0_9.ExchangeDeclareOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ExchangeDeclareOk();
164 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
168 RabbitMQ.Client.Framing.Impl.v0_9.ExchangeDelete result = new RabbitMQ.Client.Framing.Impl.v0_9.ExchangeDelete();
169 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
173 RabbitMQ.Client.Framing.Impl.v0_9.ExchangeDeleteOk result = new RabbitMQ.Client.Framing.Impl.v0_9.ExchangeDeleteOk();
174 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
184 RabbitMQ.Client.Framing.Impl.v0_9.QueueDeclare result = new RabbitMQ.Client.Framing.Impl.v0_9.QueueDeclare();
185 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
189 RabbitMQ.Client.Framing.Impl.v0_9.QueueDeclareOk result = new RabbitMQ.Client.Framing.Impl.v0_9.QueueDeclareOk();
190 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
194 RabbitMQ.Client.Framing.Impl.v0_9.QueueBind result = new RabbitMQ.Client.Framing.Impl.v0_9.QueueBind();
195 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
199 RabbitMQ.Client.Framing.Impl.v0_9.QueueBindOk result = new RabbitMQ.Client.Framing.Impl.v0_9.QueueBindOk();
200 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
204 RabbitMQ.Client.Framing.Impl.v0_9.QueueUnbind result = new RabbitMQ.Client.Framing.Impl.v0_9.QueueUnbind();
205 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
209 RabbitMQ.Client.Framing.Impl.v0_9.QueueUnbindOk result = new RabbitMQ.Client.Framing.Impl.v0_9.QueueUnbindOk();
210 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
214 RabbitMQ.Client.Framing.Impl.v0_9.QueuePurge result = new RabbitMQ.Client.Framing.Impl.v0_9.QueuePurge();
215 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
219 RabbitMQ.Client.Framing.Impl.v0_9.QueuePurgeOk result = new RabbitMQ.Client.Framing.Impl.v0_9.QueuePurgeOk();
220 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
224 RabbitMQ.Client.Framing.Impl.v0_9.QueueDelete result = new RabbitMQ.Client.Framing.Impl.v0_9.QueueDelete();
225 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
229 RabbitMQ.Client.Framing.Impl.v0_9.QueueDeleteOk result = new RabbitMQ.Client.Framing.Impl.v0_9.QueueDeleteOk();
230 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
240 RabbitMQ.Client.Framing.Impl.v0_9.BasicQos result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicQos();
241 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
245 RabbitMQ.Client.Framing.Impl.v0_9.BasicQosOk result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicQosOk();
246 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
250 RabbitMQ.Client.Framing.Impl.v0_9.BasicConsume result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicConsume();
251 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
255 RabbitMQ.Client.Framing.Impl.v0_9.BasicConsumeOk result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicConsumeOk();
256 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
260 RabbitMQ.Client.Framing.Impl.v0_9.BasicCancel result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicCancel();
261 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
265 RabbitMQ.Client.Framing.Impl.v0_9.BasicCancelOk result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicCancelOk();
266 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
270 RabbitMQ.Client.Framing.Impl.v0_9.BasicPublish result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicPublish();
271 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
275 RabbitMQ.Client.Framing.Impl.v0_9.BasicReturn result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicReturn();
276 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
280 RabbitMQ.Client.Framing.Impl.v0_9.BasicDeliver result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicDeliver();
281 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
285 RabbitMQ.Client.Framing.Impl.v0_9.BasicGet result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicGet();
286 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
290 RabbitMQ.Client.Framing.Impl.v0_9.BasicGetOk result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicGetOk();
291 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
295 RabbitMQ.Client.Framing.Impl.v0_9.BasicGetEmpty result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicGetEmpty();
296 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
300 RabbitMQ.Client.Framing.Impl.v0_9.BasicAck result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicAck();
301 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
305 RabbitMQ.Client.Framing.Impl.v0_9.BasicReject result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicReject();
306 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
310 RabbitMQ.Client.Framing.Impl.v0_9.BasicRecover result = new RabbitMQ.Client.Framing.Impl.v0_9.BasicRecover();
311 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
321 RabbitMQ.Client.Framing.Impl.v0_9.FileQos result = new RabbitMQ.Client.Framing.Impl.v0_9.FileQos();
322 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
326 RabbitMQ.Client.Framing.Impl.v0_9.FileQosOk result = new RabbitMQ.Client.Framing.Impl.v0_9.FileQosOk();
327 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
331 RabbitMQ.Client.Framing.Impl.v0_9.FileConsume result = new RabbitMQ.Client.Framing.Impl.v0_9.FileConsume();
332 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
336 RabbitMQ.Client.Framing.Impl.v0_9.FileConsumeOk result = new RabbitMQ.Client.Framing.Impl.v0_9.FileConsumeOk();
337 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
341 RabbitMQ.Client.Framing.Impl.v0_9.FileCancel result = new RabbitMQ.Client.Framing.Impl.v0_9.FileCancel();
342 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
346 RabbitMQ.Client.Framing.Impl.v0_9.FileCancelOk result = new RabbitMQ.Client.Framing.Impl.v0_9.FileCancelOk();
347 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
351 RabbitMQ.Client.Framing.Impl.v0_9.FileOpen result = new RabbitMQ.Client.Framing.Impl.v0_9.FileOpen();
352 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
356 RabbitMQ.Client.Framing.Impl.v0_9.FileOpenOk result = new RabbitMQ.Client.Framing.Impl.v0_9.FileOpenOk();
357 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
361 RabbitMQ.Client.Framing.Impl.v0_9.FileStage result = new RabbitMQ.Client.Framing.Impl.v0_9.FileStage();
362 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
366 RabbitMQ.Client.Framing.Impl.v0_9.FilePublish result = new RabbitMQ.Client.Framing.Impl.v0_9.FilePublish();
367 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
371 RabbitMQ.Client.Framing.Impl.v0_9.FileReturn result = new RabbitMQ.Client.Framing.Impl.v0_9.FileReturn();
372 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
376 RabbitMQ.Client.Framing.Impl.v0_9.FileDeliver result = new RabbitMQ.Client.Framing.Impl.v0_9.FileDeliver();
377 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
381 RabbitMQ.Client.Framing.Impl.v0_9.FileAck result = new RabbitMQ.Client.Framing.Impl.v0_9.FileAck();
382 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
386 RabbitMQ.Client.Framing.Impl.v0_9.FileReject result = new RabbitMQ.Client.Framing.Impl.v0_9.FileReject();
387 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
397 RabbitMQ.Client.Framing.Impl.v0_9.StreamQos result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamQos();
398 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
402 RabbitMQ.Client.Framing.Impl.v0_9.StreamQosOk result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamQosOk();
403 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
407 RabbitMQ.Client.Framing.Impl.v0_9.StreamConsume result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamConsume();
408 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
412 RabbitMQ.Client.Framing.Impl.v0_9.StreamConsumeOk result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamConsumeOk();
413 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
417 RabbitMQ.Client.Framing.Impl.v0_9.StreamCancel result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamCancel();
418 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
422 RabbitMQ.Client.Framing.Impl.v0_9.StreamCancelOk result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamCancelOk();
423 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
427 RabbitMQ.Client.Framing.Impl.v0_9.StreamPublish result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamPublish();
428 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
432 RabbitMQ.Client.Framing.Impl.v0_9.StreamReturn result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamReturn();
433 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
437 RabbitMQ.Client.Framing.Impl.v0_9.StreamDeliver result = new RabbitMQ.Client.Framing.Impl.v0_9.StreamDeliver();
438 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
448 RabbitMQ.Client.Framing.Impl.v0_9.TxSelect result = new RabbitMQ.Client.Framing.Impl.v0_9.TxSelect();
449 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
453 RabbitMQ.Client.Framing.Impl.v0_9.TxSelectOk result = new RabbitMQ.Client.Framing.Impl.v0_9.TxSelectOk();
454 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
458 RabbitMQ.Client.Framing.Impl.v0_9.TxCommit result = new RabbitMQ.Client.Framing.Impl.v0_9.TxCommit();
459 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
463 RabbitMQ.Client.Framing.Impl.v0_9.TxCommitOk result = new RabbitMQ.Client.Framing.Impl.v0_9.TxCommitOk();
464 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
468 RabbitMQ.Client.Framing.Impl.v0_9.TxRollback result = new RabbitMQ.Client.Framing.Impl.v0_9.TxRollback();
469 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
473 RabbitMQ.Client.Framing.Impl.v0_9.TxRollbackOk result = new RabbitMQ.Client.Framing.Impl.v0_9.TxRollbackOk();
474 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
484 RabbitMQ.Client.Framing.Impl.v0_9.DtxSelect result = new RabbitMQ.Client.Framing.Impl.v0_9.DtxSelect();
485 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
489 RabbitMQ.Client.Framing.Impl.v0_9.DtxSelectOk result = new RabbitMQ.Client.Framing.Impl.v0_9.DtxSelectOk();
490 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
494 RabbitMQ.Client.Framing.Impl.v0_9.DtxStart result = new RabbitMQ.Client.Framing.Impl.v0_9.DtxStart();
495 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
499 RabbitMQ.Client.Framing.Impl.v0_9.DtxStartOk result = new RabbitMQ.Client.Framing.Impl.v0_9.DtxStartOk();
500 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
510 RabbitMQ.Client.Framing.Impl.v0_9.TunnelRequest result = new RabbitMQ.Client.Framing.Impl.v0_9.TunnelRequest();
511 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
521 RabbitMQ.Client.Framing.Impl.v0_9.MessageTransfer result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageTransfer();
522 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
526 RabbitMQ.Client.Framing.Impl.v0_9.MessageConsume result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageConsume();
527 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
531 RabbitMQ.Client.Framing.Impl.v0_9.MessageCancel result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageCancel();
532 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
536 RabbitMQ.Client.Framing.Impl.v0_9.MessageGet result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageGet();
537 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
541 RabbitMQ.Client.Framing.Impl.v0_9.MessageRecover result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageRecover();
542 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
546 RabbitMQ.Client.Framing.Impl.v0_9.MessageOpen result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageOpen();
547 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
551 RabbitMQ.Client.Framing.Impl.v0_9.MessageClose result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageClose();
552 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
556 RabbitMQ.Client.Framing.Impl.v0_9.MessageAppend result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageAppend();
557 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
561 RabbitMQ.Client.Framing.Impl.v0_9.MessageCheckpoint result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageCheckpoint();
562 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
566 RabbitMQ.Client.Framing.Impl.v0_9.MessageResume result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageResume();
567 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
571 RabbitMQ.Client.Framing.Impl.v0_9.MessageQos result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageQos();
572 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
576 RabbitMQ.Client.Framing.Impl.v0_9.MessageOk result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageOk();
577 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
581 RabbitMQ.Client.Framing.Impl.v0_9.MessageEmpty result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageEmpty();
582 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
586 RabbitMQ.Client.Framing.Impl.v0_9.MessageReject result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageReject();
587 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
591 RabbitMQ.Client.Framing.Impl.v0_9.MessageOffset result = new RabbitMQ.Client.Framing.Impl.v0_9.MessageOffset();
592 result.ReadArgumentsFrom(new RabbitMQ.Client.Impl.MethodArgumentReader(reader));
601 throw new RabbitMQ.Client.Impl.UnknownClassOrMethodException(classId, methodId);
604 public override RabbitMQ.Client.Impl.ContentHeaderBase DecodeContentHeaderFrom(RabbitMQ.Util.NetworkBinaryReader reader) {
605 ushort classId = reader.ReadUInt16();
608 case 60: return new BasicProperties();
609 case 70: return new FileProperties();
610 case 80: return new StreamProperties();
611 case 110: return new TunnelProperties();
614 throw new RabbitMQ.Client.Impl.UnknownClassOrMethodException(classId, 0);
617 public class Constants {
618 ///<summary>(= 1)</summary>
619 public const int FrameMethod = 1;
620 ///<summary>(= 2)</summary>
621 public const int FrameHeader = 2;
622 ///<summary>(= 3)</summary>
623 public const int FrameBody = 3;
624 ///<summary>(= 4)</summary>
625 public const int FrameOobMethod = 4;
626 ///<summary>(= 5)</summary>
627 public const int FrameOobHeader = 5;
628 ///<summary>(= 6)</summary>
629 public const int FrameOobBody = 6;
630 ///<summary>(= 7)</summary>
631 public const int FrameTrace = 7;
632 ///<summary>(= 8)</summary>
633 public const int FrameHeartbeat = 8;
634 ///<summary>(= 4096)</summary>
635 public const int FrameMinSize = 4096;
636 ///<summary>(= 206)</summary>
637 public const int FrameEnd = 206;
638 ///<summary>(= 200)</summary>
639 public const int ReplySuccess = 200;
640 ///<summary>(= 310)</summary>
641 public const int NotDelivered = 310;
642 ///<summary>(= 311)</summary>
643 public const int ContentTooLarge = 311;
644 ///<summary>(= 312)</summary>
645 public const int NoRoute = 312;
646 ///<summary>(= 313)</summary>
647 public const int NoConsumers = 313;
648 ///<summary>(= 320)</summary>
649 public const int ConnectionForced = 320;
650 ///<summary>(= 402)</summary>
651 public const int InvalidPath = 402;
652 ///<summary>(= 403)</summary>
653 public const int AccessRefused = 403;
654 ///<summary>(= 404)</summary>
655 public const int NotFound = 404;
656 ///<summary>(= 405)</summary>
657 public const int ResourceLocked = 405;
658 ///<summary>(= 406)</summary>
659 public const int PreconditionFailed = 406;
660 ///<summary>(= 501)</summary>
661 public const int FrameError = 501;
662 ///<summary>(= 502)</summary>
663 public const int SyntaxError = 502;
664 ///<summary>(= 503)</summary>
665 public const int CommandInvalid = 503;
666 ///<summary>(= 504)</summary>
667 public const int ChannelError = 504;
668 ///<summary>(= 506)</summary>
669 public const int ResourceError = 506;
670 ///<summary>(= 530)</summary>
671 public const int NotAllowed = 530;
672 ///<summary>(= 540)</summary>
673 public const int NotImplemented = 540;
674 ///<summary>(= 541)</summary>
675 public const int InternalError = 541;
677 /// <summary>Autogenerated type. AMQP specification method "connection.start".</summary>
680 /// This method starts the connection negotiation process by telling the client the
681 /// protocol version that the server proposes, along with a list of security mechanisms
682 /// which the client can use for authentication.
685 public interface IConnectionStart: IMethod {
688 /// The protocol version, major component, as transmitted in the AMQP protocol
689 /// header. This, combined with the protocol minor component fully describe the
690 /// protocol version, which is written in the format major-minor. Hence, with
691 /// major=1, minor=3, the protocol version would be "1-3".
694 byte VersionMajor { get; }
697 /// The protocol version, minor component, as transmitted in the AMQP protocol
698 /// header. This, combined with the protocol major component fully describe the
699 /// protocol version, which is written in the format major-minor. Hence, with
700 /// major=1, minor=3, the protocol version would be "1-3".
703 byte VersionMinor { get; }
704 // (no documentation)
705 System.Collections.IDictionary ServerProperties { get; }
708 /// A list of the security mechanisms that the server supports, delimited by spaces.
711 byte[] Mechanisms { get; }
714 /// A list of the message locales that the server supports, delimited by spaces. The
715 /// locale defines the language in which the server will send reply texts.
718 byte[] Locales { get; }
720 /// <summary>Autogenerated type. AMQP specification method "connection.start-ok".</summary>
723 /// This method selects a SASL security mechanism.
726 public interface IConnectionStartOk: IMethod {
727 // (no documentation)
728 System.Collections.IDictionary ClientProperties { get; }
731 /// A single security mechanisms selected by the client, which must be one of those
732 /// specified by the server.
735 string Mechanism { get; }
738 /// A block of opaque data passed to the security mechanism. The contents of this
739 /// data are defined by the SASL security mechanism.
742 byte[] Response { get; }
745 /// A single message locale selected by the client, which must be one of those
746 /// specified by the server.
749 string Locale { get; }
751 /// <summary>Autogenerated type. AMQP specification method "connection.secure".</summary>
754 /// The SASL protocol works by exchanging challenges and responses until both peers have
755 /// received sufficient information to authenticate each other. This method challenges
756 /// the client to provide more information.
759 public interface IConnectionSecure: IMethod {
762 /// Challenge information, a block of opaque binary data passed to the security
766 byte[] Challenge { get; }
768 /// <summary>Autogenerated type. AMQP specification method "connection.secure-ok".</summary>
771 /// This method attempts to authenticate, passing a block of SASL data for the security
772 /// mechanism at the server side.
775 public interface IConnectionSecureOk: IMethod {
778 /// A block of opaque data passed to the security mechanism. The contents of this
779 /// data are defined by the SASL security mechanism.
782 byte[] Response { get; }
784 /// <summary>Autogenerated type. AMQP specification method "connection.tune".</summary>
787 /// This method proposes a set of connection configuration values to the client. The
788 /// client can accept and/or adjust these.
791 public interface IConnectionTune: IMethod {
794 /// The maximum total number of channels that the server allows per connection. Zero
795 /// means that the server does not impose a fixed limit, but the number of allowed
796 /// channels may be limited by available server resources.
799 ushort ChannelMax { get; }
802 /// The largest frame size that the server proposes for the connection. The client
803 /// can negotiate a lower value. Zero means that the server does not impose any
804 /// specific limit but may reject very large frames if it cannot allocate resources
808 uint FrameMax { get; }
811 /// The delay, in seconds, of the connection heartbeat that the server wants.
812 /// Zero means the server does not want a heartbeat.
815 ushort Heartbeat { get; }
817 /// <summary>Autogenerated type. AMQP specification method "connection.tune-ok".</summary>
820 /// This method sends the client's connection tuning parameters to the server.
821 /// Certain fields are negotiated, others provide capability information.
824 public interface IConnectionTuneOk: IMethod {
827 /// The maximum total number of channels that the client will use per connection.
830 ushort ChannelMax { get; }
833 /// The largest frame size that the client and server will use for the connection.
834 /// Zero means that the client does not impose any specific limit but may reject
835 /// very large frames if it cannot allocate resources for them. Note that the
836 /// frame-max limit applies principally to content frames, where large contents can
837 /// be broken into frames of arbitrary size.
840 uint FrameMax { get; }
843 /// The delay, in seconds, of the connection heartbeat that the client wants. Zero
844 /// means the client does not want a heartbeat.
847 ushort Heartbeat { get; }
849 /// <summary>Autogenerated type. AMQP specification method "connection.open".</summary>
852 /// This method opens a connection to a virtual host, which is a collection of
853 /// resources, and acts to separate multiple application domains within a server.
854 /// The server may apply arbitrary limits per virtual host, such as the number
855 /// of each type of entity that may be used, per connection and/or in total.
858 public interface IConnectionOpen: IMethod {
861 /// The name of the virtual host to work with.
864 string VirtualHost { get; }
867 /// The client can specify zero or more capability names, delimited by spaces.
868 /// The server can use this string to how to process the client's connection
872 string Capabilities { get; }
875 /// In a configuration with multiple collaborating servers, the server may respond
876 /// to a Connection.Open method with a Connection.Redirect. The insist option tells
877 /// the server that the client is insisting on a connection to the specified server.
882 /// <summary>Autogenerated type. AMQP specification method "connection.open-ok".</summary>
885 /// This method signals to the client that the connection is ready for use.
888 public interface IConnectionOpenOk: IMethod {
889 // (no documentation)
890 string KnownHosts { get; }
892 /// <summary>Autogenerated type. AMQP specification method "connection.redirect".</summary>
895 /// This method redirects the client to another server, based on the requested virtual
896 /// host and/or capabilities.
899 public interface IConnectionRedirect: IMethod {
902 /// Specifies the server to connect to. This is an IP address or a DNS name,
903 /// optionally followed by a colon and a port number. If no port number is
904 /// specified, the client should use the default port number for the protocol.
908 // (no documentation)
909 string KnownHosts { get; }
911 /// <summary>Autogenerated type. AMQP specification method "connection.close".</summary>
914 /// This method indicates that the sender wants to close the connection. This may be
915 /// due to internal conditions (e.g. a forced shut-down) or due to an error handling
916 /// a specific method, i.e. an exception. When a close is due to an exception, the
917 /// sender provides the class and method id of the method which caused the exception.
920 public interface IConnectionClose: IMethod {
921 // (no documentation)
922 ushort ReplyCode { get; }
923 // (no documentation)
924 string ReplyText { get; }
927 /// When the close is provoked by a method exception, this is the class of the
931 ushort ClassId { get; }
934 /// When the close is provoked by a method exception, this is the ID of the method.
937 ushort MethodId { get; }
939 /// <summary>Autogenerated type. AMQP specification method "connection.close-ok".</summary>
942 /// This method confirms a Connection.Close method and tells the recipient that it is
943 /// safe to release resources for the connection and close the socket.
946 public interface IConnectionCloseOk: IMethod {
948 /// <summary>Autogenerated type. AMQP specification method "channel.open".</summary>
951 /// This method opens a channel to the server.
954 public interface IChannelOpen: IMethod {
957 /// Configures out-of-band transfers on this channel. The syntax and meaning of this
958 /// field will be formally defined at a later date.
961 string OutOfBand { get; }
963 /// <summary>Autogenerated type. AMQP specification method "channel.open-ok".</summary>
966 /// This method signals to the client that the channel is ready for use.
969 public interface IChannelOpenOk: IMethod {
970 // (no documentation)
971 byte[] ChannelId { get; }
973 /// <summary>Autogenerated type. AMQP specification method "channel.flow".</summary>
976 /// This method asks the peer to pause or restart the flow of content data. This is a
977 /// simple flow-control mechanism that a peer can use to avoid overflowing its queues or
978 /// otherwise finding itself receiving more messages than it can process. Note that this
979 /// method is not intended for window control. The peer that receives a disable flow
980 /// method should finish sending the current content frame, if any, then pause.
983 public interface IChannelFlow: IMethod {
986 /// If 1, the peer starts sending content frames. If 0, the peer stops sending
992 /// <summary>Autogenerated type. AMQP specification method "channel.flow-ok".</summary>
995 /// Confirms to the peer that a flow command was received and processed.
998 public interface IChannelFlowOk: IMethod {
1001 /// Confirms the setting of the processed flow method: 1 means the peer will start
1002 /// sending or continue to send content frames; 0 means it will not.
1005 bool Active { get; }
1007 /// <summary>Autogenerated type. AMQP specification method "channel.close".</summary>
1010 /// This method indicates that the sender wants to close the channel. This may be due to
1011 /// internal conditions (e.g. a forced shut-down) or due to an error handling a specific
1012 /// method, i.e. an exception. When a close is due to an exception, the sender provides
1013 /// the class and method id of the method which caused the exception.
1016 public interface IChannelClose: IMethod {
1017 // (no documentation)
1018 ushort ReplyCode { get; }
1019 // (no documentation)
1020 string ReplyText { get; }
1023 /// When the close is provoked by a method exception, this is the class of the
1027 ushort ClassId { get; }
1030 /// When the close is provoked by a method exception, this is the ID of the method.
1033 ushort MethodId { get; }
1035 /// <summary>Autogenerated type. AMQP specification method "channel.close-ok".</summary>
1038 /// This method confirms a Channel.Close method and tells the recipient that it is safe
1039 /// to release resources for the channel.
1042 public interface IChannelCloseOk: IMethod {
1044 /// <summary>Autogenerated type. AMQP specification method "channel.resume".</summary>
1047 /// This method resume a previously interrupted channel.
1050 public interface IChannelResume: IMethod {
1051 // (no documentation)
1052 byte[] ChannelId { get; }
1054 /// <summary>Autogenerated type. AMQP specification method "channel.ping".</summary>
1057 /// [WORK IN PROGRESS] Request that the recipient issue a pong request.
1060 public interface IChannelPing: IMethod {
1062 /// <summary>Autogenerated type. AMQP specification method "channel.pong".</summary>
1065 /// [WORK IN PROGRESS] Issued after a ping request is received. Note that this is a
1066 /// request issued after receiving a ping, not a response to
1067 /// receiving a ping.
1070 public interface IChannelPong: IMethod {
1072 /// <summary>Autogenerated type. AMQP specification method "channel.ok".</summary>
1075 /// [WORK IN PROGRESS] Signals normal completion of a method.
1078 public interface IChannelOk: IMethod {
1080 /// <summary>Autogenerated type. AMQP specification method "access.request".</summary>
1083 /// This method requests an access ticket for an access realm. The server
1084 /// responds by granting the access ticket. If the client does not have
1085 /// access rights to the requested realm this causes a connection exception.
1086 /// Access tickets are a per-channel resource.
1089 public interface IAccessRequest: IMethod {
1092 /// Specifies the name of the realm to which the client is requesting access.
1093 /// The realm is a configured server-side object that collects a set of
1094 /// resources (exchanges, queues, etc.). If the channel has already requested
1095 /// an access ticket onto this realm, the previous ticket is destroyed and a
1096 /// new ticket is created with the requested access rights, if allowed.
1099 string Realm { get; }
1102 /// Request exclusive access to the realm, meaning that this will be the only
1103 /// channel that uses the realm's resources.
1106 bool Exclusive { get; }
1109 /// Request message passive access to the specified access realm. Passive
1110 /// access lets a client get information about resources in the realm but
1111 /// not to make any changes to them.
1114 bool Passive { get; }
1117 /// Request message active access to the specified access realm. Active access lets
1118 /// a client get create and delete resources in the realm.
1121 bool Active { get; }
1124 /// Request write access to the specified access realm. Write access lets a client
1125 /// publish messages to all exchanges in the realm.
1131 /// Request read access to the specified access realm. Read access lets a client
1132 /// consume messages from queues in the realm.
1137 /// <summary>Autogenerated type. AMQP specification method "access.request-ok".</summary>
1140 /// This method provides the client with an access ticket. The access ticket is valid
1141 /// within the current channel and for the lifespan of the channel.
1144 public interface IAccessRequestOk: IMethod {
1145 // (no documentation)
1146 ushort Ticket { get; }
1148 /// <summary>Autogenerated type. AMQP specification method "exchange.declare".</summary>
1151 /// This method creates an exchange if it does not already exist, and if the exchange
1152 /// exists, verifies that it is of the correct and expected class.
1155 public interface IExchangeDeclare: IMethod {
1158 /// When a client defines a new exchange, this belongs to the access realm of the
1159 /// ticket used. All further work done with that exchange must be done with an
1160 /// access ticket for the same realm.
1163 ushort Ticket { get; }
1164 // (no documentation)
1165 string Exchange { get; }
1168 /// Each exchange belongs to one of a set of exchange types implemented by the
1169 /// server. The exchange types define the functionality of the exchange - i.e. how
1170 /// messages are routed through it. It is not valid or meaningful to attempt to
1171 /// change the type of an existing exchange.
1174 string Type { get; }
1177 /// If set, the server will not create the exchange. The client can use this to
1178 /// check whether an exchange exists without modifying the server state.
1181 bool Passive { get; }
1184 /// If set when creating a new exchange, the exchange will be marked as durable.
1185 /// Durable exchanges remain active when a server restarts. Non-durable exchanges
1186 /// (transient exchanges) are purged if/when a server restarts.
1189 bool Durable { get; }
1192 /// If set, the exchange is deleted when all queues have finished using it.
1195 bool AutoDelete { get; }
1198 /// If set, the exchange may not be used directly by publishers, but only when bound
1199 /// to other exchanges. Internal exchanges are used to construct wiring that is not
1200 /// visible to applications.
1203 bool Internal { get; }
1206 /// If set, the server will not respond to the method. The client should not wait
1207 /// for a reply method. If the server could not complete the method it will raise a
1208 /// channel or connection exception.
1211 bool Nowait { get; }
1214 /// A set of arguments for the declaration. The syntax and semantics of these
1215 /// arguments depends on the server implementation. This field is ignored if passive
1219 System.Collections.IDictionary Arguments { get; }
1221 /// <summary>Autogenerated type. AMQP specification method "exchange.declare-ok".</summary>
1224 /// This method confirms a Declare method and confirms the name of the exchange,
1225 /// essential for automatically-named exchanges.
1228 public interface IExchangeDeclareOk: IMethod {
1230 /// <summary>Autogenerated type. AMQP specification method "exchange.delete".</summary>
1233 /// This method deletes an exchange. When an exchange is deleted all queue bindings on
1234 /// the exchange are cancelled.
1237 public interface IExchangeDelete: IMethod {
1238 // (no documentation)
1239 ushort Ticket { get; }
1240 // (no documentation)
1241 string Exchange { get; }
1244 /// If set, the server will only delete the exchange if it has no queue bindings. If
1245 /// the exchange has queue bindings the server does not delete it but raises a
1246 /// channel exception instead.
1249 bool IfUnused { get; }
1252 /// If set, the server will not respond to the method. The client should not wait
1253 /// for a reply method. If the server could not complete the method it will raise a
1254 /// channel or connection exception.
1257 bool Nowait { get; }
1259 /// <summary>Autogenerated type. AMQP specification method "exchange.delete-ok".</summary>
1261 /// This method confirms the deletion of an exchange.
1263 public interface IExchangeDeleteOk: IMethod {
1265 /// <summary>Autogenerated type. AMQP specification method "queue.declare".</summary>
1268 /// This method creates or checks a queue. When creating a new queue the client can
1269 /// specify various properties that control the durability of the queue and its
1270 /// contents, and the level of sharing for the queue.
1273 public interface IQueueDeclare: IMethod {
1276 /// When a client defines a new queue, this belongs to the access realm of the
1277 /// ticket used. All further work done with that queue must be done with an access
1278 /// ticket for the same realm.
1281 ushort Ticket { get; }
1282 // (no documentation)
1283 string Queue { get; }
1286 /// If set, the server will not create the queue. This field allows the client
1287 /// to assert the presence of a queue without modifying the server state.
1290 bool Passive { get; }
1293 /// If set when creating a new queue, the queue will be marked as durable. Durable
1294 /// queues remain active when a server restarts. Non-durable queues (transient
1295 /// queues) are purged if/when a server restarts. Note that durable queues do not
1296 /// necessarily hold persistent messages, although it does not make sense to send
1297 /// persistent messages to a transient queue.
1300 bool Durable { get; }
1303 /// Exclusive queues may only be consumed from by the current connection. Setting
1304 /// the 'exclusive' flag always implies 'auto-delete'.
1307 bool Exclusive { get; }
1310 /// If set, the queue is deleted when all consumers have finished using it. Last
1311 /// consumer can be cancelled either explicitly or because its channel is closed. If
1312 /// there was no consumer ever on the queue, it won't be deleted.
1315 bool AutoDelete { get; }
1318 /// If set, the server will not respond to the method. The client should not wait
1319 /// for a reply method. If the server could not complete the method it will raise a
1320 /// channel or connection exception.
1323 bool Nowait { get; }
1326 /// A set of arguments for the declaration. The syntax and semantics of these
1327 /// arguments depends on the server implementation. This field is ignored if passive
1331 System.Collections.IDictionary Arguments { get; }
1333 /// <summary>Autogenerated type. AMQP specification method "queue.declare-ok".</summary>
1336 /// This method confirms a Declare method and confirms the name of the queue, essential
1337 /// for automatically-named queues.
1340 public interface IQueueDeclareOk: IMethod {
1343 /// Reports the name of the queue. If the server generated a queue name, this field
1344 /// contains that name.
1347 string Queue { get; }
1350 /// Reports the number of messages in the queue, which will be zero for
1351 /// newly-created queues.
1354 uint MessageCount { get; }
1357 /// Reports the number of active consumers for the queue. Note that consumers can
1358 /// suspend activity (Channel.Flow) in which case they do not appear in this count.
1361 uint ConsumerCount { get; }
1363 /// <summary>Autogenerated type. AMQP specification method "queue.bind".</summary>
1366 /// This method binds a queue to an exchange. Until a queue is bound it will not receive
1367 /// any messages. In a classic messaging model, store-and-forward queues are bound to a
1368 /// direct exchange and subscription queues are bound to a topic exchange.
1371 public interface IQueueBind: IMethod {
1374 /// The client provides a valid access ticket giving "active" access rights to the
1375 /// queue's access realm.
1378 ushort Ticket { get; }
1381 /// Specifies the name of the queue to bind. If the queue name is empty, refers to
1382 /// the current queue for the channel, which is the last declared queue.
1385 string Queue { get; }
1386 // (no documentation)
1387 string Exchange { get; }
1390 /// Specifies the routing key for the binding. The routing key is used for routing
1391 /// messages depending on the exchange configuration. Not all exchanges use a
1392 /// routing key - refer to the specific exchange documentation. If the queue name
1393 /// is empty, the server uses the last queue declared on the channel. If the
1394 /// routing key is also empty, the server uses this queue name for the routing
1395 /// key as well. If the queue name is provided but the routing key is empty, the
1396 /// server does the binding with that empty routing key. The meaning of empty
1397 /// routing keys depends on the exchange implementation.
1400 string RoutingKey { get; }
1403 /// If set, the server will not respond to the method. The client should not wait
1404 /// for a reply method. If the server could not complete the method it will raise a
1405 /// channel or connection exception.
1408 bool Nowait { get; }
1411 /// A set of arguments for the binding. The syntax and semantics of these arguments
1412 /// depends on the exchange class.
1415 System.Collections.IDictionary Arguments { get; }
1417 /// <summary>Autogenerated type. AMQP specification method "queue.bind-ok".</summary>
1419 /// This method confirms that the bind was successful.
1421 public interface IQueueBindOk: IMethod {
1423 /// <summary>Autogenerated type. AMQP specification method "queue.unbind".</summary>
1425 /// This method unbinds a queue from an exchange.
1427 public interface IQueueUnbind: IMethod {
1430 /// The client provides a valid access ticket giving "active"
1431 /// access rights to the queue's access realm.
1434 ushort Ticket { get; }
1436 /// Specifies the name of the queue to unbind.
1438 string Queue { get; }
1440 /// The name of the exchange to unbind from.
1442 string Exchange { get; }
1444 /// Specifies the routing key of the binding to unbind.
1446 string RoutingKey { get; }
1448 /// Specifies the arguments of the binding to unbind.
1450 System.Collections.IDictionary Arguments { get; }
1452 /// <summary>Autogenerated type. AMQP specification method "queue.unbind-ok".</summary>
1454 /// This method confirms that the unbind was successful.
1456 public interface IQueueUnbindOk: IMethod {
1458 /// <summary>Autogenerated type. AMQP specification method "queue.purge".</summary>
1461 /// This method removes all messages from a queue. It does not cancel consumers. Purged
1462 /// messages are deleted without any formal "undo" mechanism.
1465 public interface IQueuePurge: IMethod {
1467 /// The access ticket must be for the access realm that holds the queue.
1469 ushort Ticket { get; }
1472 /// Specifies the name of the queue to purge. If the queue name is empty, refers to
1473 /// the current queue for the channel, which is the last declared queue.
1476 string Queue { get; }
1479 /// If set, the server will not respond to the method. The client should not wait
1480 /// for a reply method. If the server could not complete the method it will raise a
1481 /// channel or connection exception.
1484 bool Nowait { get; }
1486 /// <summary>Autogenerated type. AMQP specification method "queue.purge-ok".</summary>
1488 /// This method confirms the purge of a queue.
1490 public interface IQueuePurgeOk: IMethod {
1492 /// Reports the number of messages purged.
1494 uint MessageCount { get; }
1496 /// <summary>Autogenerated type. AMQP specification method "queue.delete".</summary>
1499 /// This method deletes a queue. When a queue is deleted any pending messages are sent
1500 /// to a dead-letter queue if this is defined in the server configuration, and all
1501 /// consumers on the queue are cancelled.
1504 public interface IQueueDelete: IMethod {
1507 /// The client provides a valid access ticket giving "active" access rights to the
1508 /// queue's access realm.
1511 ushort Ticket { get; }
1514 /// Specifies the name of the queue to delete. If the queue name is empty, refers to
1515 /// the current queue for the channel, which is the last declared queue.
1518 string Queue { get; }
1521 /// If set, the server will only delete the queue if it has no consumers. If the
1522 /// queue has consumers the server does does not delete it but raises a channel
1523 /// exception instead.
1526 bool IfUnused { get; }
1529 /// If set, the server will only delete the queue if it has no messages.
1532 bool IfEmpty { get; }
1535 /// If set, the server will not respond to the method. The client should not wait
1536 /// for a reply method. If the server could not complete the method it will raise a
1537 /// channel or connection exception.
1540 bool Nowait { get; }
1542 /// <summary>Autogenerated type. AMQP specification method "queue.delete-ok".</summary>
1544 /// This method confirms the deletion of a queue.
1546 public interface IQueueDeleteOk: IMethod {
1548 /// Reports the number of messages purged.
1550 uint MessageCount { get; }
1552 /// <summary>Autogenerated type. AMQP specification method "basic.qos".</summary>
1555 /// This method requests a specific quality of service. The QoS can be specified for the
1556 /// current channel or for all channels on the connection. The particular properties and
1557 /// semantics of a qos method always depend on the content class semantics. Though the
1558 /// qos method could in principle apply to both peers, it is currently meaningful only
1562 public interface IBasicQos: IMethod {
1565 /// The client can request that messages be sent in advance so that when the client
1566 /// finishes processing a message, the following message is already held locally,
1567 /// rather than needing to be sent down the channel. Prefetching gives a performance
1568 /// improvement. This field specifies the prefetch window size in octets. The server
1569 /// will send a message in advance if it is equal to or smaller in size than the
1570 /// available prefetch size (and also falls into other prefetch limits). May be set
1571 /// to zero, meaning "no specific limit", although other prefetch limits may still
1572 /// apply. The prefetch-size is ignored if the no-ack option is set.
1575 uint PrefetchSize { get; }
1578 /// Specifies a prefetch window in terms of whole messages. This field may be used
1579 /// in combination with the prefetch-size field; a message will only be sent in
1580 /// advance if both prefetch windows (and those at the channel and connection level)
1581 /// allow it. The prefetch-count is ignored if the no-ack option is set.
1584 ushort PrefetchCount { get; }
1587 /// By default the QoS settings apply to the current channel only. If this field is
1588 /// set, they are applied to the entire connection.
1591 bool Global { get; }
1593 /// <summary>Autogenerated type. AMQP specification method "basic.qos-ok".</summary>
1596 /// This method tells the client that the requested QoS levels could be handled by the
1597 /// server. The requested QoS applies to all active consumers until a new QoS is
1601 public interface IBasicQosOk: IMethod {
1603 /// <summary>Autogenerated type. AMQP specification method "basic.consume".</summary>
1606 /// This method asks the server to start a "consumer", which is a transient request for
1607 /// messages from a specific queue. Consumers last as long as the channel they were
1608 /// created on, or until the client cancels them.
1611 public interface IBasicConsume: IMethod {
1612 // (no documentation)
1613 ushort Ticket { get; }
1616 /// Specifies the name of the queue to consume from. If the queue name is null,
1617 /// refers to the current queue for the channel, which is the last declared queue.
1620 string Queue { get; }
1623 /// Specifies the identifier for the consumer. The consumer tag is local to a
1624 /// connection, so two clients can use the same consumer tags. If this field is
1625 /// empty the server will generate a unique tag.
1628 string ConsumerTag { get; }
1629 // (no documentation)
1630 bool NoLocal { get; }
1631 // (no documentation)
1635 /// Request exclusive consumer access, meaning only this consumer can access the
1639 bool Exclusive { get; }
1642 /// If set, the server will not respond to the method. The client should not wait
1643 /// for a reply method. If the server could not complete the method it will raise
1644 /// a channel or connection exception.
1647 bool Nowait { get; }
1650 /// A set of filters for the consume. The syntax and semantics
1651 /// of these filters depends on the providers implementation.
1654 System.Collections.IDictionary Filter { get; }
1656 /// <summary>Autogenerated type. AMQP specification method "basic.consume-ok".</summary>
1659 /// The server provides the client with a consumer tag, which is used by the client
1660 /// for methods called on the consumer at a later stage.
1663 public interface IBasicConsumeOk: IMethod {
1666 /// Holds the consumer tag specified by the client or provided by the server.
1669 string ConsumerTag { get; }
1671 /// <summary>Autogenerated type. AMQP specification method "basic.cancel".</summary>
1674 /// This method cancels a consumer. This does not affect already delivered
1675 /// messages, but it does mean the server will not send any more messages for
1676 /// that consumer. The client may receive an arbitrary number of messages in
1677 /// between sending the cancel method and receiving the cancel-ok reply.
1680 public interface IBasicCancel: IMethod {
1681 // (no documentation)
1682 string ConsumerTag { get; }
1685 /// If set, the server will not respond to the method. The client should not wait
1686 /// for a reply method. If the server could not complete the method it will raise a
1687 /// channel or connection exception.
1690 bool Nowait { get; }
1692 /// <summary>Autogenerated type. AMQP specification method "basic.cancel-ok".</summary>
1695 /// This method confirms that the cancellation was completed.
1698 public interface IBasicCancelOk: IMethod {
1699 // (no documentation)
1700 string ConsumerTag { get; }
1702 /// <summary>Autogenerated type. AMQP specification method "basic.publish".</summary>
1705 /// This method publishes a message to a specific exchange. The message will be routed
1706 /// to queues as defined by the exchange configuration and distributed to any active
1707 /// consumers when the transaction, if any, is committed.
1710 public interface IBasicPublish: IMethod {
1711 // (no documentation)
1712 ushort Ticket { get; }
1715 /// Specifies the name of the exchange to publish to. The exchange name can be
1716 /// empty, meaning the default exchange. If the exchange name is specified, and that
1717 /// exchange does not exist, the server will raise a channel exception.
1720 string Exchange { get; }
1723 /// Specifies the routing key for the message. The routing key is used for routing
1724 /// messages depending on the exchange configuration.
1727 string RoutingKey { get; }
1730 /// This flag tells the server how to react if the message cannot be routed to a
1731 /// queue. If this flag is set, the server will return an unroutable message with a
1732 /// Return method. If this flag is zero, the server silently drops the message.
1735 bool Mandatory { get; }
1738 /// This flag tells the server how to react if the message cannot be routed to a
1739 /// queue consumer immediately. If this flag is set, the server will return an
1740 /// undeliverable message with a Return method. If this flag is zero, the server
1741 /// will queue the message, but with no guarantee that it will ever be consumed.
1744 bool Immediate { get; }
1746 /// <summary>Autogenerated type. AMQP specification method "basic.return".</summary>
1749 /// This method returns an undeliverable message that was published with the "immediate"
1750 /// flag set, or an unroutable message published with the "mandatory" flag set. The
1751 /// reply code and text provide information about the reason that the message was
1755 public interface IBasicReturn: IMethod {
1756 // (no documentation)
1757 ushort ReplyCode { get; }
1758 // (no documentation)
1759 string ReplyText { get; }
1762 /// Specifies the name of the exchange that the message was originally published to.
1765 string Exchange { get; }
1768 /// Specifies the routing key name specified when the message was published.
1771 string RoutingKey { get; }
1773 /// <summary>Autogenerated type. AMQP specification method "basic.deliver".</summary>
1776 /// This method delivers a message to the client, via a consumer. In the asynchronous
1777 /// message delivery model, the client starts a consumer using the Consume method, then
1778 /// the server responds with Deliver methods as and when messages arrive for that
1782 public interface IBasicDeliver: IMethod {
1783 // (no documentation)
1784 string ConsumerTag { get; }
1785 // (no documentation)
1786 ulong DeliveryTag { get; }
1787 // (no documentation)
1788 bool Redelivered { get; }
1791 /// Specifies the name of the exchange that the message was originally published to.
1794 string Exchange { get; }
1796 /// Specifies the routing key name specified when the message was published.
1798 string RoutingKey { get; }
1800 /// <summary>Autogenerated type. AMQP specification method "basic.get".</summary>
1803 /// This method provides a direct access to the messages in a queue using a synchronous
1804 /// dialogue that is designed for specific types of application where synchronous
1805 /// functionality is more important than performance.
1808 public interface IBasicGet: IMethod {
1809 // (no documentation)
1810 ushort Ticket { get; }
1813 /// Specifies the name of the queue to consume from. If the queue name is null,
1814 /// refers to the current queue for the channel, which is the last declared queue.
1817 string Queue { get; }
1818 // (no documentation)
1821 /// <summary>Autogenerated type. AMQP specification method "basic.get-ok".</summary>
1824 /// This method delivers a message to the client following a get method. A message
1825 /// delivered by 'get-ok' must be acknowledged unless the no-ack option was set in the
1829 public interface IBasicGetOk: IMethod {
1830 // (no documentation)
1831 ulong DeliveryTag { get; }
1832 // (no documentation)
1833 bool Redelivered { get; }
1836 /// Specifies the name of the exchange that the message was originally published to.
1837 /// If empty, the message was published to the default exchange.
1840 string Exchange { get; }
1842 /// Specifies the routing key name specified when the message was published.
1844 string RoutingKey { get; }
1847 /// This field reports the number of messages pending on the queue, excluding the
1848 /// message being delivered. Note that this figure is indicative, not reliable, and
1849 /// can change arbitrarily as messages are added to the queue and removed by other
1853 uint MessageCount { get; }
1855 /// <summary>Autogenerated type. AMQP specification method "basic.get-empty".</summary>
1858 /// This method tells the client that the queue has no messages available for the
1862 public interface IBasicGetEmpty: IMethod {
1865 /// For use by cluster applications, should not be used by client applications.
1868 string ClusterId { get; }
1870 /// <summary>Autogenerated type. AMQP specification method "basic.ack".</summary>
1873 /// This method acknowledges one or more messages delivered via the Deliver or Get-Ok
1874 /// methods. The client can ask to confirm a single message or a set of messages up to
1875 /// and including a specific message.
1878 public interface IBasicAck: IMethod {
1879 // (no documentation)
1880 ulong DeliveryTag { get; }
1883 /// If set to 1, the delivery tag is treated as "up to and including", so that the
1884 /// client can acknowledge multiple messages with a single method. If set to zero,
1885 /// the delivery tag refers to a single message. If the multiple field is 1, and the
1886 /// delivery tag is zero, tells the server to acknowledge all outstanding messages.
1889 bool Multiple { get; }
1891 /// <summary>Autogenerated type. AMQP specification method "basic.reject".</summary>
1894 /// This method allows a client to reject a message. It can be used to interrupt and
1895 /// cancel large incoming messages, or return untreatable messages to their original
1899 public interface IBasicReject: IMethod {
1900 // (no documentation)
1901 ulong DeliveryTag { get; }
1904 /// If this field is zero, the message will be discarded. If this bit is 1, the
1905 /// server will attempt to requeue the message.
1908 bool Requeue { get; }
1910 /// <summary>Autogenerated type. AMQP specification method "basic.recover".</summary>
1913 /// This method asks the broker to redeliver all unacknowledged messages on a specified
1914 /// channel. Zero or more messages may be redelivered. This method is only allowed on
1915 /// non-transacted channels.
1918 public interface IBasicRecover: IMethod {
1921 /// If this field is zero, the message will be redelivered to the original
1922 /// recipient. If this bit is 1, the server will attempt to requeue the message,
1923 /// potentially then delivering it to an alternative subscriber.
1926 bool Requeue { get; }
1928 /// <summary>Autogenerated type. AMQP specification method "file.qos".</summary>
1931 /// This method requests a specific quality of service. The QoS can be specified for the
1932 /// current channel or for all channels on the connection. The particular properties and
1933 /// semantics of a qos method always depend on the content class semantics. Though the
1934 /// qos method could in principle apply to both peers, it is currently meaningful only
1938 public interface IFileQos: IMethod {
1941 /// The client can request that messages be sent in advance so that when the client
1942 /// finishes processing a message, the following message is already held locally,
1943 /// rather than needing to be sent down the channel. Prefetching gives a performance
1944 /// improvement. This field specifies the prefetch window size in octets. May be set
1945 /// to zero, meaning "no specific limit". Note that other prefetch limits may still
1946 /// apply. The prefetch-size is ignored if the no-ack option is set.
1949 uint PrefetchSize { get; }
1952 /// Specifies a prefetch window in terms of whole messages. This is compatible with
1953 /// some file API implementations. This field may be used in combination with the
1954 /// prefetch-size field; a message will only be sent in advance if both prefetch
1955 /// windows (and those at the channel and connection level) allow it. The
1956 /// prefetch-count is ignored if the no-ack option is set.
1959 ushort PrefetchCount { get; }
1962 /// By default the QoS settings apply to the current channel only. If this field is
1963 /// set, they are applied to the entire connection.
1966 bool Global { get; }
1968 /// <summary>Autogenerated type. AMQP specification method "file.qos-ok".</summary>
1971 /// This method tells the client that the requested QoS levels could be handled by the
1972 /// server. The requested QoS applies to all active consumers until a new QoS is
1976 public interface IFileQosOk: IMethod {
1978 /// <summary>Autogenerated type. AMQP specification method "file.consume".</summary>
1981 /// This method asks the server to start a "consumer", which is a transient request for
1982 /// messages from a specific queue. Consumers last as long as the channel they were
1983 /// created on, or until the client cancels them.
1986 public interface IFileConsume: IMethod {
1987 // (no documentation)
1988 ushort Ticket { get; }
1991 /// Specifies the name of the queue to consume from. If the queue name is null,
1992 /// refers to the current queue for the channel, which is the last declared queue.
1995 string Queue { get; }
1998 /// Specifies the identifier for the consumer. The consumer tag is local to a
1999 /// connection, so two clients can use the same consumer tags. If this field is
2000 /// empty the server will generate a unique tag.
2003 string ConsumerTag { get; }
2004 // (no documentation)
2005 bool NoLocal { get; }
2006 // (no documentation)
2010 /// Request exclusive consumer access, meaning only this consumer can access the
2014 bool Exclusive { get; }
2017 /// If set, the server will not respond to the method. The client should not wait
2018 /// for a reply method. If the server could not complete the method it will raise a
2019 /// channel or connection exception.
2022 bool Nowait { get; }
2025 /// A set of filters for the consume. The syntax and semantics
2026 /// of these filters depends on the providers implementation.
2029 System.Collections.IDictionary Filter { get; }
2031 /// <summary>Autogenerated type. AMQP specification method "file.consume-ok".</summary>
2034 /// This method provides the client with a consumer tag which it MUST use in methods
2035 /// that work with the consumer.
2038 public interface IFileConsumeOk: IMethod {
2040 /// Holds the consumer tag specified by the client or provided by the server.
2042 string ConsumerTag { get; }
2044 /// <summary>Autogenerated type. AMQP specification method "file.cancel".</summary>
2047 /// This method cancels a consumer. This does not affect already delivered messages, but
2048 /// it does mean the server will not send any more messages for that consumer.
2051 public interface IFileCancel: IMethod {
2052 // (no documentation)
2053 string ConsumerTag { get; }
2056 /// If set, the server will not respond to the method. The client should not wait
2057 /// for a reply method. If the server could not complete the method it will raise a
2058 /// channel or connection exception.
2061 bool Nowait { get; }
2063 /// <summary>Autogenerated type. AMQP specification method "file.cancel-ok".</summary>
2065 /// This method confirms that the cancellation was completed.
2067 public interface IFileCancelOk: IMethod {
2068 // (no documentation)
2069 string ConsumerTag { get; }
2071 /// <summary>Autogenerated type. AMQP specification method "file.open".</summary>
2074 /// This method requests permission to start staging a message. Staging means sending
2075 /// the message into a temporary area at the recipient end and then delivering the
2076 /// message by referring to this temporary area. Staging is how the protocol handles
2077 /// partial file transfers - if a message is partially staged and the connection breaks,
2078 /// the next time the sender starts to stage it, it can restart from where it left off.
2081 public interface IFileOpen: IMethod {
2084 /// This is the staging identifier. This is an arbitrary string chosen by the
2085 /// sender. For staging to work correctly the sender must use the same staging
2086 /// identifier when staging the same message a second time after recovery from a
2087 /// failure. A good choice for the staging identifier would be the SHA1 hash of the
2088 /// message properties data (including the original filename, revised time, etc.).
2091 string Identifier { get; }
2094 /// The size of the content in octets. The recipient may use this information to
2095 /// allocate or check available space in advance, to avoid "disk full" errors during
2096 /// staging of very large messages.
2099 ulong ContentSize { get; }
2101 /// <summary>Autogenerated type. AMQP specification method "file.open-ok".</summary>
2104 /// This method confirms that the recipient is ready to accept staged data. If the
2105 /// message was already partially-staged at a previous time the recipient will report
2106 /// the number of octets already staged.
2109 public interface IFileOpenOk: IMethod {
2112 /// The amount of previously-staged content in octets. For a new message this will
2116 ulong StagedSize { get; }
2118 /// <summary>Autogenerated type. AMQP specification method "file.stage".</summary>
2121 /// This method stages the message, sending the message content to the recipient from
2122 /// the octet offset specified in the Open-Ok method.
2125 public interface IFileStage: IMethod {
2127 /// <summary>Autogenerated type. AMQP specification method "file.publish".</summary>
2130 /// This method publishes a staged file message to a specific exchange. The file message
2131 /// will be routed to queues as defined by the exchange configuration and distributed to
2132 /// any active consumers when the transaction, if any, is committed.
2135 public interface IFilePublish: IMethod {
2136 // (no documentation)
2137 ushort Ticket { get; }
2140 /// Specifies the name of the exchange to publish to. The exchange name can be
2141 /// empty, meaning the default exchange. If the exchange name is specified, and that
2142 /// exchange does not exist, the server will raise a channel exception.
2145 string Exchange { get; }
2148 /// Specifies the routing key for the message. The routing key is used for routing
2149 /// messages depending on the exchange configuration.
2152 string RoutingKey { get; }
2155 /// This flag tells the server how to react if the message cannot be routed to a
2156 /// queue. If this flag is set, the server will return an unroutable message with a
2157 /// Return method. If this flag is zero, the server silently drops the message.
2160 bool Mandatory { get; }
2163 /// This flag tells the server how to react if the message cannot be routed to a
2164 /// queue consumer immediately. If this flag is set, the server will return an
2165 /// undeliverable message with a Return method. If this flag is zero, the server
2166 /// will queue the message, but with no guarantee that it will ever be consumed.
2169 bool Immediate { get; }
2172 /// This is the staging identifier of the message to publish. The message must have
2173 /// been staged. Note that a client can send the Publish method asynchronously
2174 /// without waiting for staging to finish.
2177 string Identifier { get; }
2179 /// <summary>Autogenerated type. AMQP specification method "file.return".</summary>
2182 /// This method returns an undeliverable message that was published with the "immediate"
2183 /// flag set, or an unroutable message published with the "mandatory" flag set. The
2184 /// reply code and text provide information about the reason that the message was
2188 public interface IFileReturn: IMethod {
2189 // (no documentation)
2190 ushort ReplyCode { get; }
2191 // (no documentation)
2192 string ReplyText { get; }
2195 /// Specifies the name of the exchange that the message was originally published to.
2198 string Exchange { get; }
2200 /// Specifies the routing key name specified when the message was published.
2202 string RoutingKey { get; }
2204 /// <summary>Autogenerated type. AMQP specification method "file.deliver".</summary>
2207 /// This method delivers a staged file message to the client, via a consumer. In the
2208 /// asynchronous message delivery model, the client starts a consumer using the Consume
2209 /// method, then the server responds with Deliver methods as and when messages arrive
2210 /// for that consumer.
2213 public interface IFileDeliver: IMethod {
2214 // (no documentation)
2215 string ConsumerTag { get; }
2216 // (no documentation)
2217 ulong DeliveryTag { get; }
2218 // (no documentation)
2219 bool Redelivered { get; }
2222 /// Specifies the name of the exchange that the message was originally published to.
2225 string Exchange { get; }
2227 /// Specifies the routing key name specified when the message was published.
2229 string RoutingKey { get; }
2232 /// This is the staging identifier of the message to deliver. The message must have
2233 /// been staged. Note that a server can send the Deliver method asynchronously
2234 /// without waiting for staging to finish.
2237 string Identifier { get; }
2239 /// <summary>Autogenerated type. AMQP specification method "file.ack".</summary>
2242 /// This method acknowledges one or more messages delivered via the Deliver method. The
2243 /// client can ask to confirm a single message or a set of messages up to and including
2244 /// a specific message.
2247 public interface IFileAck: IMethod {
2248 // (no documentation)
2249 ulong DeliveryTag { get; }
2252 /// If set to 1, the delivery tag is treated as "up to and including", so that the
2253 /// client can acknowledge multiple messages with a single method. If set to zero,
2254 /// the delivery tag refers to a single message. If the multiple field is 1, and the
2255 /// delivery tag is zero, tells the server to acknowledge all outstanding messages.
2258 bool Multiple { get; }
2260 /// <summary>Autogenerated type. AMQP specification method "file.reject".</summary>
2263 /// This method allows a client to reject a message. It can be used to return
2264 /// untreatable messages to their original queue. Note that file content is staged
2265 /// before delivery, so the client will not use this method to interrupt delivery of a
2269 public interface IFileReject: IMethod {
2270 // (no documentation)
2271 ulong DeliveryTag { get; }
2274 /// If this field is zero, the message will be discarded. If this bit is 1, the
2275 /// server will attempt to requeue the message.
2278 bool Requeue { get; }
2280 /// <summary>Autogenerated type. AMQP specification method "stream.qos".</summary>
2283 /// This method requests a specific quality of service. The QoS can be specified for the
2284 /// current channel or for all channels on the connection. The particular properties and
2285 /// semantics of a qos method always depend on the content class semantics. Though the
2286 /// qos method could in principle apply to both peers, it is currently meaningful only
2290 public interface IStreamQos: IMethod {
2293 /// The client can request that messages be sent in advance so that when the client
2294 /// finishes processing a message, the following message is already held locally,
2295 /// rather than needing to be sent down the channel. Prefetching gives a performance
2296 /// improvement. This field specifies the prefetch window size in octets. May be set
2297 /// to zero, meaning "no specific limit". Note that other prefetch limits may still
2301 uint PrefetchSize { get; }
2304 /// Specifies a prefetch window in terms of whole messages. This field may be used
2305 /// in combination with the prefetch-size field; a message will only be sent in
2306 /// advance if both prefetch windows (and those at the channel and connection level)
2310 ushort PrefetchCount { get; }
2313 /// Specifies a desired transfer rate in octets per second. This is usually
2314 /// determined by the application that uses the streaming data. A value of zero
2315 /// means "no limit", i.e. as rapidly as possible.
2318 uint ConsumeRate { get; }
2321 /// By default the QoS settings apply to the current channel only. If this field is
2322 /// set, they are applied to the entire connection.
2325 bool Global { get; }
2327 /// <summary>Autogenerated type. AMQP specification method "stream.qos-ok".</summary>
2330 /// This method tells the client that the requested QoS levels could be handled by the
2331 /// server. The requested QoS applies to all active consumers until a new QoS is
2335 public interface IStreamQosOk: IMethod {
2337 /// <summary>Autogenerated type. AMQP specification method "stream.consume".</summary>
2340 /// This method asks the server to start a "consumer", which is a transient request for
2341 /// messages from a specific queue. Consumers last as long as the channel they were
2342 /// created on, or until the client cancels them.
2345 public interface IStreamConsume: IMethod {
2346 // (no documentation)
2347 ushort Ticket { get; }
2350 /// Specifies the name of the queue to consume from. If the queue name is null,
2351 /// refers to the current queue for the channel, which is the last declared queue.
2354 string Queue { get; }
2357 /// Specifies the identifier for the consumer. The consumer tag is local to a
2358 /// connection, so two clients can use the same consumer tags. If this field is
2359 /// empty the server will generate a unique tag.
2362 string ConsumerTag { get; }
2363 // (no documentation)
2364 bool NoLocal { get; }
2367 /// Request exclusive consumer access, meaning only this consumer can access the
2371 bool Exclusive { get; }
2374 /// If set, the server will not respond to the method. The client should not wait
2375 /// for a reply method. If the server could not complete the method it will raise a
2376 /// channel or connection exception.
2379 bool Nowait { get; }
2382 /// A set of filters for the consume. The syntax and semantics
2383 /// of these filters depends on the providers implementation.
2386 System.Collections.IDictionary Filter { get; }
2388 /// <summary>Autogenerated type. AMQP specification method "stream.consume-ok".</summary>
2391 /// This method provides the client with a consumer tag which it may use in methods that
2392 /// work with the consumer.
2395 public interface IStreamConsumeOk: IMethod {
2397 /// Holds the consumer tag specified by the client or provided by the server.
2399 string ConsumerTag { get; }
2401 /// <summary>Autogenerated type. AMQP specification method "stream.cancel".</summary>
2404 /// This method cancels a consumer. Since message delivery is asynchronous the client
2405 /// may continue to receive messages for a short while after cancelling a consumer. It
2406 /// may process or discard these as appropriate.
2409 public interface IStreamCancel: IMethod {
2410 // (no documentation)
2411 string ConsumerTag { get; }
2414 /// If set, the server will not respond to the method. The client should not wait
2415 /// for a reply method. If the server could not complete the method it will raise a
2416 /// channel or connection exception.
2419 bool Nowait { get; }
2421 /// <summary>Autogenerated type. AMQP specification method "stream.cancel-ok".</summary>
2423 /// This method confirms that the cancellation was completed.
2425 public interface IStreamCancelOk: IMethod {
2426 // (no documentation)
2427 string ConsumerTag { get; }
2429 /// <summary>Autogenerated type. AMQP specification method "stream.publish".</summary>
2432 /// This method publishes a message to a specific exchange. The message will be routed
2433 /// to queues as defined by the exchange configuration and distributed to any active
2434 /// consumers as appropriate.
2437 public interface IStreamPublish: IMethod {
2438 // (no documentation)
2439 ushort Ticket { get; }
2442 /// Specifies the name of the exchange to publish to. The exchange name can be
2443 /// empty, meaning the default exchange. If the exchange name is specified, and that
2444 /// exchange does not exist, the server will raise a channel exception.
2447 string Exchange { get; }
2450 /// Specifies the routing key for the message. The routing key is used for routing
2451 /// messages depending on the exchange configuration.
2454 string RoutingKey { get; }
2457 /// This flag tells the server how to react if the message cannot be routed to a
2458 /// queue. If this flag is set, the server will return an unroutable message with a
2459 /// Return method. If this flag is zero, the server silently drops the message.
2462 bool Mandatory { get; }
2465 /// This flag tells the server how to react if the message cannot be routed to a
2466 /// queue consumer immediately. If this flag is set, the server will return an
2467 /// undeliverable message with a Return method. If this flag is zero, the server
2468 /// will queue the message, but with no guarantee that it will ever be consumed.
2471 bool Immediate { get; }
2473 /// <summary>Autogenerated type. AMQP specification method "stream.return".</summary>
2476 /// This method returns an undeliverable message that was published with the "immediate"
2477 /// flag set, or an unroutable message published with the "mandatory" flag set. The
2478 /// reply code and text provide information about the reason that the message was
2482 public interface IStreamReturn: IMethod {
2483 // (no documentation)
2484 ushort ReplyCode { get; }
2485 // (no documentation)
2486 string ReplyText { get; }
2489 /// Specifies the name of the exchange that the message was originally published to.
2492 string Exchange { get; }
2494 /// Specifies the routing key name specified when the message was published.
2496 string RoutingKey { get; }
2498 /// <summary>Autogenerated type. AMQP specification method "stream.deliver".</summary>
2501 /// This method delivers a message to the client, via a consumer. In the asynchronous
2502 /// message delivery model, the client starts a consumer using the Consume method, then
2503 /// the server responds with Deliver methods as and when messages arrive for that
2507 public interface IStreamDeliver: IMethod {
2508 // (no documentation)
2509 string ConsumerTag { get; }
2510 // (no documentation)
2511 ulong DeliveryTag { get; }
2514 /// Specifies the name of the exchange that the message was originally published to.
2517 string Exchange { get; }
2520 /// Specifies the name of the queue that the message came from. Note that a single
2521 /// channel can start many consumers on different queues.
2524 string Queue { get; }
2526 /// <summary>Autogenerated type. AMQP specification method "tx.select".</summary>
2529 /// This method sets the channel to use standard transactions. The client must use this
2530 /// method at least once on a channel before using the Commit or Rollback methods.
2533 public interface ITxSelect: IMethod {
2535 /// <summary>Autogenerated type. AMQP specification method "tx.select-ok".</summary>
2538 /// This method confirms to the client that the channel was successfully set to use
2539 /// standard transactions.
2542 public interface ITxSelectOk: IMethod {
2544 /// <summary>Autogenerated type. AMQP specification method "tx.commit".</summary>
2547 /// This method commits all messages published and acknowledged in the current
2548 /// transaction. A new transaction starts immediately after a commit.
2551 public interface ITxCommit: IMethod {
2553 /// <summary>Autogenerated type. AMQP specification method "tx.commit-ok".</summary>
2556 /// This method confirms to the client that the commit succeeded. Note that if a commit
2557 /// fails, the server raises a channel exception.
2560 public interface ITxCommitOk: IMethod {
2562 /// <summary>Autogenerated type. AMQP specification method "tx.rollback".</summary>
2565 /// This method abandons all messages published and acknowledged in the current
2566 /// transaction. A new transaction starts immediately after a rollback.
2569 public interface ITxRollback: IMethod {
2571 /// <summary>Autogenerated type. AMQP specification method "tx.rollback-ok".</summary>
2574 /// This method confirms to the client that the rollback succeeded. Note that if an
2575 /// rollback fails, the server raises a channel exception.
2578 public interface ITxRollbackOk: IMethod {
2580 /// <summary>Autogenerated type. AMQP specification method "dtx.select".</summary>
2583 /// This method sets the channel to use distributed transactions. The client must use
2584 /// this method at least once on a channel before using the Start method.
2587 public interface IDtxSelect: IMethod {
2589 /// <summary>Autogenerated type. AMQP specification method "dtx.select-ok".</summary>
2592 /// This method confirms to the client that the channel was successfully set to use
2593 /// distributed transactions.
2596 public interface IDtxSelectOk: IMethod {
2598 /// <summary>Autogenerated type. AMQP specification method "dtx.start".</summary>
2601 /// This method starts a new distributed transaction. This must be the first method on a
2602 /// new channel that uses the distributed transaction mode, before any methods that
2603 /// publish or consume messages.
2606 public interface IDtxStart: IMethod {
2609 /// The distributed transaction key. This identifies the transaction so that the
2610 /// AMQP server can coordinate with the distributed transaction coordinator.
2613 string DtxIdentifier { get; }
2615 /// <summary>Autogenerated type. AMQP specification method "dtx.start-ok".</summary>
2618 /// This method confirms to the client that the transaction started. Note that if a
2619 /// start fails, the server raises a channel exception.
2622 public interface IDtxStartOk: IMethod {
2624 /// <summary>Autogenerated type. AMQP specification method "tunnel.request".</summary>
2627 /// This method tunnels a block of binary data, which can be an encoded
2628 /// AMQP method or other data. The binary data is sent as the content for
2629 /// the Tunnel.Request method.
2632 public interface ITunnelRequest: IMethod {
2635 /// This field table holds arbitrary meta-data that the sender needs to
2636 /// pass to the recipient.
2639 System.Collections.IDictionary MetaData { get; }
2641 /// <summary>Autogenerated type. AMQP specification method "message.transfer".</summary>
2644 /// [WORK IN PROGRESS] This method transfers a message between two peers. When a
2645 /// client uses this method to publish a message to a broker, the
2646 /// destination identifies a specific exchange. The message will
2647 /// then be routed to queues as defined by the exchange
2648 /// configuration and distributed to any active consumers when the
2649 /// transaction, if any, is committed.
2651 /// In the asynchronous message delivery model, the client starts
2652 /// a consumer using the Consume method and passing in a
2653 /// destination, then the broker responds with transfer methods to
2654 /// the specified destination as and when messages arrive for that
2657 /// If synchronous message delivery is required, the client may
2658 /// issue a get request which on success causes a single message
2659 /// to be transferred to the specified destination.
2661 /// Message acknowledgement is signalled by the return result of
2665 public interface IMessageTransfer: IMethod {
2666 // (no documentation)
2667 ushort Ticket { get; }
2670 /// Specifies the destination to which the message is to be
2671 /// transferred. The destination can be empty, meaning the
2672 /// default exchange or consumer. If the destination is
2673 /// specified, and that exchange or consumer does not exist, the
2674 /// peer must raise a channel exception.
2677 string Destination { get; }
2678 // (no documentation)
2679 bool Redelivered { get; }
2682 /// This flag tells the server how to react if the message
2683 /// cannot be routed to a queue consumer immediately. If this
2684 /// flag is set, the server will reject the message. If this
2685 /// flag is zero, the server will queue the message, but with no
2686 /// guarantee that it will ever be consumed.
2689 bool Immediate { get; }
2692 /// If this is set to a non zero value then a message expiration
2693 /// time will be computed based on the current time plus this
2694 /// value. Messages that live longer than their expiration time
2695 /// will be discarded (or dead lettered).
2699 // (no documentation)
2700 byte Priority { get; }
2703 /// Set on arrival by the broker.
2706 AmqpTimestamp Timestamp { get; }
2707 // (no documentation)
2708 byte DeliveryMode { get; }
2711 /// The expiration header assigned by the broker. After
2712 /// receiving the message the broker sets expiration to the sum
2713 /// of the ttl specified in the publish method and the current
2714 /// time. (ttl = expiration - timestamp)
2717 AmqpTimestamp Expiration { get; }
2718 // (no documentation)
2719 string Exchange { get; }
2720 // (no documentation)
2721 string RoutingKey { get; }
2722 // (no documentation)
2723 string MessageId { get; }
2724 // (no documentation)
2725 string CorrelationId { get; }
2726 // (no documentation)
2727 string ReplyTo { get; }
2728 // (no documentation)
2729 string ContentType { get; }
2730 // (no documentation)
2731 string ContentEncoding { get; }
2732 // (no documentation)
2733 string UserId { get; }
2734 // (no documentation)
2735 string AppId { get; }
2736 // (no documentation)
2737 string TransactionId { get; }
2738 // (no documentation)
2739 byte[] SecurityToken { get; }
2740 // (no documentation)
2741 System.Collections.IDictionary ApplicationHeaders { get; }
2742 // (no documentation)
2743 byte[] Body { get; }
2745 /// <summary>Autogenerated type. AMQP specification method "message.consume".</summary>
2748 /// [WORK IN PROGRESS] This method asks the server to start a "consumer", which is a transient request for
2749 /// messages from a specific queue. Consumers last as long as the channel they were
2750 /// created on, or until the client cancels them.
2753 public interface IMessageConsume: IMethod {
2754 // (no documentation)
2755 ushort Ticket { get; }
2758 /// Specifies the name of the queue to consume from. If the queue name is null,
2759 /// refers to the current queue for the channel, which is the last declared queue.
2762 string Queue { get; }
2765 /// Specifies the destination for the consumer. The destination is local to a
2766 /// connection, so two clients can use the same destination.
2769 string Destination { get; }
2770 // (no documentation)
2771 bool NoLocal { get; }
2772 // (no documentation)
2776 /// Request exclusive consumer access, meaning only this consumer can access the
2780 bool Exclusive { get; }
2783 /// A set of filters for the consume. The syntax and semantics
2784 /// of these filters depends on the providers implementation.
2787 System.Collections.IDictionary Filter { get; }
2789 /// <summary>Autogenerated type. AMQP specification method "message.cancel".</summary>
2792 /// [WORK IN PROGRESS] This method cancels a consumer. This does not affect already delivered
2793 /// messages, but it does mean the server will not send any more messages for
2794 /// that consumer. The client may receive an arbitrary number of messages in
2795 /// between sending the cancel method and receiving the cancel-ok reply.
2798 public interface IMessageCancel: IMethod {
2799 // (no documentation)
2800 string Destination { get; }
2802 /// <summary>Autogenerated type. AMQP specification method "message.get".</summary>
2805 /// [WORK IN PROGRESS] This method provides a direct access to the messages in a queue using a synchronous
2806 /// dialogue that is designed for specific types of application where synchronous
2807 /// functionality is more important than performance.
2810 public interface IMessageGet: IMethod {
2811 // (no documentation)
2812 ushort Ticket { get; }
2815 /// Specifies the name of the queue to consume from. If the queue name is null,
2816 /// refers to the current queue for the channel, which is the last declared queue.
2819 string Queue { get; }
2822 /// On normal completion of the get request (i.e. a response of
2823 /// ok). A message will be transferred to the supplied destination.
2826 string Destination { get; }
2827 // (no documentation)
2830 /// <summary>Autogenerated type. AMQP specification method "message.recover".</summary>
2833 /// [WORK IN PROGRESS] This method asks the broker to redeliver all unacknowledged
2834 /// messages on a specified channel. Zero or more messages may be
2835 /// redelivered. This method is only allowed on non-transacted
2839 public interface IMessageRecover: IMethod {
2842 /// If this field is zero, the message will be redelivered to
2843 /// the original recipient. If this bit is 1, the server will
2844 /// attempt to requeue the message, potentially then delivering
2845 /// it to an alternative subscriber.
2848 bool Requeue { get; }
2850 /// <summary>Autogenerated type. AMQP specification method "message.open".</summary>
2853 /// [WORK IN PROGRESS] This method creates a reference. A references provides a means
2854 /// to send a message body into a temporary area at the recipient
2855 /// end and then deliver the message by referring to this
2856 /// temporary area. This is how the protocol handles large message
2859 /// The scope of a ref is defined to be between calls to
2860 /// open (or resume) and close. Between these points it is valid
2861 /// for a ref to be used from any content data type, and so the
2862 /// receiver must hold onto its contents. Should the channel be
2863 /// closed when a ref is still in scope, the receiver may discard
2864 /// its contents (unless it is checkpointed). A ref that is in
2865 /// scope is considered open.
2868 public interface IMessageOpen: IMethod {
2869 // (no documentation)
2870 byte[] Reference { get; }
2872 /// <summary>Autogenerated type. AMQP specification method "message.close".</summary>
2875 /// [WORK IN PROGRESS] This method signals the recipient that no more data will be
2876 /// appended to the reference.
2879 public interface IMessageClose: IMethod {
2880 // (no documentation)
2881 byte[] Reference { get; }
2883 /// <summary>Autogenerated type. AMQP specification method "message.append".</summary>
2886 /// [WORK IN PROGRESS] This method appends data to a reference.
2889 public interface IMessageAppend: IMethod {
2890 // (no documentation)
2891 byte[] Reference { get; }
2892 // (no documentation)
2893 byte[] Bytes { get; }
2895 /// <summary>Autogenerated type. AMQP specification method "message.checkpoint".</summary>
2898 /// [WORK IN PROGRESS] This method provides a means to checkpoint large message
2899 /// transfer. The sender may ask the recipient to checkpoint the
2900 /// contents of a reference using the supplied identifier. The
2901 /// sender may then resume the transfer at a later point. It is at
2902 /// the discretion of the recipient how much data to save with the
2903 /// checkpoint, and the sender MUST honour the offset returned by
2904 /// the resume method.
2907 public interface IMessageCheckpoint: IMethod {
2908 // (no documentation)
2909 byte[] Reference { get; }
2912 /// This is the checkpoint identifier. This is an arbitrary
2913 /// string chosen by the sender. For checkpointing to work
2914 /// correctly the sender must use the same checkpoint identifier
2915 /// when resuming the message. A good choice for the checkpoint
2916 /// identifier would be the SHA1 hash of the message properties
2917 /// data (including the original filename, revised time, etc.).
2920 string Identifier { get; }
2922 /// <summary>Autogenerated type. AMQP specification method "message.resume".</summary>
2925 /// [WORK IN PROGRESS] This method resumes a reference from the last checkpoint. A
2926 /// reference is considered to be open (in scope) after a resume
2927 /// even though it will not have been opened via the open method
2928 /// during this session.
2931 public interface IMessageResume: IMethod {
2932 // (no documentation)
2933 byte[] Reference { get; }
2934 // (no documentation)
2935 string Identifier { get; }
2937 /// <summary>Autogenerated type. AMQP specification method "message.qos".</summary>
2940 /// [WORK IN PROGRESS] This method requests a specific quality of service. The QoS can be specified for the
2941 /// current channel or for all channels on the connection. The particular properties and
2942 /// semantics of a qos method always depend on the content class semantics. Though the
2943 /// qos method could in principle apply to both peers, it is currently meaningful only
2947 public interface IMessageQos: IMethod {
2950 /// The client can request that messages be sent in advance so that when the client
2951 /// finishes processing a message, the following message is already held locally,
2952 /// rather than needing to be sent down the channel. Prefetching gives a performance
2953 /// improvement. This field specifies the prefetch window size in octets. The server
2954 /// will send a message in advance if it is equal to or smaller in size than the
2955 /// available prefetch size (and also falls into other prefetch limits). May be set
2956 /// to zero, meaning "no specific limit", although other prefetch limits may still
2957 /// apply. The prefetch-size is ignored if the no-ack option is set.
2960 uint PrefetchSize { get; }
2963 /// Specifies a prefetch window in terms of whole messages. This field may be used
2964 /// in combination with the prefetch-size field; a message will only be sent in
2965 /// advance if both prefetch windows (and those at the channel and connection level)
2966 /// allow it. The prefetch-count is ignored if the no-ack option is set.
2969 ushort PrefetchCount { get; }
2972 /// By default the QoS settings apply to the current channel only. If this field is
2973 /// set, they are applied to the entire connection.
2976 bool Global { get; }
2978 /// <summary>Autogenerated type. AMQP specification method "message.ok".</summary>
2981 /// [WORK IN PROGRESS] Signals the normal completion of a method.
2984 public interface IMessageOk: IMethod {
2986 /// <summary>Autogenerated type. AMQP specification method "message.empty".</summary>
2989 /// [WORK IN PROGRESS] Signals that a queue does not contain any messages.
2992 public interface IMessageEmpty: IMethod {
2994 /// <summary>Autogenerated type. AMQP specification method "message.reject".</summary>
2997 /// [WORK IN PROGRESS] This response rejects a message. A message may be rejected for
2998 /// a number of reasons.
3001 public interface IMessageReject: IMethod {
3002 // (no documentation)
3003 ushort Code { get; }
3004 // (no documentation)
3005 string Text { get; }
3007 /// <summary>Autogenerated type. AMQP specification method "message.offset".</summary>
3010 /// [WORK IN PROGRESS] Returns the data offset into a reference body.
3013 public interface IMessageOffset: IMethod {
3014 // (no documentation)
3015 ulong Value { get; }
3017 /// <summary>Autogenerated type. AMQP specification content header properties for content class "basic"</summary>
3020 /// The Basic class provides methods that support an industry-standard messaging model.
3023 public class BasicProperties: RabbitMQ.Client.Impl.BasicProperties {
3024 private string m_contentType;
3025 private string m_contentEncoding;
3026 private System.Collections.IDictionary m_headers;
3027 private byte m_deliveryMode;
3028 private byte m_priority;
3029 private string m_correlationId;
3030 private string m_replyTo;
3031 private string m_expiration;
3032 private string m_messageId;
3033 private AmqpTimestamp m_timestamp;
3034 private string m_type;
3035 private string m_userId;
3036 private string m_appId;
3037 private string m_clusterId;
3039 private bool contentType_present = false;
3040 private bool contentEncoding_present = false;
3041 private bool headers_present = false;
3042 private bool deliveryMode_present = false;
3043 private bool priority_present = false;
3044 private bool correlationId_present = false;
3045 private bool replyTo_present = false;
3046 private bool expiration_present = false;
3047 private bool messageId_present = false;
3048 private bool timestamp_present = false;
3049 private bool type_present = false;
3050 private bool userId_present = false;
3051 private bool appId_present = false;
3052 private bool clusterId_present = false;
3055 /// MIME content type
3057 public override string ContentType {
3059 return m_contentType;
3062 contentType_present = true;
3063 m_contentType = value;
3067 /// MIME content encoding
3069 public override string ContentEncoding {
3071 return m_contentEncoding;
3074 contentEncoding_present = true;
3075 m_contentEncoding = value;
3079 /// message header field table
3081 public override System.Collections.IDictionary Headers {
3086 headers_present = true;
3091 /// non-persistent (1) or persistent (2)
3093 public override byte DeliveryMode {
3095 return m_deliveryMode;
3098 deliveryMode_present = true;
3099 m_deliveryMode = value;
3103 /// message priority, 0 to 9
3105 public override byte Priority {
3110 priority_present = true;
3115 /// application correlation identifier
3117 public override string CorrelationId {
3119 return m_correlationId;
3122 correlationId_present = true;
3123 m_correlationId = value;
3127 /// destination to reply to
3129 public override string ReplyTo {
3134 replyTo_present = true;
3139 /// message expiration specification
3141 public override string Expiration {
3143 return m_expiration;
3146 expiration_present = true;
3147 m_expiration = value;
3151 /// application message identifier
3153 public override string MessageId {
3158 messageId_present = true;
3159 m_messageId = value;
3163 /// message timestamp
3165 public override AmqpTimestamp Timestamp {
3170 timestamp_present = true;
3171 m_timestamp = value;
3175 /// message type name
3177 public override string Type {
3182 type_present = true;
3187 /// creating user id
3189 public override string UserId {
3194 userId_present = true;
3199 /// creating application id
3201 public override string AppId {
3206 appId_present = true;
3211 /// intra-cluster routing identifier
3213 public override string ClusterId {
3218 clusterId_present = true;
3219 m_clusterId = value;
3223 public override void ClearContentType() { contentType_present = false; }
3224 public override void ClearContentEncoding() { contentEncoding_present = false; }
3225 public override void ClearHeaders() { headers_present = false; }
3226 public override void ClearDeliveryMode() { deliveryMode_present = false; }
3227 public override void ClearPriority() { priority_present = false; }
3228 public override void ClearCorrelationId() { correlationId_present = false; }
3229 public override void ClearReplyTo() { replyTo_present = false; }
3230 public override void ClearExpiration() { expiration_present = false; }
3231 public override void ClearMessageId() { messageId_present = false; }
3232 public override void ClearTimestamp() { timestamp_present = false; }
3233 public override void ClearType() { type_present = false; }
3234 public override void ClearUserId() { userId_present = false; }
3235 public override void ClearAppId() { appId_present = false; }
3236 public override void ClearClusterId() { clusterId_present = false; }
3238 public BasicProperties() {}
3239 public override int ProtocolClassId { get { return 60; } }
3240 public override string ProtocolClassName { get { return "basic"; } }
3242 public override void ReadPropertiesFrom(RabbitMQ.Client.Impl.ContentHeaderPropertyReader reader) {
3243 contentType_present = reader.ReadPresence();
3244 contentEncoding_present = reader.ReadPresence();
3245 headers_present = reader.ReadPresence();
3246 deliveryMode_present = reader.ReadPresence();
3247 priority_present = reader.ReadPresence();
3248 correlationId_present = reader.ReadPresence();
3249 replyTo_present = reader.ReadPresence();
3250 expiration_present = reader.ReadPresence();
3251 messageId_present = reader.ReadPresence();
3252 timestamp_present = reader.ReadPresence();
3253 type_present = reader.ReadPresence();
3254 userId_present = reader.ReadPresence();
3255 appId_present = reader.ReadPresence();
3256 clusterId_present = reader.ReadPresence();
3257 reader.FinishPresence();
3258 if (contentType_present) { m_contentType = reader.ReadShortstr(); }
3259 if (contentEncoding_present) { m_contentEncoding = reader.ReadShortstr(); }
3260 if (headers_present) { m_headers = reader.ReadTable(); }
3261 if (deliveryMode_present) { m_deliveryMode = reader.ReadOctet(); }
3262 if (priority_present) { m_priority = reader.ReadOctet(); }
3263 if (correlationId_present) { m_correlationId = reader.ReadShortstr(); }
3264 if (replyTo_present) { m_replyTo = reader.ReadShortstr(); }
3265 if (expiration_present) { m_expiration = reader.ReadShortstr(); }
3266 if (messageId_present) { m_messageId = reader.ReadShortstr(); }
3267 if (timestamp_present) { m_timestamp = reader.ReadTimestamp(); }
3268 if (type_present) { m_type = reader.ReadShortstr(); }
3269 if (userId_present) { m_userId = reader.ReadShortstr(); }
3270 if (appId_present) { m_appId = reader.ReadShortstr(); }
3271 if (clusterId_present) { m_clusterId = reader.ReadShortstr(); }
3274 public override void WritePropertiesTo(RabbitMQ.Client.Impl.ContentHeaderPropertyWriter writer) {
3275 writer.WritePresence(contentType_present);
3276 writer.WritePresence(contentEncoding_present);
3277 writer.WritePresence(headers_present);
3278 writer.WritePresence(deliveryMode_present);
3279 writer.WritePresence(priority_present);
3280 writer.WritePresence(correlationId_present);
3281 writer.WritePresence(replyTo_present);
3282 writer.WritePresence(expiration_present);
3283 writer.WritePresence(messageId_present);
3284 writer.WritePresence(timestamp_present);
3285 writer.WritePresence(type_present);
3286 writer.WritePresence(userId_present);
3287 writer.WritePresence(appId_present);
3288 writer.WritePresence(clusterId_present);
3289 writer.FinishPresence();
3290 if (contentType_present) { writer.WriteShortstr(m_contentType); }
3291 if (contentEncoding_present) { writer.WriteShortstr(m_contentEncoding); }
3292 if (headers_present) { writer.WriteTable(m_headers); }
3293 if (deliveryMode_present) { writer.WriteOctet(m_deliveryMode); }
3294 if (priority_present) { writer.WriteOctet(m_priority); }
3295 if (correlationId_present) { writer.WriteShortstr(m_correlationId); }
3296 if (replyTo_present) { writer.WriteShortstr(m_replyTo); }
3297 if (expiration_present) { writer.WriteShortstr(m_expiration); }
3298 if (messageId_present) { writer.WriteShortstr(m_messageId); }
3299 if (timestamp_present) { writer.WriteTimestamp(m_timestamp); }
3300 if (type_present) { writer.WriteShortstr(m_type); }
3301 if (userId_present) { writer.WriteShortstr(m_userId); }
3302 if (appId_present) { writer.WriteShortstr(m_appId); }
3303 if (clusterId_present) { writer.WriteShortstr(m_clusterId); }
3306 public override void AppendPropertyDebugStringTo(System.Text.StringBuilder sb) {
3308 sb.Append("content-type="); sb.Append(contentType_present ? (m_contentType == null ? "(null)" : m_contentType.ToString()) : "_"); sb.Append(", ");
3309 sb.Append("content-encoding="); sb.Append(contentEncoding_present ? (m_contentEncoding == null ? "(null)" : m_contentEncoding.ToString()) : "_"); sb.Append(", ");
3310 sb.Append("headers="); sb.Append(headers_present ? (m_headers == null ? "(null)" : m_headers.ToString()) : "_"); sb.Append(", ");
3311 sb.Append("delivery-mode="); sb.Append(deliveryMode_present ? m_deliveryMode.ToString() : "_"); sb.Append(", ");
3312 sb.Append("priority="); sb.Append(priority_present ? m_priority.ToString() : "_"); sb.Append(", ");
3313 sb.Append("correlation-id="); sb.Append(correlationId_present ? (m_correlationId == null ? "(null)" : m_correlationId.ToString()) : "_"); sb.Append(", ");
3314 sb.Append("reply-to="); sb.Append(replyTo_present ? (m_replyTo == null ? "(null)" : m_replyTo.ToString()) : "_"); sb.Append(", ");
3315 sb.Append("expiration="); sb.Append(expiration_present ? (m_expiration == null ? "(null)" : m_expiration.ToString()) : "_"); sb.Append(", ");
3316 sb.Append("message-id="); sb.Append(messageId_present ? (m_messageId == null ? "(null)" : m_messageId.ToString()) : "_"); sb.Append(", ");
3317 sb.Append("timestamp="); sb.Append(timestamp_present ? m_timestamp.ToString() : "_"); sb.Append(", ");
3318 sb.Append("type="); sb.Append(type_present ? (m_type == null ? "(null)" : m_type.ToString()) : "_"); sb.Append(", ");
3319 sb.Append("user-id="); sb.Append(userId_present ? (m_userId == null ? "(null)" : m_userId.ToString()) : "_"); sb.Append(", ");
3320 sb.Append("app-id="); sb.Append(appId_present ? (m_appId == null ? "(null)" : m_appId.ToString()) : "_"); sb.Append(", ");
3321 sb.Append("cluster-id="); sb.Append(clusterId_present ? (m_clusterId == null ? "(null)" : m_clusterId.ToString()) : "_");
3325 /// <summary>Autogenerated type. AMQP specification content header properties for content class "file"</summary>
3328 /// The file class provides methods that support reliable file transfer. File
3329 /// messages have a specific set of properties that are required for interoperability
3330 /// with file transfer applications. File messages and acknowledgements are subject to
3331 /// channel transactions. Note that the file class does not provide message browsing
3332 /// methods; these are not compatible with the staging model. Applications that need
3333 /// browsable file transfer should use Basic content and the Basic class.
3336 public class FileProperties: RabbitMQ.Client.Impl.FileProperties {
3337 private string m_contentType;
3338 private string m_contentEncoding;
3339 private System.Collections.IDictionary m_headers;
3340 private byte m_priority;
3341 private string m_replyTo;
3342 private string m_messageId;
3343 private string m_filename;
3344 private AmqpTimestamp m_timestamp;
3345 private string m_clusterId;
3347 private bool contentType_present = false;
3348 private bool contentEncoding_present = false;
3349 private bool headers_present = false;
3350 private bool priority_present = false;
3351 private bool replyTo_present = false;
3352 private bool messageId_present = false;
3353 private bool filename_present = false;
3354 private bool timestamp_present = false;
3355 private bool clusterId_present = false;
3358 /// MIME content type
3360 public override string ContentType {
3362 return m_contentType;
3365 contentType_present = true;
3366 m_contentType = value;
3370 /// MIME content encoding
3372 public override string ContentEncoding {
3374 return m_contentEncoding;
3377 contentEncoding_present = true;
3378 m_contentEncoding = value;
3382 /// message header field table
3384 public override System.Collections.IDictionary Headers {
3389 headers_present = true;
3394 /// message priority, 0 to 9
3396 public override byte Priority {
3401 priority_present = true;
3406 /// destination to reply to
3408 public override string ReplyTo {
3413 replyTo_present = true;
3418 /// application message identifier
3420 public override string MessageId {
3425 messageId_present = true;
3426 m_messageId = value;
3430 /// message filename
3432 public override string Filename {
3437 filename_present = true;
3442 /// message timestamp
3444 public override AmqpTimestamp Timestamp {
3449 timestamp_present = true;
3450 m_timestamp = value;
3454 /// intra-cluster routing identifier
3456 public override string ClusterId {
3461 clusterId_present = true;
3462 m_clusterId = value;
3466 public override void ClearContentType() { contentType_present = false; }
3467 public override void ClearContentEncoding() { contentEncoding_present = false; }
3468 public override void ClearHeaders() { headers_present = false; }
3469 public override void ClearPriority() { priority_present = false; }
3470 public override void ClearReplyTo() { replyTo_present = false; }
3471 public override void ClearMessageId() { messageId_present = false; }
3472 public override void ClearFilename() { filename_present = false; }
3473 public override void ClearTimestamp() { timestamp_present = false; }
3474 public override void ClearClusterId() { clusterId_present = false; }
3476 public FileProperties() {}
3477 public override int ProtocolClassId { get { return 70; } }
3478 public override string ProtocolClassName { get { return "file"; } }
3480 public override void ReadPropertiesFrom(RabbitMQ.Client.Impl.ContentHeaderPropertyReader reader) {
3481 contentType_present = reader.ReadPresence();
3482 contentEncoding_present = reader.ReadPresence();
3483 headers_present = reader.ReadPresence();
3484 priority_present = reader.ReadPresence();
3485 replyTo_present = reader.ReadPresence();
3486 messageId_present = reader.ReadPresence();
3487 filename_present = reader.ReadPresence();
3488 timestamp_present = reader.ReadPresence();
3489 clusterId_present = reader.ReadPresence();
3490 reader.FinishPresence();
3491 if (contentType_present) { m_contentType = reader.ReadShortstr(); }
3492 if (contentEncoding_present) { m_contentEncoding = reader.ReadShortstr(); }
3493 if (headers_present) { m_headers = reader.ReadTable(); }
3494 if (priority_present) { m_priority = reader.ReadOctet(); }
3495 if (replyTo_present) { m_replyTo = reader.ReadShortstr(); }
3496 if (messageId_present) { m_messageId = reader.ReadShortstr(); }
3497 if (filename_present) { m_filename = reader.ReadShortstr(); }
3498 if (timestamp_present) { m_timestamp = reader.ReadTimestamp(); }
3499 if (clusterId_present) { m_clusterId = reader.ReadShortstr(); }
3502 public override void WritePropertiesTo(RabbitMQ.Client.Impl.ContentHeaderPropertyWriter writer) {
3503 writer.WritePresence(contentType_present);
3504 writer.WritePresence(contentEncoding_present);
3505 writer.WritePresence(headers_present);
3506 writer.WritePresence(priority_present);
3507 writer.WritePresence(replyTo_present);
3508 writer.WritePresence(messageId_present);
3509 writer.WritePresence(filename_present);
3510 writer.WritePresence(timestamp_present);
3511 writer.WritePresence(clusterId_present);
3512 writer.FinishPresence();
3513 if (contentType_present) { writer.WriteShortstr(m_contentType); }
3514 if (contentEncoding_present) { writer.WriteShortstr(m_contentEncoding); }
3515 if (headers_present) { writer.WriteTable(m_headers); }
3516 if (priority_present) { writer.WriteOctet(m_priority); }
3517 if (replyTo_present) { writer.WriteShortstr(m_replyTo); }
3518 if (messageId_present) { writer.WriteShortstr(m_messageId); }
3519 if (filename_present) { writer.WriteShortstr(m_filename); }
3520 if (timestamp_present) { writer.WriteTimestamp(m_timestamp); }
3521 if (clusterId_present) { writer.WriteShortstr(m_clusterId); }
3524 public override void AppendPropertyDebugStringTo(System.Text.StringBuilder sb) {
3526 sb.Append("content-type="); sb.Append(contentType_present ? (m_contentType == null ? "(null)" : m_contentType.ToString()) : "_"); sb.Append(", ");
3527 sb.Append("content-encoding="); sb.Append(contentEncoding_present ? (m_contentEncoding == null ? "(null)" : m_contentEncoding.ToString()) : "_"); sb.Append(", ");
3528 sb.Append("headers="); sb.Append(headers_present ? (m_headers == null ? "(null)" : m_headers.ToString()) : "_"); sb.Append(", ");
3529 sb.Append("priority="); sb.Append(priority_present ? m_priority.ToString() : "_"); sb.Append(", ");
3530 sb.Append("reply-to="); sb.Append(replyTo_present ? (m_replyTo == null ? "(null)" : m_replyTo.ToString()) : "_"); sb.Append(", ");
3531 sb.Append("message-id="); sb.Append(messageId_present ? (m_messageId == null ? "(null)" : m_messageId.ToString()) : "_"); sb.Append(", ");
3532 sb.Append("filename="); sb.Append(filename_present ? (m_filename == null ? "(null)" : m_filename.ToString()) : "_"); sb.Append(", ");
3533 sb.Append("timestamp="); sb.Append(timestamp_present ? m_timestamp.ToString() : "_"); sb.Append(", ");
3534 sb.Append("cluster-id="); sb.Append(clusterId_present ? (m_clusterId == null ? "(null)" : m_clusterId.ToString()) : "_");
3538 /// <summary>Autogenerated type. AMQP specification content header properties for content class "stream"</summary>
3541 /// The stream class provides methods that support multimedia streaming. The stream class
3542 /// uses the following semantics: one message is one packet of data; delivery is
3543 /// unacknowledged and unreliable; the consumer can specify quality of service parameters
3544 /// that the server can try to adhere to; lower-priority messages may be discarded in favour
3545 /// of high priority messages.
3548 public class StreamProperties: RabbitMQ.Client.Impl.StreamProperties {
3549 private string m_contentType;
3550 private string m_contentEncoding;
3551 private System.Collections.IDictionary m_headers;
3552 private byte m_priority;
3553 private AmqpTimestamp m_timestamp;
3555 private bool contentType_present = false;
3556 private bool contentEncoding_present = false;
3557 private bool headers_present = false;
3558 private bool priority_present = false;
3559 private bool timestamp_present = false;
3562 /// MIME content type
3564 public override string ContentType {
3566 return m_contentType;
3569 contentType_present = true;
3570 m_contentType = value;
3574 /// MIME content encoding
3576 public override string ContentEncoding {
3578 return m_contentEncoding;
3581 contentEncoding_present = true;
3582 m_contentEncoding = value;
3586 /// message header field table
3588 public override System.Collections.IDictionary Headers {
3593 headers_present = true;
3598 /// message priority, 0 to 9
3600 public override byte Priority {
3605 priority_present = true;
3610 /// message timestamp
3612 public override AmqpTimestamp Timestamp {
3617 timestamp_present = true;
3618 m_timestamp = value;
3622 public override void ClearContentType() { contentType_present = false; }
3623 public override void ClearContentEncoding() { contentEncoding_present = false; }
3624 public override void ClearHeaders() { headers_present = false; }
3625 public override void ClearPriority() { priority_present = false; }
3626 public override void ClearTimestamp() { timestamp_present = false; }
3628 public StreamProperties() {}
3629 public override int ProtocolClassId { get { return 80; } }
3630 public override string ProtocolClassName { get { return "stream"; } }
3632 public override void ReadPropertiesFrom(RabbitMQ.Client.Impl.ContentHeaderPropertyReader reader) {
3633 contentType_present = reader.ReadPresence();
3634 contentEncoding_present = reader.ReadPresence();
3635 headers_present = reader.ReadPresence();
3636 priority_present = reader.ReadPresence();
3637 timestamp_present = reader.ReadPresence();
3638 reader.FinishPresence();
3639 if (contentType_present) { m_contentType = reader.ReadShortstr(); }
3640 if (contentEncoding_present) { m_contentEncoding = reader.ReadShortstr(); }
3641 if (headers_present) { m_headers = reader.ReadTable(); }
3642 if (priority_present) { m_priority = reader.ReadOctet(); }
3643 if (timestamp_present) { m_timestamp = reader.ReadTimestamp(); }
3646 public override void WritePropertiesTo(RabbitMQ.Client.Impl.ContentHeaderPropertyWriter writer) {
3647 writer.WritePresence(contentType_present);
3648 writer.WritePresence(contentEncoding_present);
3649 writer.WritePresence(headers_present);
3650 writer.WritePresence(priority_present);
3651 writer.WritePresence(timestamp_present);
3652 writer.FinishPresence();
3653 if (contentType_present) { writer.WriteShortstr(m_contentType); }
3654 if (contentEncoding_present) { writer.WriteShortstr(m_contentEncoding); }
3655 if (headers_present) { writer.WriteTable(m_headers); }
3656 if (priority_present) { writer.WriteOctet(m_priority); }
3657 if (timestamp_present) { writer.WriteTimestamp(m_timestamp); }
3660 public override void AppendPropertyDebugStringTo(System.Text.StringBuilder sb) {
3662 sb.Append("content-type="); sb.Append(contentType_present ? (m_contentType == null ? "(null)" : m_contentType.ToString()) : "_"); sb.Append(", ");
3663 sb.Append("content-encoding="); sb.Append(contentEncoding_present ? (m_contentEncoding == null ? "(null)" : m_contentEncoding.ToString()) : "_"); sb.Append(", ");
3664 sb.Append("headers="); sb.Append(headers_present ? (m_headers == null ? "(null)" : m_headers.ToString()) : "_"); sb.Append(", ");
3665 sb.Append("priority="); sb.Append(priority_present ? m_priority.ToString() : "_"); sb.Append(", ");
3666 sb.Append("timestamp="); sb.Append(timestamp_present ? m_timestamp.ToString() : "_");
3670 /// <summary>Autogenerated type. AMQP specification content header properties for content class "tunnel"</summary>
3673 /// The tunnel methods are used to send blocks of binary data - which can be serialised AMQP
3674 /// methods or other protocol frames - between AMQP peers.
3677 public class TunnelProperties: RabbitMQ.Client.Impl.ContentHeaderBase {
3678 private System.Collections.IDictionary m_headers;
3679 private string m_proxyName;
3680 private string m_dataName;
3681 private byte m_durable;
3682 private byte m_broadcast;
3684 private bool headers_present = false;
3685 private bool proxyName_present = false;
3686 private bool dataName_present = false;
3687 private bool durable_present = false;
3688 private bool broadcast_present = false;
3691 /// message header field table
3693 public System.Collections.IDictionary Headers {
3698 headers_present = true;
3703 /// identity of tunnelling proxy
3705 public string ProxyName {
3710 proxyName_present = true;
3711 m_proxyName = value;
3715 /// name or type of message being tunnelled
3717 public string DataName {
3722 dataName_present = true;
3727 /// message durability indicator
3729 public byte Durable {
3734 durable_present = true;
3739 /// message broadcast mode
3741 public byte Broadcast {
3746 broadcast_present = true;
3747 m_broadcast = value;
3751 public void ClearHeaders() { headers_present = false; }
3752 public void ClearProxyName() { proxyName_present = false; }
3753 public void ClearDataName() { dataName_present = false; }
3754 public void ClearDurable() { durable_present = false; }
3755 public void ClearBroadcast() { broadcast_present = false; }
3757 public TunnelProperties() {}
3758 public override int ProtocolClassId { get { return 110; } }
3759 public override string ProtocolClassName { get { return "tunnel"; } }
3761 public override void ReadPropertiesFrom(RabbitMQ.Client.Impl.ContentHeaderPropertyReader reader) {
3762 headers_present = reader.ReadPresence();
3763 proxyName_present = reader.ReadPresence();
3764 dataName_present = reader.ReadPresence();
3765 durable_present = reader.ReadPresence();
3766 broadcast_present = reader.ReadPresence();
3767 reader.FinishPresence();
3768 if (headers_present) { m_headers = reader.ReadTable(); }
3769 if (proxyName_present) { m_proxyName = reader.ReadShortstr(); }
3770 if (dataName_present) { m_dataName = reader.ReadShortstr(); }
3771 if (durable_present) { m_durable = reader.ReadOctet(); }
3772 if (broadcast_present) { m_broadcast = reader.ReadOctet(); }
3775 public override void WritePropertiesTo(RabbitMQ.Client.Impl.ContentHeaderPropertyWriter writer) {
3776 writer.WritePresence(headers_present);
3777 writer.WritePresence(proxyName_present);
3778 writer.WritePresence(dataName_present);
3779 writer.WritePresence(durable_present);
3780 writer.WritePresence(broadcast_present);
3781 writer.FinishPresence();
3782 if (headers_present) { writer.WriteTable(m_headers); }
3783 if (proxyName_present) { writer.WriteShortstr(m_proxyName); }
3784 if (dataName_present) { writer.WriteShortstr(m_dataName); }
3785 if (durable_present) { writer.WriteOctet(m_durable); }
3786 if (broadcast_present) { writer.WriteOctet(m_broadcast); }
3789 public override void AppendPropertyDebugStringTo(System.Text.StringBuilder sb) {
3791 sb.Append("headers="); sb.Append(headers_present ? (m_headers == null ? "(null)" : m_headers.ToString()) : "_"); sb.Append(", ");
3792 sb.Append("proxy-name="); sb.Append(proxyName_present ? (m_proxyName == null ? "(null)" : m_proxyName.ToString()) : "_"); sb.Append(", ");
3793 sb.Append("data-name="); sb.Append(dataName_present ? (m_dataName == null ? "(null)" : m_dataName.ToString()) : "_"); sb.Append(", ");
3794 sb.Append("durable="); sb.Append(durable_present ? m_durable.ToString() : "_"); sb.Append(", ");
3795 sb.Append("broadcast="); sb.Append(broadcast_present ? m_broadcast.ToString() : "_");
3800 namespace RabbitMQ.Client.Framing.Impl.v0_9 {
3801 using RabbitMQ.Client.Framing.v0_9;
3802 public enum ClassId {
3817 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3818 public class ConnectionStart: RabbitMQ.Client.Impl.MethodBase, IConnectionStart {
3819 public const int ClassId = 10;
3820 public const int MethodId = 10;
3822 public byte m_versionMajor;
3823 public byte m_versionMinor;
3824 public System.Collections.IDictionary m_serverProperties;
3825 public byte[] m_mechanisms;
3826 public byte[] m_locales;
3828 byte IConnectionStart.VersionMajor { get { return m_versionMajor; } }
3829 byte IConnectionStart.VersionMinor { get { return m_versionMinor; } }
3830 System.Collections.IDictionary IConnectionStart.ServerProperties { get { return m_serverProperties; } }
3831 byte[] IConnectionStart.Mechanisms { get { return m_mechanisms; } }
3832 byte[] IConnectionStart.Locales { get { return m_locales; } }
3834 public ConnectionStart() {}
3835 public ConnectionStart(
3836 byte initVersionMajor,
3837 byte initVersionMinor,
3838 System.Collections.IDictionary initServerProperties,
3839 byte[] initMechanisms,
3842 m_versionMajor = initVersionMajor;
3843 m_versionMinor = initVersionMinor;
3844 m_serverProperties = initServerProperties;
3845 m_mechanisms = initMechanisms;
3846 m_locales = initLocales;
3849 public override int ProtocolClassId { get { return 10; } }
3850 public override int ProtocolMethodId { get { return 10; } }
3851 public override string ProtocolMethodName { get { return "connection.start"; } }
3852 public override bool HasContent { get { return false; } }
3854 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3855 m_versionMajor = reader.ReadOctet();
3856 m_versionMinor = reader.ReadOctet();
3857 m_serverProperties = reader.ReadTable();
3858 m_mechanisms = reader.ReadLongstr();
3859 m_locales = reader.ReadLongstr();
3862 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3863 writer.WriteOctet(m_versionMajor);
3864 writer.WriteOctet(m_versionMinor);
3865 writer.WriteTable(m_serverProperties);
3866 writer.WriteLongstr(m_mechanisms);
3867 writer.WriteLongstr(m_locales);
3870 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3872 sb.Append(m_versionMajor); sb.Append(",");
3873 sb.Append(m_versionMinor); sb.Append(",");
3874 sb.Append(m_serverProperties); sb.Append(",");
3875 sb.Append(m_mechanisms); sb.Append(",");
3876 sb.Append(m_locales);
3880 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3881 public class ConnectionStartOk: RabbitMQ.Client.Impl.MethodBase, IConnectionStartOk {
3882 public const int ClassId = 10;
3883 public const int MethodId = 11;
3885 public System.Collections.IDictionary m_clientProperties;
3886 public string m_mechanism;
3887 public byte[] m_response;
3888 public string m_locale;
3890 System.Collections.IDictionary IConnectionStartOk.ClientProperties { get { return m_clientProperties; } }
3891 string IConnectionStartOk.Mechanism { get { return m_mechanism; } }
3892 byte[] IConnectionStartOk.Response { get { return m_response; } }
3893 string IConnectionStartOk.Locale { get { return m_locale; } }
3895 public ConnectionStartOk() {}
3896 public ConnectionStartOk(
3897 System.Collections.IDictionary initClientProperties,
3898 string initMechanism,
3899 byte[] initResponse,
3902 m_clientProperties = initClientProperties;
3903 m_mechanism = initMechanism;
3904 m_response = initResponse;
3905 m_locale = initLocale;
3908 public override int ProtocolClassId { get { return 10; } }
3909 public override int ProtocolMethodId { get { return 11; } }
3910 public override string ProtocolMethodName { get { return "connection.start-ok"; } }
3911 public override bool HasContent { get { return false; } }
3913 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3914 m_clientProperties = reader.ReadTable();
3915 m_mechanism = reader.ReadShortstr();
3916 m_response = reader.ReadLongstr();
3917 m_locale = reader.ReadShortstr();
3920 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3921 writer.WriteTable(m_clientProperties);
3922 writer.WriteShortstr(m_mechanism);
3923 writer.WriteLongstr(m_response);
3924 writer.WriteShortstr(m_locale);
3927 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3929 sb.Append(m_clientProperties); sb.Append(",");
3930 sb.Append(m_mechanism); sb.Append(",");
3931 sb.Append(m_response); sb.Append(",");
3932 sb.Append(m_locale);
3936 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3937 public class ConnectionSecure: RabbitMQ.Client.Impl.MethodBase, IConnectionSecure {
3938 public const int ClassId = 10;
3939 public const int MethodId = 20;
3941 public byte[] m_challenge;
3943 byte[] IConnectionSecure.Challenge { get { return m_challenge; } }
3945 public ConnectionSecure() {}
3946 public ConnectionSecure(
3947 byte[] initChallenge)
3949 m_challenge = initChallenge;
3952 public override int ProtocolClassId { get { return 10; } }
3953 public override int ProtocolMethodId { get { return 20; } }
3954 public override string ProtocolMethodName { get { return "connection.secure"; } }
3955 public override bool HasContent { get { return false; } }
3957 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3958 m_challenge = reader.ReadLongstr();
3961 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3962 writer.WriteLongstr(m_challenge);
3965 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3967 sb.Append(m_challenge);
3971 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3972 public class ConnectionSecureOk: RabbitMQ.Client.Impl.MethodBase, IConnectionSecureOk {
3973 public const int ClassId = 10;
3974 public const int MethodId = 21;
3976 public byte[] m_response;
3978 byte[] IConnectionSecureOk.Response { get { return m_response; } }
3980 public ConnectionSecureOk() {}
3981 public ConnectionSecureOk(
3982 byte[] initResponse)
3984 m_response = initResponse;
3987 public override int ProtocolClassId { get { return 10; } }
3988 public override int ProtocolMethodId { get { return 21; } }
3989 public override string ProtocolMethodName { get { return "connection.secure-ok"; } }
3990 public override bool HasContent { get { return false; } }
3992 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3993 m_response = reader.ReadLongstr();
3996 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3997 writer.WriteLongstr(m_response);
4000 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4002 sb.Append(m_response);
4006 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4007 public class ConnectionTune: RabbitMQ.Client.Impl.MethodBase, IConnectionTune {
4008 public const int ClassId = 10;
4009 public const int MethodId = 30;
4011 public ushort m_channelMax;
4012 public uint m_frameMax;
4013 public ushort m_heartbeat;
4015 ushort IConnectionTune.ChannelMax { get { return m_channelMax; } }
4016 uint IConnectionTune.FrameMax { get { return m_frameMax; } }
4017 ushort IConnectionTune.Heartbeat { get { return m_heartbeat; } }
4019 public ConnectionTune() {}
4020 public ConnectionTune(
4021 ushort initChannelMax,
4023 ushort initHeartbeat)
4025 m_channelMax = initChannelMax;
4026 m_frameMax = initFrameMax;
4027 m_heartbeat = initHeartbeat;
4030 public override int ProtocolClassId { get { return 10; } }
4031 public override int ProtocolMethodId { get { return 30; } }
4032 public override string ProtocolMethodName { get { return "connection.tune"; } }
4033 public override bool HasContent { get { return false; } }
4035 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4036 m_channelMax = reader.ReadShort();
4037 m_frameMax = reader.ReadLong();
4038 m_heartbeat = reader.ReadShort();
4041 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4042 writer.WriteShort(m_channelMax);
4043 writer.WriteLong(m_frameMax);
4044 writer.WriteShort(m_heartbeat);
4047 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4049 sb.Append(m_channelMax); sb.Append(",");
4050 sb.Append(m_frameMax); sb.Append(",");
4051 sb.Append(m_heartbeat);
4055 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4056 public class ConnectionTuneOk: RabbitMQ.Client.Impl.MethodBase, IConnectionTuneOk {
4057 public const int ClassId = 10;
4058 public const int MethodId = 31;
4060 public ushort m_channelMax;
4061 public uint m_frameMax;
4062 public ushort m_heartbeat;
4064 ushort IConnectionTuneOk.ChannelMax { get { return m_channelMax; } }
4065 uint IConnectionTuneOk.FrameMax { get { return m_frameMax; } }
4066 ushort IConnectionTuneOk.Heartbeat { get { return m_heartbeat; } }
4068 public ConnectionTuneOk() {}
4069 public ConnectionTuneOk(
4070 ushort initChannelMax,
4072 ushort initHeartbeat)
4074 m_channelMax = initChannelMax;
4075 m_frameMax = initFrameMax;
4076 m_heartbeat = initHeartbeat;
4079 public override int ProtocolClassId { get { return 10; } }
4080 public override int ProtocolMethodId { get { return 31; } }
4081 public override string ProtocolMethodName { get { return "connection.tune-ok"; } }
4082 public override bool HasContent { get { return false; } }
4084 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4085 m_channelMax = reader.ReadShort();
4086 m_frameMax = reader.ReadLong();
4087 m_heartbeat = reader.ReadShort();
4090 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4091 writer.WriteShort(m_channelMax);
4092 writer.WriteLong(m_frameMax);
4093 writer.WriteShort(m_heartbeat);
4096 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4098 sb.Append(m_channelMax); sb.Append(",");
4099 sb.Append(m_frameMax); sb.Append(",");
4100 sb.Append(m_heartbeat);
4104 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4105 public class ConnectionOpen: RabbitMQ.Client.Impl.MethodBase, IConnectionOpen {
4106 public const int ClassId = 10;
4107 public const int MethodId = 40;
4109 public string m_virtualHost;
4110 public string m_capabilities;
4111 public bool m_insist;
4113 string IConnectionOpen.VirtualHost { get { return m_virtualHost; } }
4114 string IConnectionOpen.Capabilities { get { return m_capabilities; } }
4115 bool IConnectionOpen.Insist { get { return m_insist; } }
4117 public ConnectionOpen() {}
4118 public ConnectionOpen(
4119 string initVirtualHost,
4120 string initCapabilities,
4123 m_virtualHost = initVirtualHost;
4124 m_capabilities = initCapabilities;
4125 m_insist = initInsist;
4128 public override int ProtocolClassId { get { return 10; } }
4129 public override int ProtocolMethodId { get { return 40; } }
4130 public override string ProtocolMethodName { get { return "connection.open"; } }
4131 public override bool HasContent { get { return false; } }
4133 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4134 m_virtualHost = reader.ReadShortstr();
4135 m_capabilities = reader.ReadShortstr();
4136 m_insist = reader.ReadBit();
4139 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4140 writer.WriteShortstr(m_virtualHost);
4141 writer.WriteShortstr(m_capabilities);
4142 writer.WriteBit(m_insist);
4145 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4147 sb.Append(m_virtualHost); sb.Append(",");
4148 sb.Append(m_capabilities); sb.Append(",");
4149 sb.Append(m_insist);
4153 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4154 public class ConnectionOpenOk: RabbitMQ.Client.Impl.MethodBase, IConnectionOpenOk {
4155 public const int ClassId = 10;
4156 public const int MethodId = 41;
4158 public string m_knownHosts;
4160 string IConnectionOpenOk.KnownHosts { get { return m_knownHosts; } }
4162 public ConnectionOpenOk() {}
4163 public ConnectionOpenOk(
4164 string initKnownHosts)
4166 m_knownHosts = initKnownHosts;
4169 public override int ProtocolClassId { get { return 10; } }
4170 public override int ProtocolMethodId { get { return 41; } }
4171 public override string ProtocolMethodName { get { return "connection.open-ok"; } }
4172 public override bool HasContent { get { return false; } }
4174 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4175 m_knownHosts = reader.ReadShortstr();
4178 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4179 writer.WriteShortstr(m_knownHosts);
4182 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4184 sb.Append(m_knownHosts);
4188 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4189 public class ConnectionRedirect: RabbitMQ.Client.Impl.MethodBase, IConnectionRedirect {
4190 public const int ClassId = 10;
4191 public const int MethodId = 42;
4193 public string m_host;
4194 public string m_knownHosts;
4196 string IConnectionRedirect.Host { get { return m_host; } }
4197 string IConnectionRedirect.KnownHosts { get { return m_knownHosts; } }
4199 public ConnectionRedirect() {}
4200 public ConnectionRedirect(
4202 string initKnownHosts)
4205 m_knownHosts = initKnownHosts;
4208 public override int ProtocolClassId { get { return 10; } }
4209 public override int ProtocolMethodId { get { return 42; } }
4210 public override string ProtocolMethodName { get { return "connection.redirect"; } }
4211 public override bool HasContent { get { return false; } }
4213 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4214 m_host = reader.ReadShortstr();
4215 m_knownHosts = reader.ReadShortstr();
4218 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4219 writer.WriteShortstr(m_host);
4220 writer.WriteShortstr(m_knownHosts);
4223 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4225 sb.Append(m_host); sb.Append(",");
4226 sb.Append(m_knownHosts);
4230 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4231 public class ConnectionClose: RabbitMQ.Client.Impl.MethodBase, IConnectionClose {
4232 public const int ClassId = 10;
4233 public const int MethodId = 50;
4235 public ushort m_replyCode;
4236 public string m_replyText;
4237 public ushort m_classId;
4238 public ushort m_methodId;
4240 ushort IConnectionClose.ReplyCode { get { return m_replyCode; } }
4241 string IConnectionClose.ReplyText { get { return m_replyText; } }
4242 ushort IConnectionClose.ClassId { get { return m_classId; } }
4243 ushort IConnectionClose.MethodId { get { return m_methodId; } }
4245 public ConnectionClose() {}
4246 public ConnectionClose(
4247 ushort initReplyCode,
4248 string initReplyText,
4250 ushort initMethodId)
4252 m_replyCode = initReplyCode;
4253 m_replyText = initReplyText;
4254 m_classId = initClassId;
4255 m_methodId = initMethodId;
4258 public override int ProtocolClassId { get { return 10; } }
4259 public override int ProtocolMethodId { get { return 50; } }
4260 public override string ProtocolMethodName { get { return "connection.close"; } }
4261 public override bool HasContent { get { return false; } }
4263 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4264 m_replyCode = reader.ReadShort();
4265 m_replyText = reader.ReadShortstr();
4266 m_classId = reader.ReadShort();
4267 m_methodId = reader.ReadShort();
4270 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4271 writer.WriteShort(m_replyCode);
4272 writer.WriteShortstr(m_replyText);
4273 writer.WriteShort(m_classId);
4274 writer.WriteShort(m_methodId);
4277 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4279 sb.Append(m_replyCode); sb.Append(",");
4280 sb.Append(m_replyText); sb.Append(",");
4281 sb.Append(m_classId); sb.Append(",");
4282 sb.Append(m_methodId);
4286 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4287 public class ConnectionCloseOk: RabbitMQ.Client.Impl.MethodBase, IConnectionCloseOk {
4288 public const int ClassId = 10;
4289 public const int MethodId = 51;
4293 public ConnectionCloseOk(
4298 public override int ProtocolClassId { get { return 10; } }
4299 public override int ProtocolMethodId { get { return 51; } }
4300 public override string ProtocolMethodName { get { return "connection.close-ok"; } }
4301 public override bool HasContent { get { return false; } }
4303 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4306 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4309 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4314 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4315 public class ChannelOpen: RabbitMQ.Client.Impl.MethodBase, IChannelOpen {
4316 public const int ClassId = 20;
4317 public const int MethodId = 10;
4319 public string m_outOfBand;
4321 string IChannelOpen.OutOfBand { get { return m_outOfBand; } }
4323 public ChannelOpen() {}
4325 string initOutOfBand)
4327 m_outOfBand = initOutOfBand;
4330 public override int ProtocolClassId { get { return 20; } }
4331 public override int ProtocolMethodId { get { return 10; } }
4332 public override string ProtocolMethodName { get { return "channel.open"; } }
4333 public override bool HasContent { get { return false; } }
4335 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4336 m_outOfBand = reader.ReadShortstr();
4339 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4340 writer.WriteShortstr(m_outOfBand);
4343 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4345 sb.Append(m_outOfBand);
4349 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4350 public class ChannelOpenOk: RabbitMQ.Client.Impl.MethodBase, IChannelOpenOk {
4351 public const int ClassId = 20;
4352 public const int MethodId = 11;
4354 public byte[] m_channelId;
4356 byte[] IChannelOpenOk.ChannelId { get { return m_channelId; } }
4358 public ChannelOpenOk() {}
4359 public ChannelOpenOk(
4360 byte[] initChannelId)
4362 m_channelId = initChannelId;
4365 public override int ProtocolClassId { get { return 20; } }
4366 public override int ProtocolMethodId { get { return 11; } }
4367 public override string ProtocolMethodName { get { return "channel.open-ok"; } }
4368 public override bool HasContent { get { return false; } }
4370 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4371 m_channelId = reader.ReadLongstr();
4374 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4375 writer.WriteLongstr(m_channelId);
4378 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4380 sb.Append(m_channelId);
4384 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4385 public class ChannelFlow: RabbitMQ.Client.Impl.MethodBase, IChannelFlow {
4386 public const int ClassId = 20;
4387 public const int MethodId = 20;
4389 public bool m_active;
4391 bool IChannelFlow.Active { get { return m_active; } }
4393 public ChannelFlow() {}
4397 m_active = initActive;
4400 public override int ProtocolClassId { get { return 20; } }
4401 public override int ProtocolMethodId { get { return 20; } }
4402 public override string ProtocolMethodName { get { return "channel.flow"; } }
4403 public override bool HasContent { get { return false; } }
4405 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4406 m_active = reader.ReadBit();
4409 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4410 writer.WriteBit(m_active);
4413 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4415 sb.Append(m_active);
4419 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4420 public class ChannelFlowOk: RabbitMQ.Client.Impl.MethodBase, IChannelFlowOk {
4421 public const int ClassId = 20;
4422 public const int MethodId = 21;
4424 public bool m_active;
4426 bool IChannelFlowOk.Active { get { return m_active; } }
4428 public ChannelFlowOk() {}
4429 public ChannelFlowOk(
4432 m_active = initActive;
4435 public override int ProtocolClassId { get { return 20; } }
4436 public override int ProtocolMethodId { get { return 21; } }
4437 public override string ProtocolMethodName { get { return "channel.flow-ok"; } }
4438 public override bool HasContent { get { return false; } }
4440 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4441 m_active = reader.ReadBit();
4444 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4445 writer.WriteBit(m_active);
4448 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4450 sb.Append(m_active);
4454 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4455 public class ChannelClose: RabbitMQ.Client.Impl.MethodBase, IChannelClose {
4456 public const int ClassId = 20;
4457 public const int MethodId = 40;
4459 public ushort m_replyCode;
4460 public string m_replyText;
4461 public ushort m_classId;
4462 public ushort m_methodId;
4464 ushort IChannelClose.ReplyCode { get { return m_replyCode; } }
4465 string IChannelClose.ReplyText { get { return m_replyText; } }
4466 ushort IChannelClose.ClassId { get { return m_classId; } }
4467 ushort IChannelClose.MethodId { get { return m_methodId; } }
4469 public ChannelClose() {}
4470 public ChannelClose(
4471 ushort initReplyCode,
4472 string initReplyText,
4474 ushort initMethodId)
4476 m_replyCode = initReplyCode;
4477 m_replyText = initReplyText;
4478 m_classId = initClassId;
4479 m_methodId = initMethodId;
4482 public override int ProtocolClassId { get { return 20; } }
4483 public override int ProtocolMethodId { get { return 40; } }
4484 public override string ProtocolMethodName { get { return "channel.close"; } }
4485 public override bool HasContent { get { return false; } }
4487 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4488 m_replyCode = reader.ReadShort();
4489 m_replyText = reader.ReadShortstr();
4490 m_classId = reader.ReadShort();
4491 m_methodId = reader.ReadShort();
4494 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4495 writer.WriteShort(m_replyCode);
4496 writer.WriteShortstr(m_replyText);
4497 writer.WriteShort(m_classId);
4498 writer.WriteShort(m_methodId);
4501 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4503 sb.Append(m_replyCode); sb.Append(",");
4504 sb.Append(m_replyText); sb.Append(",");
4505 sb.Append(m_classId); sb.Append(",");
4506 sb.Append(m_methodId);
4510 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4511 public class ChannelCloseOk: RabbitMQ.Client.Impl.MethodBase, IChannelCloseOk {
4512 public const int ClassId = 20;
4513 public const int MethodId = 41;
4517 public ChannelCloseOk(
4522 public override int ProtocolClassId { get { return 20; } }
4523 public override int ProtocolMethodId { get { return 41; } }
4524 public override string ProtocolMethodName { get { return "channel.close-ok"; } }
4525 public override bool HasContent { get { return false; } }
4527 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4530 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4533 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4538 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4539 public class ChannelResume: RabbitMQ.Client.Impl.MethodBase, IChannelResume {
4540 public const int ClassId = 20;
4541 public const int MethodId = 50;
4543 public byte[] m_channelId;
4545 byte[] IChannelResume.ChannelId { get { return m_channelId; } }
4547 public ChannelResume() {}
4548 public ChannelResume(
4549 byte[] initChannelId)
4551 m_channelId = initChannelId;
4554 public override int ProtocolClassId { get { return 20; } }
4555 public override int ProtocolMethodId { get { return 50; } }
4556 public override string ProtocolMethodName { get { return "channel.resume"; } }
4557 public override bool HasContent { get { return false; } }
4559 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4560 m_channelId = reader.ReadLongstr();
4563 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4564 writer.WriteLongstr(m_channelId);
4567 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4569 sb.Append(m_channelId);
4573 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4574 public class ChannelPing: RabbitMQ.Client.Impl.MethodBase, IChannelPing {
4575 public const int ClassId = 20;
4576 public const int MethodId = 60;
4585 public override int ProtocolClassId { get { return 20; } }
4586 public override int ProtocolMethodId { get { return 60; } }
4587 public override string ProtocolMethodName { get { return "channel.ping"; } }
4588 public override bool HasContent { get { return false; } }
4590 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4593 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4596 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4601 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4602 public class ChannelPong: RabbitMQ.Client.Impl.MethodBase, IChannelPong {
4603 public const int ClassId = 20;
4604 public const int MethodId = 70;
4613 public override int ProtocolClassId { get { return 20; } }
4614 public override int ProtocolMethodId { get { return 70; } }
4615 public override string ProtocolMethodName { get { return "channel.pong"; } }
4616 public override bool HasContent { get { return false; } }
4618 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4621 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4624 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4629 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4630 public class ChannelOk: RabbitMQ.Client.Impl.MethodBase, IChannelOk {
4631 public const int ClassId = 20;
4632 public const int MethodId = 80;
4641 public override int ProtocolClassId { get { return 20; } }
4642 public override int ProtocolMethodId { get { return 80; } }
4643 public override string ProtocolMethodName { get { return "channel.ok"; } }
4644 public override bool HasContent { get { return false; } }
4646 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4649 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4652 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4657 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4658 public class AccessRequest: RabbitMQ.Client.Impl.MethodBase, IAccessRequest {
4659 public const int ClassId = 30;
4660 public const int MethodId = 10;
4662 public string m_realm;
4663 public bool m_exclusive;
4664 public bool m_passive;
4665 public bool m_active;
4666 public bool m_write;
4669 string IAccessRequest.Realm { get { return m_realm; } }
4670 bool IAccessRequest.Exclusive { get { return m_exclusive; } }
4671 bool IAccessRequest.Passive { get { return m_passive; } }
4672 bool IAccessRequest.Active { get { return m_active; } }
4673 bool IAccessRequest.Write { get { return m_write; } }
4674 bool IAccessRequest.Read { get { return m_read; } }
4676 public AccessRequest() {}
4677 public AccessRequest(
4685 m_realm = initRealm;
4686 m_exclusive = initExclusive;
4687 m_passive = initPassive;
4688 m_active = initActive;
4689 m_write = initWrite;
4693 public override int ProtocolClassId { get { return 30; } }
4694 public override int ProtocolMethodId { get { return 10; } }
4695 public override string ProtocolMethodName { get { return "access.request"; } }
4696 public override bool HasContent { get { return false; } }
4698 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4699 m_realm = reader.ReadShortstr();
4700 m_exclusive = reader.ReadBit();
4701 m_passive = reader.ReadBit();
4702 m_active = reader.ReadBit();
4703 m_write = reader.ReadBit();
4704 m_read = reader.ReadBit();
4707 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4708 writer.WriteShortstr(m_realm);
4709 writer.WriteBit(m_exclusive);
4710 writer.WriteBit(m_passive);
4711 writer.WriteBit(m_active);
4712 writer.WriteBit(m_write);
4713 writer.WriteBit(m_read);
4716 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4718 sb.Append(m_realm); sb.Append(",");
4719 sb.Append(m_exclusive); sb.Append(",");
4720 sb.Append(m_passive); sb.Append(",");
4721 sb.Append(m_active); sb.Append(",");
4722 sb.Append(m_write); sb.Append(",");
4727 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4728 public class AccessRequestOk: RabbitMQ.Client.Impl.MethodBase, IAccessRequestOk {
4729 public const int ClassId = 30;
4730 public const int MethodId = 11;
4732 public ushort m_ticket;
4734 ushort IAccessRequestOk.Ticket { get { return m_ticket; } }
4736 public AccessRequestOk() {}
4737 public AccessRequestOk(
4740 m_ticket = initTicket;
4743 public override int ProtocolClassId { get { return 30; } }
4744 public override int ProtocolMethodId { get { return 11; } }
4745 public override string ProtocolMethodName { get { return "access.request-ok"; } }
4746 public override bool HasContent { get { return false; } }
4748 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4749 m_ticket = reader.ReadShort();
4752 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4753 writer.WriteShort(m_ticket);
4756 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4758 sb.Append(m_ticket);
4762 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4763 public class ExchangeDeclare: RabbitMQ.Client.Impl.MethodBase, IExchangeDeclare {
4764 public const int ClassId = 40;
4765 public const int MethodId = 10;
4767 public ushort m_ticket;
4768 public string m_exchange;
4769 public string m_type;
4770 public bool m_passive;
4771 public bool m_durable;
4772 public bool m_autoDelete;
4773 public bool m_internal;
4774 public bool m_nowait;
4775 public System.Collections.IDictionary m_arguments;
4777 ushort IExchangeDeclare.Ticket { get { return m_ticket; } }
4778 string IExchangeDeclare.Exchange { get { return m_exchange; } }
4779 string IExchangeDeclare.Type { get { return m_type; } }
4780 bool IExchangeDeclare.Passive { get { return m_passive; } }
4781 bool IExchangeDeclare.Durable { get { return m_durable; } }
4782 bool IExchangeDeclare.AutoDelete { get { return m_autoDelete; } }
4783 bool IExchangeDeclare.Internal { get { return m_internal; } }
4784 bool IExchangeDeclare.Nowait { get { return m_nowait; } }
4785 System.Collections.IDictionary IExchangeDeclare.Arguments { get { return m_arguments; } }
4787 public ExchangeDeclare() {}
4788 public ExchangeDeclare(
4790 string initExchange,
4794 bool initAutoDelete,
4797 System.Collections.IDictionary initArguments)
4799 m_ticket = initTicket;
4800 m_exchange = initExchange;
4802 m_passive = initPassive;
4803 m_durable = initDurable;
4804 m_autoDelete = initAutoDelete;
4805 m_internal = initInternal;
4806 m_nowait = initNowait;
4807 m_arguments = initArguments;
4810 public override int ProtocolClassId { get { return 40; } }
4811 public override int ProtocolMethodId { get { return 10; } }
4812 public override string ProtocolMethodName { get { return "exchange.declare"; } }
4813 public override bool HasContent { get { return false; } }
4815 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4816 m_ticket = reader.ReadShort();
4817 m_exchange = reader.ReadShortstr();
4818 m_type = reader.ReadShortstr();
4819 m_passive = reader.ReadBit();
4820 m_durable = reader.ReadBit();
4821 m_autoDelete = reader.ReadBit();
4822 m_internal = reader.ReadBit();
4823 m_nowait = reader.ReadBit();
4824 m_arguments = reader.ReadTable();
4827 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4828 writer.WriteShort(m_ticket);
4829 writer.WriteShortstr(m_exchange);
4830 writer.WriteShortstr(m_type);
4831 writer.WriteBit(m_passive);
4832 writer.WriteBit(m_durable);
4833 writer.WriteBit(m_autoDelete);
4834 writer.WriteBit(m_internal);
4835 writer.WriteBit(m_nowait);
4836 writer.WriteTable(m_arguments);
4839 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4841 sb.Append(m_ticket); sb.Append(",");
4842 sb.Append(m_exchange); sb.Append(",");
4843 sb.Append(m_type); sb.Append(",");
4844 sb.Append(m_passive); sb.Append(",");
4845 sb.Append(m_durable); sb.Append(",");
4846 sb.Append(m_autoDelete); sb.Append(",");
4847 sb.Append(m_internal); sb.Append(",");
4848 sb.Append(m_nowait); sb.Append(",");
4849 sb.Append(m_arguments);
4853 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4854 public class ExchangeDeclareOk: RabbitMQ.Client.Impl.MethodBase, IExchangeDeclareOk {
4855 public const int ClassId = 40;
4856 public const int MethodId = 11;
4860 public ExchangeDeclareOk(
4865 public override int ProtocolClassId { get { return 40; } }
4866 public override int ProtocolMethodId { get { return 11; } }
4867 public override string ProtocolMethodName { get { return "exchange.declare-ok"; } }
4868 public override bool HasContent { get { return false; } }
4870 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4873 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4876 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4881 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4882 public class ExchangeDelete: RabbitMQ.Client.Impl.MethodBase, IExchangeDelete {
4883 public const int ClassId = 40;
4884 public const int MethodId = 20;
4886 public ushort m_ticket;
4887 public string m_exchange;
4888 public bool m_ifUnused;
4889 public bool m_nowait;
4891 ushort IExchangeDelete.Ticket { get { return m_ticket; } }
4892 string IExchangeDelete.Exchange { get { return m_exchange; } }
4893 bool IExchangeDelete.IfUnused { get { return m_ifUnused; } }
4894 bool IExchangeDelete.Nowait { get { return m_nowait; } }
4896 public ExchangeDelete() {}
4897 public ExchangeDelete(
4899 string initExchange,
4903 m_ticket = initTicket;
4904 m_exchange = initExchange;
4905 m_ifUnused = initIfUnused;
4906 m_nowait = initNowait;
4909 public override int ProtocolClassId { get { return 40; } }
4910 public override int ProtocolMethodId { get { return 20; } }
4911 public override string ProtocolMethodName { get { return "exchange.delete"; } }
4912 public override bool HasContent { get { return false; } }
4914 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4915 m_ticket = reader.ReadShort();
4916 m_exchange = reader.ReadShortstr();
4917 m_ifUnused = reader.ReadBit();
4918 m_nowait = reader.ReadBit();
4921 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4922 writer.WriteShort(m_ticket);
4923 writer.WriteShortstr(m_exchange);
4924 writer.WriteBit(m_ifUnused);
4925 writer.WriteBit(m_nowait);
4928 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4930 sb.Append(m_ticket); sb.Append(",");
4931 sb.Append(m_exchange); sb.Append(",");
4932 sb.Append(m_ifUnused); sb.Append(",");
4933 sb.Append(m_nowait);
4937 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4938 public class ExchangeDeleteOk: RabbitMQ.Client.Impl.MethodBase, IExchangeDeleteOk {
4939 public const int ClassId = 40;
4940 public const int MethodId = 21;
4944 public ExchangeDeleteOk(
4949 public override int ProtocolClassId { get { return 40; } }
4950 public override int ProtocolMethodId { get { return 21; } }
4951 public override string ProtocolMethodName { get { return "exchange.delete-ok"; } }
4952 public override bool HasContent { get { return false; } }
4954 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4957 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4960 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4965 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4966 public class QueueDeclare: RabbitMQ.Client.Impl.MethodBase, IQueueDeclare {
4967 public const int ClassId = 50;
4968 public const int MethodId = 10;
4970 public ushort m_ticket;
4971 public string m_queue;
4972 public bool m_passive;
4973 public bool m_durable;
4974 public bool m_exclusive;
4975 public bool m_autoDelete;
4976 public bool m_nowait;
4977 public System.Collections.IDictionary m_arguments;
4979 ushort IQueueDeclare.Ticket { get { return m_ticket; } }
4980 string IQueueDeclare.Queue { get { return m_queue; } }
4981 bool IQueueDeclare.Passive { get { return m_passive; } }
4982 bool IQueueDeclare.Durable { get { return m_durable; } }
4983 bool IQueueDeclare.Exclusive { get { return m_exclusive; } }
4984 bool IQueueDeclare.AutoDelete { get { return m_autoDelete; } }
4985 bool IQueueDeclare.Nowait { get { return m_nowait; } }
4986 System.Collections.IDictionary IQueueDeclare.Arguments { get { return m_arguments; } }
4988 public QueueDeclare() {}
4989 public QueueDeclare(
4995 bool initAutoDelete,
4997 System.Collections.IDictionary initArguments)
4999 m_ticket = initTicket;
5000 m_queue = initQueue;
5001 m_passive = initPassive;
5002 m_durable = initDurable;
5003 m_exclusive = initExclusive;
5004 m_autoDelete = initAutoDelete;
5005 m_nowait = initNowait;
5006 m_arguments = initArguments;
5009 public override int ProtocolClassId { get { return 50; } }
5010 public override int ProtocolMethodId { get { return 10; } }
5011 public override string ProtocolMethodName { get { return "queue.declare"; } }
5012 public override bool HasContent { get { return false; } }
5014 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5015 m_ticket = reader.ReadShort();
5016 m_queue = reader.ReadShortstr();
5017 m_passive = reader.ReadBit();
5018 m_durable = reader.ReadBit();
5019 m_exclusive = reader.ReadBit();
5020 m_autoDelete = reader.ReadBit();
5021 m_nowait = reader.ReadBit();
5022 m_arguments = reader.ReadTable();
5025 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5026 writer.WriteShort(m_ticket);
5027 writer.WriteShortstr(m_queue);
5028 writer.WriteBit(m_passive);
5029 writer.WriteBit(m_durable);
5030 writer.WriteBit(m_exclusive);
5031 writer.WriteBit(m_autoDelete);
5032 writer.WriteBit(m_nowait);
5033 writer.WriteTable(m_arguments);
5036 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5038 sb.Append(m_ticket); sb.Append(",");
5039 sb.Append(m_queue); sb.Append(",");
5040 sb.Append(m_passive); sb.Append(",");
5041 sb.Append(m_durable); sb.Append(",");
5042 sb.Append(m_exclusive); sb.Append(",");
5043 sb.Append(m_autoDelete); sb.Append(",");
5044 sb.Append(m_nowait); sb.Append(",");
5045 sb.Append(m_arguments);
5049 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5050 public class QueueDeclareOk: RabbitMQ.Client.Impl.MethodBase, IQueueDeclareOk {
5051 public const int ClassId = 50;
5052 public const int MethodId = 11;
5054 public string m_queue;
5055 public uint m_messageCount;
5056 public uint m_consumerCount;
5058 string IQueueDeclareOk.Queue { get { return m_queue; } }
5059 uint IQueueDeclareOk.MessageCount { get { return m_messageCount; } }
5060 uint IQueueDeclareOk.ConsumerCount { get { return m_consumerCount; } }
5062 public QueueDeclareOk() {}
5063 public QueueDeclareOk(
5065 uint initMessageCount,
5066 uint initConsumerCount)
5068 m_queue = initQueue;
5069 m_messageCount = initMessageCount;
5070 m_consumerCount = initConsumerCount;
5073 public override int ProtocolClassId { get { return 50; } }
5074 public override int ProtocolMethodId { get { return 11; } }
5075 public override string ProtocolMethodName { get { return "queue.declare-ok"; } }
5076 public override bool HasContent { get { return false; } }
5078 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5079 m_queue = reader.ReadShortstr();
5080 m_messageCount = reader.ReadLong();
5081 m_consumerCount = reader.ReadLong();
5084 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5085 writer.WriteShortstr(m_queue);
5086 writer.WriteLong(m_messageCount);
5087 writer.WriteLong(m_consumerCount);
5090 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5092 sb.Append(m_queue); sb.Append(",");
5093 sb.Append(m_messageCount); sb.Append(",");
5094 sb.Append(m_consumerCount);
5098 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5099 public class QueueBind: RabbitMQ.Client.Impl.MethodBase, IQueueBind {
5100 public const int ClassId = 50;
5101 public const int MethodId = 20;
5103 public ushort m_ticket;
5104 public string m_queue;
5105 public string m_exchange;
5106 public string m_routingKey;
5107 public bool m_nowait;
5108 public System.Collections.IDictionary m_arguments;
5110 ushort IQueueBind.Ticket { get { return m_ticket; } }
5111 string IQueueBind.Queue { get { return m_queue; } }
5112 string IQueueBind.Exchange { get { return m_exchange; } }
5113 string IQueueBind.RoutingKey { get { return m_routingKey; } }
5114 bool IQueueBind.Nowait { get { return m_nowait; } }
5115 System.Collections.IDictionary IQueueBind.Arguments { get { return m_arguments; } }
5117 public QueueBind() {}
5121 string initExchange,
5122 string initRoutingKey,
5124 System.Collections.IDictionary initArguments)
5126 m_ticket = initTicket;
5127 m_queue = initQueue;
5128 m_exchange = initExchange;
5129 m_routingKey = initRoutingKey;
5130 m_nowait = initNowait;
5131 m_arguments = initArguments;
5134 public override int ProtocolClassId { get { return 50; } }
5135 public override int ProtocolMethodId { get { return 20; } }
5136 public override string ProtocolMethodName { get { return "queue.bind"; } }
5137 public override bool HasContent { get { return false; } }
5139 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5140 m_ticket = reader.ReadShort();
5141 m_queue = reader.ReadShortstr();
5142 m_exchange = reader.ReadShortstr();
5143 m_routingKey = reader.ReadShortstr();
5144 m_nowait = reader.ReadBit();
5145 m_arguments = reader.ReadTable();
5148 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5149 writer.WriteShort(m_ticket);
5150 writer.WriteShortstr(m_queue);
5151 writer.WriteShortstr(m_exchange);
5152 writer.WriteShortstr(m_routingKey);
5153 writer.WriteBit(m_nowait);
5154 writer.WriteTable(m_arguments);
5157 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5159 sb.Append(m_ticket); sb.Append(",");
5160 sb.Append(m_queue); sb.Append(",");
5161 sb.Append(m_exchange); sb.Append(",");
5162 sb.Append(m_routingKey); sb.Append(",");
5163 sb.Append(m_nowait); sb.Append(",");
5164 sb.Append(m_arguments);
5168 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5169 public class QueueBindOk: RabbitMQ.Client.Impl.MethodBase, IQueueBindOk {
5170 public const int ClassId = 50;
5171 public const int MethodId = 21;
5180 public override int ProtocolClassId { get { return 50; } }
5181 public override int ProtocolMethodId { get { return 21; } }
5182 public override string ProtocolMethodName { get { return "queue.bind-ok"; } }
5183 public override bool HasContent { get { return false; } }
5185 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5188 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5191 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5196 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5197 public class QueueUnbind: RabbitMQ.Client.Impl.MethodBase, IQueueUnbind {
5198 public const int ClassId = 50;
5199 public const int MethodId = 50;
5201 public ushort m_ticket;
5202 public string m_queue;
5203 public string m_exchange;
5204 public string m_routingKey;
5205 public System.Collections.IDictionary m_arguments;
5207 ushort IQueueUnbind.Ticket { get { return m_ticket; } }
5208 string IQueueUnbind.Queue { get { return m_queue; } }
5209 string IQueueUnbind.Exchange { get { return m_exchange; } }
5210 string IQueueUnbind.RoutingKey { get { return m_routingKey; } }
5211 System.Collections.IDictionary IQueueUnbind.Arguments { get { return m_arguments; } }
5213 public QueueUnbind() {}
5217 string initExchange,
5218 string initRoutingKey,
5219 System.Collections.IDictionary initArguments)
5221 m_ticket = initTicket;
5222 m_queue = initQueue;
5223 m_exchange = initExchange;
5224 m_routingKey = initRoutingKey;
5225 m_arguments = initArguments;
5228 public override int ProtocolClassId { get { return 50; } }
5229 public override int ProtocolMethodId { get { return 50; } }
5230 public override string ProtocolMethodName { get { return "queue.unbind"; } }
5231 public override bool HasContent { get { return false; } }
5233 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5234 m_ticket = reader.ReadShort();
5235 m_queue = reader.ReadShortstr();
5236 m_exchange = reader.ReadShortstr();
5237 m_routingKey = reader.ReadShortstr();
5238 m_arguments = reader.ReadTable();
5241 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5242 writer.WriteShort(m_ticket);
5243 writer.WriteShortstr(m_queue);
5244 writer.WriteShortstr(m_exchange);
5245 writer.WriteShortstr(m_routingKey);
5246 writer.WriteTable(m_arguments);
5249 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5251 sb.Append(m_ticket); sb.Append(",");
5252 sb.Append(m_queue); sb.Append(",");
5253 sb.Append(m_exchange); sb.Append(",");
5254 sb.Append(m_routingKey); sb.Append(",");
5255 sb.Append(m_arguments);
5259 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5260 public class QueueUnbindOk: RabbitMQ.Client.Impl.MethodBase, IQueueUnbindOk {
5261 public const int ClassId = 50;
5262 public const int MethodId = 51;
5266 public QueueUnbindOk(
5271 public override int ProtocolClassId { get { return 50; } }
5272 public override int ProtocolMethodId { get { return 51; } }
5273 public override string ProtocolMethodName { get { return "queue.unbind-ok"; } }
5274 public override bool HasContent { get { return false; } }
5276 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5279 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5282 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5287 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5288 public class QueuePurge: RabbitMQ.Client.Impl.MethodBase, IQueuePurge {
5289 public const int ClassId = 50;
5290 public const int MethodId = 30;
5292 public ushort m_ticket;
5293 public string m_queue;
5294 public bool m_nowait;
5296 ushort IQueuePurge.Ticket { get { return m_ticket; } }
5297 string IQueuePurge.Queue { get { return m_queue; } }
5298 bool IQueuePurge.Nowait { get { return m_nowait; } }
5300 public QueuePurge() {}
5306 m_ticket = initTicket;
5307 m_queue = initQueue;
5308 m_nowait = initNowait;
5311 public override int ProtocolClassId { get { return 50; } }
5312 public override int ProtocolMethodId { get { return 30; } }
5313 public override string ProtocolMethodName { get { return "queue.purge"; } }
5314 public override bool HasContent { get { return false; } }
5316 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5317 m_ticket = reader.ReadShort();
5318 m_queue = reader.ReadShortstr();
5319 m_nowait = reader.ReadBit();
5322 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5323 writer.WriteShort(m_ticket);
5324 writer.WriteShortstr(m_queue);
5325 writer.WriteBit(m_nowait);
5328 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5330 sb.Append(m_ticket); sb.Append(",");
5331 sb.Append(m_queue); sb.Append(",");
5332 sb.Append(m_nowait);
5336 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5337 public class QueuePurgeOk: RabbitMQ.Client.Impl.MethodBase, IQueuePurgeOk {
5338 public const int ClassId = 50;
5339 public const int MethodId = 31;
5341 public uint m_messageCount;
5343 uint IQueuePurgeOk.MessageCount { get { return m_messageCount; } }
5345 public QueuePurgeOk() {}
5346 public QueuePurgeOk(
5347 uint initMessageCount)
5349 m_messageCount = initMessageCount;
5352 public override int ProtocolClassId { get { return 50; } }
5353 public override int ProtocolMethodId { get { return 31; } }
5354 public override string ProtocolMethodName { get { return "queue.purge-ok"; } }
5355 public override bool HasContent { get { return false; } }
5357 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5358 m_messageCount = reader.ReadLong();
5361 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5362 writer.WriteLong(m_messageCount);
5365 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5367 sb.Append(m_messageCount);
5371 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5372 public class QueueDelete: RabbitMQ.Client.Impl.MethodBase, IQueueDelete {
5373 public const int ClassId = 50;
5374 public const int MethodId = 40;
5376 public ushort m_ticket;
5377 public string m_queue;
5378 public bool m_ifUnused;
5379 public bool m_ifEmpty;
5380 public bool m_nowait;
5382 ushort IQueueDelete.Ticket { get { return m_ticket; } }
5383 string IQueueDelete.Queue { get { return m_queue; } }
5384 bool IQueueDelete.IfUnused { get { return m_ifUnused; } }
5385 bool IQueueDelete.IfEmpty { get { return m_ifEmpty; } }
5386 bool IQueueDelete.Nowait { get { return m_nowait; } }
5388 public QueueDelete() {}
5396 m_ticket = initTicket;
5397 m_queue = initQueue;
5398 m_ifUnused = initIfUnused;
5399 m_ifEmpty = initIfEmpty;
5400 m_nowait = initNowait;
5403 public override int ProtocolClassId { get { return 50; } }
5404 public override int ProtocolMethodId { get { return 40; } }
5405 public override string ProtocolMethodName { get { return "queue.delete"; } }
5406 public override bool HasContent { get { return false; } }
5408 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5409 m_ticket = reader.ReadShort();
5410 m_queue = reader.ReadShortstr();
5411 m_ifUnused = reader.ReadBit();
5412 m_ifEmpty = reader.ReadBit();
5413 m_nowait = reader.ReadBit();
5416 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5417 writer.WriteShort(m_ticket);
5418 writer.WriteShortstr(m_queue);
5419 writer.WriteBit(m_ifUnused);
5420 writer.WriteBit(m_ifEmpty);
5421 writer.WriteBit(m_nowait);
5424 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5426 sb.Append(m_ticket); sb.Append(",");
5427 sb.Append(m_queue); sb.Append(",");
5428 sb.Append(m_ifUnused); sb.Append(",");
5429 sb.Append(m_ifEmpty); sb.Append(",");
5430 sb.Append(m_nowait);
5434 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5435 public class QueueDeleteOk: RabbitMQ.Client.Impl.MethodBase, IQueueDeleteOk {
5436 public const int ClassId = 50;
5437 public const int MethodId = 41;
5439 public uint m_messageCount;
5441 uint IQueueDeleteOk.MessageCount { get { return m_messageCount; } }
5443 public QueueDeleteOk() {}
5444 public QueueDeleteOk(
5445 uint initMessageCount)
5447 m_messageCount = initMessageCount;
5450 public override int ProtocolClassId { get { return 50; } }
5451 public override int ProtocolMethodId { get { return 41; } }
5452 public override string ProtocolMethodName { get { return "queue.delete-ok"; } }
5453 public override bool HasContent { get { return false; } }
5455 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5456 m_messageCount = reader.ReadLong();
5459 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5460 writer.WriteLong(m_messageCount);
5463 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5465 sb.Append(m_messageCount);
5469 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5470 public class BasicQos: RabbitMQ.Client.Impl.MethodBase, IBasicQos {
5471 public const int ClassId = 60;
5472 public const int MethodId = 10;
5474 public uint m_prefetchSize;
5475 public ushort m_prefetchCount;
5476 public bool m_global;
5478 uint IBasicQos.PrefetchSize { get { return m_prefetchSize; } }
5479 ushort IBasicQos.PrefetchCount { get { return m_prefetchCount; } }
5480 bool IBasicQos.Global { get { return m_global; } }
5482 public BasicQos() {}
5484 uint initPrefetchSize,
5485 ushort initPrefetchCount,
5488 m_prefetchSize = initPrefetchSize;
5489 m_prefetchCount = initPrefetchCount;
5490 m_global = initGlobal;
5493 public override int ProtocolClassId { get { return 60; } }
5494 public override int ProtocolMethodId { get { return 10; } }
5495 public override string ProtocolMethodName { get { return "basic.qos"; } }
5496 public override bool HasContent { get { return false; } }
5498 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5499 m_prefetchSize = reader.ReadLong();
5500 m_prefetchCount = reader.ReadShort();
5501 m_global = reader.ReadBit();
5504 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5505 writer.WriteLong(m_prefetchSize);
5506 writer.WriteShort(m_prefetchCount);
5507 writer.WriteBit(m_global);
5510 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5512 sb.Append(m_prefetchSize); sb.Append(",");
5513 sb.Append(m_prefetchCount); sb.Append(",");
5514 sb.Append(m_global);
5518 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5519 public class BasicQosOk: RabbitMQ.Client.Impl.MethodBase, IBasicQosOk {
5520 public const int ClassId = 60;
5521 public const int MethodId = 11;
5530 public override int ProtocolClassId { get { return 60; } }
5531 public override int ProtocolMethodId { get { return 11; } }
5532 public override string ProtocolMethodName { get { return "basic.qos-ok"; } }
5533 public override bool HasContent { get { return false; } }
5535 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5538 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5541 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5546 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5547 public class BasicConsume: RabbitMQ.Client.Impl.MethodBase, IBasicConsume {
5548 public const int ClassId = 60;
5549 public const int MethodId = 20;
5551 public ushort m_ticket;
5552 public string m_queue;
5553 public string m_consumerTag;
5554 public bool m_noLocal;
5555 public bool m_noAck;
5556 public bool m_exclusive;
5557 public bool m_nowait;
5558 public System.Collections.IDictionary m_filter;
5560 ushort IBasicConsume.Ticket { get { return m_ticket; } }
5561 string IBasicConsume.Queue { get { return m_queue; } }
5562 string IBasicConsume.ConsumerTag { get { return m_consumerTag; } }
5563 bool IBasicConsume.NoLocal { get { return m_noLocal; } }
5564 bool IBasicConsume.NoAck { get { return m_noAck; } }
5565 bool IBasicConsume.Exclusive { get { return m_exclusive; } }
5566 bool IBasicConsume.Nowait { get { return m_nowait; } }
5567 System.Collections.IDictionary IBasicConsume.Filter { get { return m_filter; } }
5569 public BasicConsume() {}
5570 public BasicConsume(
5573 string initConsumerTag,
5578 System.Collections.IDictionary initFilter)
5580 m_ticket = initTicket;
5581 m_queue = initQueue;
5582 m_consumerTag = initConsumerTag;
5583 m_noLocal = initNoLocal;
5584 m_noAck = initNoAck;
5585 m_exclusive = initExclusive;
5586 m_nowait = initNowait;
5587 m_filter = initFilter;
5590 public override int ProtocolClassId { get { return 60; } }
5591 public override int ProtocolMethodId { get { return 20; } }
5592 public override string ProtocolMethodName { get { return "basic.consume"; } }
5593 public override bool HasContent { get { return false; } }
5595 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5596 m_ticket = reader.ReadShort();
5597 m_queue = reader.ReadShortstr();
5598 m_consumerTag = reader.ReadShortstr();
5599 m_noLocal = reader.ReadBit();
5600 m_noAck = reader.ReadBit();
5601 m_exclusive = reader.ReadBit();
5602 m_nowait = reader.ReadBit();
5603 m_filter = reader.ReadTable();
5606 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5607 writer.WriteShort(m_ticket);
5608 writer.WriteShortstr(m_queue);
5609 writer.WriteShortstr(m_consumerTag);
5610 writer.WriteBit(m_noLocal);
5611 writer.WriteBit(m_noAck);
5612 writer.WriteBit(m_exclusive);
5613 writer.WriteBit(m_nowait);
5614 writer.WriteTable(m_filter);
5617 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5619 sb.Append(m_ticket); sb.Append(",");
5620 sb.Append(m_queue); sb.Append(",");
5621 sb.Append(m_consumerTag); sb.Append(",");
5622 sb.Append(m_noLocal); sb.Append(",");
5623 sb.Append(m_noAck); sb.Append(",");
5624 sb.Append(m_exclusive); sb.Append(",");
5625 sb.Append(m_nowait); sb.Append(",");
5626 sb.Append(m_filter);
5630 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5631 public class BasicConsumeOk: RabbitMQ.Client.Impl.MethodBase, IBasicConsumeOk {
5632 public const int ClassId = 60;
5633 public const int MethodId = 21;
5635 public string m_consumerTag;
5637 string IBasicConsumeOk.ConsumerTag { get { return m_consumerTag; } }
5639 public BasicConsumeOk() {}
5640 public BasicConsumeOk(
5641 string initConsumerTag)
5643 m_consumerTag = initConsumerTag;
5646 public override int ProtocolClassId { get { return 60; } }
5647 public override int ProtocolMethodId { get { return 21; } }
5648 public override string ProtocolMethodName { get { return "basic.consume-ok"; } }
5649 public override bool HasContent { get { return false; } }
5651 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5652 m_consumerTag = reader.ReadShortstr();
5655 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5656 writer.WriteShortstr(m_consumerTag);
5659 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5661 sb.Append(m_consumerTag);
5665 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5666 public class BasicCancel: RabbitMQ.Client.Impl.MethodBase, IBasicCancel {
5667 public const int ClassId = 60;
5668 public const int MethodId = 30;
5670 public string m_consumerTag;
5671 public bool m_nowait;
5673 string IBasicCancel.ConsumerTag { get { return m_consumerTag; } }
5674 bool IBasicCancel.Nowait { get { return m_nowait; } }
5676 public BasicCancel() {}
5678 string initConsumerTag,
5681 m_consumerTag = initConsumerTag;
5682 m_nowait = initNowait;
5685 public override int ProtocolClassId { get { return 60; } }
5686 public override int ProtocolMethodId { get { return 30; } }
5687 public override string ProtocolMethodName { get { return "basic.cancel"; } }
5688 public override bool HasContent { get { return false; } }
5690 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5691 m_consumerTag = reader.ReadShortstr();
5692 m_nowait = reader.ReadBit();
5695 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5696 writer.WriteShortstr(m_consumerTag);
5697 writer.WriteBit(m_nowait);
5700 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5702 sb.Append(m_consumerTag); sb.Append(",");
5703 sb.Append(m_nowait);
5707 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5708 public class BasicCancelOk: RabbitMQ.Client.Impl.MethodBase, IBasicCancelOk {
5709 public const int ClassId = 60;
5710 public const int MethodId = 31;
5712 public string m_consumerTag;
5714 string IBasicCancelOk.ConsumerTag { get { return m_consumerTag; } }
5716 public BasicCancelOk() {}
5717 public BasicCancelOk(
5718 string initConsumerTag)
5720 m_consumerTag = initConsumerTag;
5723 public override int ProtocolClassId { get { return 60; } }
5724 public override int ProtocolMethodId { get { return 31; } }
5725 public override string ProtocolMethodName { get { return "basic.cancel-ok"; } }
5726 public override bool HasContent { get { return false; } }
5728 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5729 m_consumerTag = reader.ReadShortstr();
5732 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5733 writer.WriteShortstr(m_consumerTag);
5736 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5738 sb.Append(m_consumerTag);
5742 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5743 public class BasicPublish: RabbitMQ.Client.Impl.MethodBase, IBasicPublish {
5744 public const int ClassId = 60;
5745 public const int MethodId = 40;
5747 public ushort m_ticket;
5748 public string m_exchange;
5749 public string m_routingKey;
5750 public bool m_mandatory;
5751 public bool m_immediate;
5753 ushort IBasicPublish.Ticket { get { return m_ticket; } }
5754 string IBasicPublish.Exchange { get { return m_exchange; } }
5755 string IBasicPublish.RoutingKey { get { return m_routingKey; } }
5756 bool IBasicPublish.Mandatory { get { return m_mandatory; } }
5757 bool IBasicPublish.Immediate { get { return m_immediate; } }
5759 public BasicPublish() {}
5760 public BasicPublish(
5762 string initExchange,
5763 string initRoutingKey,
5767 m_ticket = initTicket;
5768 m_exchange = initExchange;
5769 m_routingKey = initRoutingKey;
5770 m_mandatory = initMandatory;
5771 m_immediate = initImmediate;
5774 public override int ProtocolClassId { get { return 60; } }
5775 public override int ProtocolMethodId { get { return 40; } }
5776 public override string ProtocolMethodName { get { return "basic.publish"; } }
5777 public override bool HasContent { get { return true; } }
5779 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5780 m_ticket = reader.ReadShort();
5781 m_exchange = reader.ReadShortstr();
5782 m_routingKey = reader.ReadShortstr();
5783 m_mandatory = reader.ReadBit();
5784 m_immediate = reader.ReadBit();
5787 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5788 writer.WriteShort(m_ticket);
5789 writer.WriteShortstr(m_exchange);
5790 writer.WriteShortstr(m_routingKey);
5791 writer.WriteBit(m_mandatory);
5792 writer.WriteBit(m_immediate);
5795 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5797 sb.Append(m_ticket); sb.Append(",");
5798 sb.Append(m_exchange); sb.Append(",");
5799 sb.Append(m_routingKey); sb.Append(",");
5800 sb.Append(m_mandatory); sb.Append(",");
5801 sb.Append(m_immediate);
5805 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5806 public class BasicReturn: RabbitMQ.Client.Impl.MethodBase, IBasicReturn {
5807 public const int ClassId = 60;
5808 public const int MethodId = 50;
5810 public ushort m_replyCode;
5811 public string m_replyText;
5812 public string m_exchange;
5813 public string m_routingKey;
5815 ushort IBasicReturn.ReplyCode { get { return m_replyCode; } }
5816 string IBasicReturn.ReplyText { get { return m_replyText; } }
5817 string IBasicReturn.Exchange { get { return m_exchange; } }
5818 string IBasicReturn.RoutingKey { get { return m_routingKey; } }
5820 public BasicReturn() {}
5822 ushort initReplyCode,
5823 string initReplyText,
5824 string initExchange,
5825 string initRoutingKey)
5827 m_replyCode = initReplyCode;
5828 m_replyText = initReplyText;
5829 m_exchange = initExchange;
5830 m_routingKey = initRoutingKey;
5833 public override int ProtocolClassId { get { return 60; } }
5834 public override int ProtocolMethodId { get { return 50; } }
5835 public override string ProtocolMethodName { get { return "basic.return"; } }
5836 public override bool HasContent { get { return true; } }
5838 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5839 m_replyCode = reader.ReadShort();
5840 m_replyText = reader.ReadShortstr();
5841 m_exchange = reader.ReadShortstr();
5842 m_routingKey = reader.ReadShortstr();
5845 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5846 writer.WriteShort(m_replyCode);
5847 writer.WriteShortstr(m_replyText);
5848 writer.WriteShortstr(m_exchange);
5849 writer.WriteShortstr(m_routingKey);
5852 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5854 sb.Append(m_replyCode); sb.Append(",");
5855 sb.Append(m_replyText); sb.Append(",");
5856 sb.Append(m_exchange); sb.Append(",");
5857 sb.Append(m_routingKey);
5861 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5862 public class BasicDeliver: RabbitMQ.Client.Impl.MethodBase, IBasicDeliver {
5863 public const int ClassId = 60;
5864 public const int MethodId = 60;
5866 public string m_consumerTag;
5867 public ulong m_deliveryTag;
5868 public bool m_redelivered;
5869 public string m_exchange;
5870 public string m_routingKey;
5872 string IBasicDeliver.ConsumerTag { get { return m_consumerTag; } }
5873 ulong IBasicDeliver.DeliveryTag { get { return m_deliveryTag; } }
5874 bool IBasicDeliver.Redelivered { get { return m_redelivered; } }
5875 string IBasicDeliver.Exchange { get { return m_exchange; } }
5876 string IBasicDeliver.RoutingKey { get { return m_routingKey; } }
5878 public BasicDeliver() {}
5879 public BasicDeliver(
5880 string initConsumerTag,
5881 ulong initDeliveryTag,
5882 bool initRedelivered,
5883 string initExchange,
5884 string initRoutingKey)
5886 m_consumerTag = initConsumerTag;
5887 m_deliveryTag = initDeliveryTag;
5888 m_redelivered = initRedelivered;
5889 m_exchange = initExchange;
5890 m_routingKey = initRoutingKey;
5893 public override int ProtocolClassId { get { return 60; } }
5894 public override int ProtocolMethodId { get { return 60; } }
5895 public override string ProtocolMethodName { get { return "basic.deliver"; } }
5896 public override bool HasContent { get { return true; } }
5898 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5899 m_consumerTag = reader.ReadShortstr();
5900 m_deliveryTag = reader.ReadLonglong();
5901 m_redelivered = reader.ReadBit();
5902 m_exchange = reader.ReadShortstr();
5903 m_routingKey = reader.ReadShortstr();
5906 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5907 writer.WriteShortstr(m_consumerTag);
5908 writer.WriteLonglong(m_deliveryTag);
5909 writer.WriteBit(m_redelivered);
5910 writer.WriteShortstr(m_exchange);
5911 writer.WriteShortstr(m_routingKey);
5914 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5916 sb.Append(m_consumerTag); sb.Append(",");
5917 sb.Append(m_deliveryTag); sb.Append(",");
5918 sb.Append(m_redelivered); sb.Append(",");
5919 sb.Append(m_exchange); sb.Append(",");
5920 sb.Append(m_routingKey);
5924 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5925 public class BasicGet: RabbitMQ.Client.Impl.MethodBase, IBasicGet {
5926 public const int ClassId = 60;
5927 public const int MethodId = 70;
5929 public ushort m_ticket;
5930 public string m_queue;
5931 public bool m_noAck;
5933 ushort IBasicGet.Ticket { get { return m_ticket; } }
5934 string IBasicGet.Queue { get { return m_queue; } }
5935 bool IBasicGet.NoAck { get { return m_noAck; } }
5937 public BasicGet() {}
5943 m_ticket = initTicket;
5944 m_queue = initQueue;
5945 m_noAck = initNoAck;
5948 public override int ProtocolClassId { get { return 60; } }
5949 public override int ProtocolMethodId { get { return 70; } }
5950 public override string ProtocolMethodName { get { return "basic.get"; } }
5951 public override bool HasContent { get { return false; } }
5953 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5954 m_ticket = reader.ReadShort();
5955 m_queue = reader.ReadShortstr();
5956 m_noAck = reader.ReadBit();
5959 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5960 writer.WriteShort(m_ticket);
5961 writer.WriteShortstr(m_queue);
5962 writer.WriteBit(m_noAck);
5965 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5967 sb.Append(m_ticket); sb.Append(",");
5968 sb.Append(m_queue); sb.Append(",");
5973 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5974 public class BasicGetOk: RabbitMQ.Client.Impl.MethodBase, IBasicGetOk {
5975 public const int ClassId = 60;
5976 public const int MethodId = 71;
5978 public ulong m_deliveryTag;
5979 public bool m_redelivered;
5980 public string m_exchange;
5981 public string m_routingKey;
5982 public uint m_messageCount;
5984 ulong IBasicGetOk.DeliveryTag { get { return m_deliveryTag; } }
5985 bool IBasicGetOk.Redelivered { get { return m_redelivered; } }
5986 string IBasicGetOk.Exchange { get { return m_exchange; } }
5987 string IBasicGetOk.RoutingKey { get { return m_routingKey; } }
5988 uint IBasicGetOk.MessageCount { get { return m_messageCount; } }
5990 public BasicGetOk() {}
5992 ulong initDeliveryTag,
5993 bool initRedelivered,
5994 string initExchange,
5995 string initRoutingKey,
5996 uint initMessageCount)
5998 m_deliveryTag = initDeliveryTag;
5999 m_redelivered = initRedelivered;
6000 m_exchange = initExchange;
6001 m_routingKey = initRoutingKey;
6002 m_messageCount = initMessageCount;
6005 public override int ProtocolClassId { get { return 60; } }
6006 public override int ProtocolMethodId { get { return 71; } }
6007 public override string ProtocolMethodName { get { return "basic.get-ok"; } }
6008 public override bool HasContent { get { return true; } }
6010 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6011 m_deliveryTag = reader.ReadLonglong();
6012 m_redelivered = reader.ReadBit();
6013 m_exchange = reader.ReadShortstr();
6014 m_routingKey = reader.ReadShortstr();
6015 m_messageCount = reader.ReadLong();
6018 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6019 writer.WriteLonglong(m_deliveryTag);
6020 writer.WriteBit(m_redelivered);
6021 writer.WriteShortstr(m_exchange);
6022 writer.WriteShortstr(m_routingKey);
6023 writer.WriteLong(m_messageCount);
6026 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6028 sb.Append(m_deliveryTag); sb.Append(",");
6029 sb.Append(m_redelivered); sb.Append(",");
6030 sb.Append(m_exchange); sb.Append(",");
6031 sb.Append(m_routingKey); sb.Append(",");
6032 sb.Append(m_messageCount);
6036 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6037 public class BasicGetEmpty: RabbitMQ.Client.Impl.MethodBase, IBasicGetEmpty {
6038 public const int ClassId = 60;
6039 public const int MethodId = 72;
6041 public string m_clusterId;
6043 string IBasicGetEmpty.ClusterId { get { return m_clusterId; } }
6045 public BasicGetEmpty() {}
6046 public BasicGetEmpty(
6047 string initClusterId)
6049 m_clusterId = initClusterId;
6052 public override int ProtocolClassId { get { return 60; } }
6053 public override int ProtocolMethodId { get { return 72; } }
6054 public override string ProtocolMethodName { get { return "basic.get-empty"; } }
6055 public override bool HasContent { get { return false; } }
6057 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6058 m_clusterId = reader.ReadShortstr();
6061 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6062 writer.WriteShortstr(m_clusterId);
6065 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6067 sb.Append(m_clusterId);
6071 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6072 public class BasicAck: RabbitMQ.Client.Impl.MethodBase, IBasicAck {
6073 public const int ClassId = 60;
6074 public const int MethodId = 80;
6076 public ulong m_deliveryTag;
6077 public bool m_multiple;
6079 ulong IBasicAck.DeliveryTag { get { return m_deliveryTag; } }
6080 bool IBasicAck.Multiple { get { return m_multiple; } }
6082 public BasicAck() {}
6084 ulong initDeliveryTag,
6087 m_deliveryTag = initDeliveryTag;
6088 m_multiple = initMultiple;
6091 public override int ProtocolClassId { get { return 60; } }
6092 public override int ProtocolMethodId { get { return 80; } }
6093 public override string ProtocolMethodName { get { return "basic.ack"; } }
6094 public override bool HasContent { get { return false; } }
6096 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6097 m_deliveryTag = reader.ReadLonglong();
6098 m_multiple = reader.ReadBit();
6101 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6102 writer.WriteLonglong(m_deliveryTag);
6103 writer.WriteBit(m_multiple);
6106 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6108 sb.Append(m_deliveryTag); sb.Append(",");
6109 sb.Append(m_multiple);
6113 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6114 public class BasicReject: RabbitMQ.Client.Impl.MethodBase, IBasicReject {
6115 public const int ClassId = 60;
6116 public const int MethodId = 90;
6118 public ulong m_deliveryTag;
6119 public bool m_requeue;
6121 ulong IBasicReject.DeliveryTag { get { return m_deliveryTag; } }
6122 bool IBasicReject.Requeue { get { return m_requeue; } }
6124 public BasicReject() {}
6126 ulong initDeliveryTag,
6129 m_deliveryTag = initDeliveryTag;
6130 m_requeue = initRequeue;
6133 public override int ProtocolClassId { get { return 60; } }
6134 public override int ProtocolMethodId { get { return 90; } }
6135 public override string ProtocolMethodName { get { return "basic.reject"; } }
6136 public override bool HasContent { get { return false; } }
6138 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6139 m_deliveryTag = reader.ReadLonglong();
6140 m_requeue = reader.ReadBit();
6143 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6144 writer.WriteLonglong(m_deliveryTag);
6145 writer.WriteBit(m_requeue);
6148 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6150 sb.Append(m_deliveryTag); sb.Append(",");
6151 sb.Append(m_requeue);
6155 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6156 public class BasicRecover: RabbitMQ.Client.Impl.MethodBase, IBasicRecover {
6157 public const int ClassId = 60;
6158 public const int MethodId = 100;
6160 public bool m_requeue;
6162 bool IBasicRecover.Requeue { get { return m_requeue; } }
6164 public BasicRecover() {}
6165 public BasicRecover(
6168 m_requeue = initRequeue;
6171 public override int ProtocolClassId { get { return 60; } }
6172 public override int ProtocolMethodId { get { return 100; } }
6173 public override string ProtocolMethodName { get { return "basic.recover"; } }
6174 public override bool HasContent { get { return false; } }
6176 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6177 m_requeue = reader.ReadBit();
6180 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6181 writer.WriteBit(m_requeue);
6184 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6186 sb.Append(m_requeue);
6190 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6191 public class FileQos: RabbitMQ.Client.Impl.MethodBase, IFileQos {
6192 public const int ClassId = 70;
6193 public const int MethodId = 10;
6195 public uint m_prefetchSize;
6196 public ushort m_prefetchCount;
6197 public bool m_global;
6199 uint IFileQos.PrefetchSize { get { return m_prefetchSize; } }
6200 ushort IFileQos.PrefetchCount { get { return m_prefetchCount; } }
6201 bool IFileQos.Global { get { return m_global; } }
6205 uint initPrefetchSize,
6206 ushort initPrefetchCount,
6209 m_prefetchSize = initPrefetchSize;
6210 m_prefetchCount = initPrefetchCount;
6211 m_global = initGlobal;
6214 public override int ProtocolClassId { get { return 70; } }
6215 public override int ProtocolMethodId { get { return 10; } }
6216 public override string ProtocolMethodName { get { return "file.qos"; } }
6217 public override bool HasContent { get { return false; } }
6219 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6220 m_prefetchSize = reader.ReadLong();
6221 m_prefetchCount = reader.ReadShort();
6222 m_global = reader.ReadBit();
6225 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6226 writer.WriteLong(m_prefetchSize);
6227 writer.WriteShort(m_prefetchCount);
6228 writer.WriteBit(m_global);
6231 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6233 sb.Append(m_prefetchSize); sb.Append(",");
6234 sb.Append(m_prefetchCount); sb.Append(",");
6235 sb.Append(m_global);
6239 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6240 public class FileQosOk: RabbitMQ.Client.Impl.MethodBase, IFileQosOk {
6241 public const int ClassId = 70;
6242 public const int MethodId = 11;
6251 public override int ProtocolClassId { get { return 70; } }
6252 public override int ProtocolMethodId { get { return 11; } }
6253 public override string ProtocolMethodName { get { return "file.qos-ok"; } }
6254 public override bool HasContent { get { return false; } }
6256 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6259 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6262 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6267 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6268 public class FileConsume: RabbitMQ.Client.Impl.MethodBase, IFileConsume {
6269 public const int ClassId = 70;
6270 public const int MethodId = 20;
6272 public ushort m_ticket;
6273 public string m_queue;
6274 public string m_consumerTag;
6275 public bool m_noLocal;
6276 public bool m_noAck;
6277 public bool m_exclusive;
6278 public bool m_nowait;
6279 public System.Collections.IDictionary m_filter;
6281 ushort IFileConsume.Ticket { get { return m_ticket; } }
6282 string IFileConsume.Queue { get { return m_queue; } }
6283 string IFileConsume.ConsumerTag { get { return m_consumerTag; } }
6284 bool IFileConsume.NoLocal { get { return m_noLocal; } }
6285 bool IFileConsume.NoAck { get { return m_noAck; } }
6286 bool IFileConsume.Exclusive { get { return m_exclusive; } }
6287 bool IFileConsume.Nowait { get { return m_nowait; } }
6288 System.Collections.IDictionary IFileConsume.Filter { get { return m_filter; } }
6290 public FileConsume() {}
6294 string initConsumerTag,
6299 System.Collections.IDictionary initFilter)
6301 m_ticket = initTicket;
6302 m_queue = initQueue;
6303 m_consumerTag = initConsumerTag;
6304 m_noLocal = initNoLocal;
6305 m_noAck = initNoAck;
6306 m_exclusive = initExclusive;
6307 m_nowait = initNowait;
6308 m_filter = initFilter;
6311 public override int ProtocolClassId { get { return 70; } }
6312 public override int ProtocolMethodId { get { return 20; } }
6313 public override string ProtocolMethodName { get { return "file.consume"; } }
6314 public override bool HasContent { get { return false; } }
6316 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6317 m_ticket = reader.ReadShort();
6318 m_queue = reader.ReadShortstr();
6319 m_consumerTag = reader.ReadShortstr();
6320 m_noLocal = reader.ReadBit();
6321 m_noAck = reader.ReadBit();
6322 m_exclusive = reader.ReadBit();
6323 m_nowait = reader.ReadBit();
6324 m_filter = reader.ReadTable();
6327 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6328 writer.WriteShort(m_ticket);
6329 writer.WriteShortstr(m_queue);
6330 writer.WriteShortstr(m_consumerTag);
6331 writer.WriteBit(m_noLocal);
6332 writer.WriteBit(m_noAck);
6333 writer.WriteBit(m_exclusive);
6334 writer.WriteBit(m_nowait);
6335 writer.WriteTable(m_filter);
6338 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6340 sb.Append(m_ticket); sb.Append(",");
6341 sb.Append(m_queue); sb.Append(",");
6342 sb.Append(m_consumerTag); sb.Append(",");
6343 sb.Append(m_noLocal); sb.Append(",");
6344 sb.Append(m_noAck); sb.Append(",");
6345 sb.Append(m_exclusive); sb.Append(",");
6346 sb.Append(m_nowait); sb.Append(",");
6347 sb.Append(m_filter);
6351 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6352 public class FileConsumeOk: RabbitMQ.Client.Impl.MethodBase, IFileConsumeOk {
6353 public const int ClassId = 70;
6354 public const int MethodId = 21;
6356 public string m_consumerTag;
6358 string IFileConsumeOk.ConsumerTag { get { return m_consumerTag; } }
6360 public FileConsumeOk() {}
6361 public FileConsumeOk(
6362 string initConsumerTag)
6364 m_consumerTag = initConsumerTag;
6367 public override int ProtocolClassId { get { return 70; } }
6368 public override int ProtocolMethodId { get { return 21; } }
6369 public override string ProtocolMethodName { get { return "file.consume-ok"; } }
6370 public override bool HasContent { get { return false; } }
6372 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6373 m_consumerTag = reader.ReadShortstr();
6376 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6377 writer.WriteShortstr(m_consumerTag);
6380 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6382 sb.Append(m_consumerTag);
6386 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6387 public class FileCancel: RabbitMQ.Client.Impl.MethodBase, IFileCancel {
6388 public const int ClassId = 70;
6389 public const int MethodId = 30;
6391 public string m_consumerTag;
6392 public bool m_nowait;
6394 string IFileCancel.ConsumerTag { get { return m_consumerTag; } }
6395 bool IFileCancel.Nowait { get { return m_nowait; } }
6397 public FileCancel() {}
6399 string initConsumerTag,
6402 m_consumerTag = initConsumerTag;
6403 m_nowait = initNowait;
6406 public override int ProtocolClassId { get { return 70; } }
6407 public override int ProtocolMethodId { get { return 30; } }
6408 public override string ProtocolMethodName { get { return "file.cancel"; } }
6409 public override bool HasContent { get { return false; } }
6411 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6412 m_consumerTag = reader.ReadShortstr();
6413 m_nowait = reader.ReadBit();
6416 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6417 writer.WriteShortstr(m_consumerTag);
6418 writer.WriteBit(m_nowait);
6421 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6423 sb.Append(m_consumerTag); sb.Append(",");
6424 sb.Append(m_nowait);
6428 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6429 public class FileCancelOk: RabbitMQ.Client.Impl.MethodBase, IFileCancelOk {
6430 public const int ClassId = 70;
6431 public const int MethodId = 31;
6433 public string m_consumerTag;
6435 string IFileCancelOk.ConsumerTag { get { return m_consumerTag; } }
6437 public FileCancelOk() {}
6438 public FileCancelOk(
6439 string initConsumerTag)
6441 m_consumerTag = initConsumerTag;
6444 public override int ProtocolClassId { get { return 70; } }
6445 public override int ProtocolMethodId { get { return 31; } }
6446 public override string ProtocolMethodName { get { return "file.cancel-ok"; } }
6447 public override bool HasContent { get { return false; } }
6449 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6450 m_consumerTag = reader.ReadShortstr();
6453 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6454 writer.WriteShortstr(m_consumerTag);
6457 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6459 sb.Append(m_consumerTag);
6463 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6464 public class FileOpen: RabbitMQ.Client.Impl.MethodBase, IFileOpen {
6465 public const int ClassId = 70;
6466 public const int MethodId = 40;
6468 public string m_identifier;
6469 public ulong m_contentSize;
6471 string IFileOpen.Identifier { get { return m_identifier; } }
6472 ulong IFileOpen.ContentSize { get { return m_contentSize; } }
6474 public FileOpen() {}
6476 string initIdentifier,
6477 ulong initContentSize)
6479 m_identifier = initIdentifier;
6480 m_contentSize = initContentSize;
6483 public override int ProtocolClassId { get { return 70; } }
6484 public override int ProtocolMethodId { get { return 40; } }
6485 public override string ProtocolMethodName { get { return "file.open"; } }
6486 public override bool HasContent { get { return false; } }
6488 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6489 m_identifier = reader.ReadShortstr();
6490 m_contentSize = reader.ReadLonglong();
6493 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6494 writer.WriteShortstr(m_identifier);
6495 writer.WriteLonglong(m_contentSize);
6498 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6500 sb.Append(m_identifier); sb.Append(",");
6501 sb.Append(m_contentSize);
6505 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6506 public class FileOpenOk: RabbitMQ.Client.Impl.MethodBase, IFileOpenOk {
6507 public const int ClassId = 70;
6508 public const int MethodId = 41;
6510 public ulong m_stagedSize;
6512 ulong IFileOpenOk.StagedSize { get { return m_stagedSize; } }
6514 public FileOpenOk() {}
6516 ulong initStagedSize)
6518 m_stagedSize = initStagedSize;
6521 public override int ProtocolClassId { get { return 70; } }
6522 public override int ProtocolMethodId { get { return 41; } }
6523 public override string ProtocolMethodName { get { return "file.open-ok"; } }
6524 public override bool HasContent { get { return false; } }
6526 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6527 m_stagedSize = reader.ReadLonglong();
6530 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6531 writer.WriteLonglong(m_stagedSize);
6534 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6536 sb.Append(m_stagedSize);
6540 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6541 public class FileStage: RabbitMQ.Client.Impl.MethodBase, IFileStage {
6542 public const int ClassId = 70;
6543 public const int MethodId = 50;
6552 public override int ProtocolClassId { get { return 70; } }
6553 public override int ProtocolMethodId { get { return 50; } }
6554 public override string ProtocolMethodName { get { return "file.stage"; } }
6555 public override bool HasContent { get { return true; } }
6557 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6560 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6563 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6568 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6569 public class FilePublish: RabbitMQ.Client.Impl.MethodBase, IFilePublish {
6570 public const int ClassId = 70;
6571 public const int MethodId = 60;
6573 public ushort m_ticket;
6574 public string m_exchange;
6575 public string m_routingKey;
6576 public bool m_mandatory;
6577 public bool m_immediate;
6578 public string m_identifier;
6580 ushort IFilePublish.Ticket { get { return m_ticket; } }
6581 string IFilePublish.Exchange { get { return m_exchange; } }
6582 string IFilePublish.RoutingKey { get { return m_routingKey; } }
6583 bool IFilePublish.Mandatory { get { return m_mandatory; } }
6584 bool IFilePublish.Immediate { get { return m_immediate; } }
6585 string IFilePublish.Identifier { get { return m_identifier; } }
6587 public FilePublish() {}
6590 string initExchange,
6591 string initRoutingKey,
6594 string initIdentifier)
6596 m_ticket = initTicket;
6597 m_exchange = initExchange;
6598 m_routingKey = initRoutingKey;
6599 m_mandatory = initMandatory;
6600 m_immediate = initImmediate;
6601 m_identifier = initIdentifier;
6604 public override int ProtocolClassId { get { return 70; } }
6605 public override int ProtocolMethodId { get { return 60; } }
6606 public override string ProtocolMethodName { get { return "file.publish"; } }
6607 public override bool HasContent { get { return false; } }
6609 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6610 m_ticket = reader.ReadShort();
6611 m_exchange = reader.ReadShortstr();
6612 m_routingKey = reader.ReadShortstr();
6613 m_mandatory = reader.ReadBit();
6614 m_immediate = reader.ReadBit();
6615 m_identifier = reader.ReadShortstr();
6618 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6619 writer.WriteShort(m_ticket);
6620 writer.WriteShortstr(m_exchange);
6621 writer.WriteShortstr(m_routingKey);
6622 writer.WriteBit(m_mandatory);
6623 writer.WriteBit(m_immediate);
6624 writer.WriteShortstr(m_identifier);
6627 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6629 sb.Append(m_ticket); sb.Append(",");
6630 sb.Append(m_exchange); sb.Append(",");
6631 sb.Append(m_routingKey); sb.Append(",");
6632 sb.Append(m_mandatory); sb.Append(",");
6633 sb.Append(m_immediate); sb.Append(",");
6634 sb.Append(m_identifier);
6638 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6639 public class FileReturn: RabbitMQ.Client.Impl.MethodBase, IFileReturn {
6640 public const int ClassId = 70;
6641 public const int MethodId = 70;
6643 public ushort m_replyCode;
6644 public string m_replyText;
6645 public string m_exchange;
6646 public string m_routingKey;
6648 ushort IFileReturn.ReplyCode { get { return m_replyCode; } }
6649 string IFileReturn.ReplyText { get { return m_replyText; } }
6650 string IFileReturn.Exchange { get { return m_exchange; } }
6651 string IFileReturn.RoutingKey { get { return m_routingKey; } }
6653 public FileReturn() {}
6655 ushort initReplyCode,
6656 string initReplyText,
6657 string initExchange,
6658 string initRoutingKey)
6660 m_replyCode = initReplyCode;
6661 m_replyText = initReplyText;
6662 m_exchange = initExchange;
6663 m_routingKey = initRoutingKey;
6666 public override int ProtocolClassId { get { return 70; } }
6667 public override int ProtocolMethodId { get { return 70; } }
6668 public override string ProtocolMethodName { get { return "file.return"; } }
6669 public override bool HasContent { get { return true; } }
6671 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6672 m_replyCode = reader.ReadShort();
6673 m_replyText = reader.ReadShortstr();
6674 m_exchange = reader.ReadShortstr();
6675 m_routingKey = reader.ReadShortstr();
6678 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6679 writer.WriteShort(m_replyCode);
6680 writer.WriteShortstr(m_replyText);
6681 writer.WriteShortstr(m_exchange);
6682 writer.WriteShortstr(m_routingKey);
6685 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6687 sb.Append(m_replyCode); sb.Append(",");
6688 sb.Append(m_replyText); sb.Append(",");
6689 sb.Append(m_exchange); sb.Append(",");
6690 sb.Append(m_routingKey);
6694 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6695 public class FileDeliver: RabbitMQ.Client.Impl.MethodBase, IFileDeliver {
6696 public const int ClassId = 70;
6697 public const int MethodId = 80;
6699 public string m_consumerTag;
6700 public ulong m_deliveryTag;
6701 public bool m_redelivered;
6702 public string m_exchange;
6703 public string m_routingKey;
6704 public string m_identifier;
6706 string IFileDeliver.ConsumerTag { get { return m_consumerTag; } }
6707 ulong IFileDeliver.DeliveryTag { get { return m_deliveryTag; } }
6708 bool IFileDeliver.Redelivered { get { return m_redelivered; } }
6709 string IFileDeliver.Exchange { get { return m_exchange; } }
6710 string IFileDeliver.RoutingKey { get { return m_routingKey; } }
6711 string IFileDeliver.Identifier { get { return m_identifier; } }
6713 public FileDeliver() {}
6715 string initConsumerTag,
6716 ulong initDeliveryTag,
6717 bool initRedelivered,
6718 string initExchange,
6719 string initRoutingKey,
6720 string initIdentifier)
6722 m_consumerTag = initConsumerTag;
6723 m_deliveryTag = initDeliveryTag;
6724 m_redelivered = initRedelivered;
6725 m_exchange = initExchange;
6726 m_routingKey = initRoutingKey;
6727 m_identifier = initIdentifier;
6730 public override int ProtocolClassId { get { return 70; } }
6731 public override int ProtocolMethodId { get { return 80; } }
6732 public override string ProtocolMethodName { get { return "file.deliver"; } }
6733 public override bool HasContent { get { return false; } }
6735 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6736 m_consumerTag = reader.ReadShortstr();
6737 m_deliveryTag = reader.ReadLonglong();
6738 m_redelivered = reader.ReadBit();
6739 m_exchange = reader.ReadShortstr();
6740 m_routingKey = reader.ReadShortstr();
6741 m_identifier = reader.ReadShortstr();
6744 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6745 writer.WriteShortstr(m_consumerTag);
6746 writer.WriteLonglong(m_deliveryTag);
6747 writer.WriteBit(m_redelivered);
6748 writer.WriteShortstr(m_exchange);
6749 writer.WriteShortstr(m_routingKey);
6750 writer.WriteShortstr(m_identifier);
6753 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6755 sb.Append(m_consumerTag); sb.Append(",");
6756 sb.Append(m_deliveryTag); sb.Append(",");
6757 sb.Append(m_redelivered); sb.Append(",");
6758 sb.Append(m_exchange); sb.Append(",");
6759 sb.Append(m_routingKey); sb.Append(",");
6760 sb.Append(m_identifier);
6764 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6765 public class FileAck: RabbitMQ.Client.Impl.MethodBase, IFileAck {
6766 public const int ClassId = 70;
6767 public const int MethodId = 90;
6769 public ulong m_deliveryTag;
6770 public bool m_multiple;
6772 ulong IFileAck.DeliveryTag { get { return m_deliveryTag; } }
6773 bool IFileAck.Multiple { get { return m_multiple; } }
6777 ulong initDeliveryTag,
6780 m_deliveryTag = initDeliveryTag;
6781 m_multiple = initMultiple;
6784 public override int ProtocolClassId { get { return 70; } }
6785 public override int ProtocolMethodId { get { return 90; } }
6786 public override string ProtocolMethodName { get { return "file.ack"; } }
6787 public override bool HasContent { get { return false; } }
6789 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6790 m_deliveryTag = reader.ReadLonglong();
6791 m_multiple = reader.ReadBit();
6794 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6795 writer.WriteLonglong(m_deliveryTag);
6796 writer.WriteBit(m_multiple);
6799 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6801 sb.Append(m_deliveryTag); sb.Append(",");
6802 sb.Append(m_multiple);
6806 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6807 public class FileReject: RabbitMQ.Client.Impl.MethodBase, IFileReject {
6808 public const int ClassId = 70;
6809 public const int MethodId = 100;
6811 public ulong m_deliveryTag;
6812 public bool m_requeue;
6814 ulong IFileReject.DeliveryTag { get { return m_deliveryTag; } }
6815 bool IFileReject.Requeue { get { return m_requeue; } }
6817 public FileReject() {}
6819 ulong initDeliveryTag,
6822 m_deliveryTag = initDeliveryTag;
6823 m_requeue = initRequeue;
6826 public override int ProtocolClassId { get { return 70; } }
6827 public override int ProtocolMethodId { get { return 100; } }
6828 public override string ProtocolMethodName { get { return "file.reject"; } }
6829 public override bool HasContent { get { return false; } }
6831 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6832 m_deliveryTag = reader.ReadLonglong();
6833 m_requeue = reader.ReadBit();
6836 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6837 writer.WriteLonglong(m_deliveryTag);
6838 writer.WriteBit(m_requeue);
6841 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6843 sb.Append(m_deliveryTag); sb.Append(",");
6844 sb.Append(m_requeue);
6848 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6849 public class StreamQos: RabbitMQ.Client.Impl.MethodBase, IStreamQos {
6850 public const int ClassId = 80;
6851 public const int MethodId = 10;
6853 public uint m_prefetchSize;
6854 public ushort m_prefetchCount;
6855 public uint m_consumeRate;
6856 public bool m_global;
6858 uint IStreamQos.PrefetchSize { get { return m_prefetchSize; } }
6859 ushort IStreamQos.PrefetchCount { get { return m_prefetchCount; } }
6860 uint IStreamQos.ConsumeRate { get { return m_consumeRate; } }
6861 bool IStreamQos.Global { get { return m_global; } }
6863 public StreamQos() {}
6865 uint initPrefetchSize,
6866 ushort initPrefetchCount,
6867 uint initConsumeRate,
6870 m_prefetchSize = initPrefetchSize;
6871 m_prefetchCount = initPrefetchCount;
6872 m_consumeRate = initConsumeRate;
6873 m_global = initGlobal;
6876 public override int ProtocolClassId { get { return 80; } }
6877 public override int ProtocolMethodId { get { return 10; } }
6878 public override string ProtocolMethodName { get { return "stream.qos"; } }
6879 public override bool HasContent { get { return false; } }
6881 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6882 m_prefetchSize = reader.ReadLong();
6883 m_prefetchCount = reader.ReadShort();
6884 m_consumeRate = reader.ReadLong();
6885 m_global = reader.ReadBit();
6888 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6889 writer.WriteLong(m_prefetchSize);
6890 writer.WriteShort(m_prefetchCount);
6891 writer.WriteLong(m_consumeRate);
6892 writer.WriteBit(m_global);
6895 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6897 sb.Append(m_prefetchSize); sb.Append(",");
6898 sb.Append(m_prefetchCount); sb.Append(",");
6899 sb.Append(m_consumeRate); sb.Append(",");
6900 sb.Append(m_global);
6904 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6905 public class StreamQosOk: RabbitMQ.Client.Impl.MethodBase, IStreamQosOk {
6906 public const int ClassId = 80;
6907 public const int MethodId = 11;
6916 public override int ProtocolClassId { get { return 80; } }
6917 public override int ProtocolMethodId { get { return 11; } }
6918 public override string ProtocolMethodName { get { return "stream.qos-ok"; } }
6919 public override bool HasContent { get { return false; } }
6921 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6924 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6927 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6932 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6933 public class StreamConsume: RabbitMQ.Client.Impl.MethodBase, IStreamConsume {
6934 public const int ClassId = 80;
6935 public const int MethodId = 20;
6937 public ushort m_ticket;
6938 public string m_queue;
6939 public string m_consumerTag;
6940 public bool m_noLocal;
6941 public bool m_exclusive;
6942 public bool m_nowait;
6943 public System.Collections.IDictionary m_filter;
6945 ushort IStreamConsume.Ticket { get { return m_ticket; } }
6946 string IStreamConsume.Queue { get { return m_queue; } }
6947 string IStreamConsume.ConsumerTag { get { return m_consumerTag; } }
6948 bool IStreamConsume.NoLocal { get { return m_noLocal; } }
6949 bool IStreamConsume.Exclusive { get { return m_exclusive; } }
6950 bool IStreamConsume.Nowait { get { return m_nowait; } }
6951 System.Collections.IDictionary IStreamConsume.Filter { get { return m_filter; } }
6953 public StreamConsume() {}
6954 public StreamConsume(
6957 string initConsumerTag,
6961 System.Collections.IDictionary initFilter)
6963 m_ticket = initTicket;
6964 m_queue = initQueue;
6965 m_consumerTag = initConsumerTag;
6966 m_noLocal = initNoLocal;
6967 m_exclusive = initExclusive;
6968 m_nowait = initNowait;
6969 m_filter = initFilter;
6972 public override int ProtocolClassId { get { return 80; } }
6973 public override int ProtocolMethodId { get { return 20; } }
6974 public override string ProtocolMethodName { get { return "stream.consume"; } }
6975 public override bool HasContent { get { return false; } }
6977 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6978 m_ticket = reader.ReadShort();
6979 m_queue = reader.ReadShortstr();
6980 m_consumerTag = reader.ReadShortstr();
6981 m_noLocal = reader.ReadBit();
6982 m_exclusive = reader.ReadBit();
6983 m_nowait = reader.ReadBit();
6984 m_filter = reader.ReadTable();
6987 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6988 writer.WriteShort(m_ticket);
6989 writer.WriteShortstr(m_queue);
6990 writer.WriteShortstr(m_consumerTag);
6991 writer.WriteBit(m_noLocal);
6992 writer.WriteBit(m_exclusive);
6993 writer.WriteBit(m_nowait);
6994 writer.WriteTable(m_filter);
6997 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6999 sb.Append(m_ticket); sb.Append(",");
7000 sb.Append(m_queue); sb.Append(",");
7001 sb.Append(m_consumerTag); sb.Append(",");
7002 sb.Append(m_noLocal); sb.Append(",");
7003 sb.Append(m_exclusive); sb.Append(",");
7004 sb.Append(m_nowait); sb.Append(",");
7005 sb.Append(m_filter);
7009 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7010 public class StreamConsumeOk: RabbitMQ.Client.Impl.MethodBase, IStreamConsumeOk {
7011 public const int ClassId = 80;
7012 public const int MethodId = 21;
7014 public string m_consumerTag;
7016 string IStreamConsumeOk.ConsumerTag { get { return m_consumerTag; } }
7018 public StreamConsumeOk() {}
7019 public StreamConsumeOk(
7020 string initConsumerTag)
7022 m_consumerTag = initConsumerTag;
7025 public override int ProtocolClassId { get { return 80; } }
7026 public override int ProtocolMethodId { get { return 21; } }
7027 public override string ProtocolMethodName { get { return "stream.consume-ok"; } }
7028 public override bool HasContent { get { return false; } }
7030 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7031 m_consumerTag = reader.ReadShortstr();
7034 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7035 writer.WriteShortstr(m_consumerTag);
7038 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7040 sb.Append(m_consumerTag);
7044 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7045 public class StreamCancel: RabbitMQ.Client.Impl.MethodBase, IStreamCancel {
7046 public const int ClassId = 80;
7047 public const int MethodId = 30;
7049 public string m_consumerTag;
7050 public bool m_nowait;
7052 string IStreamCancel.ConsumerTag { get { return m_consumerTag; } }
7053 bool IStreamCancel.Nowait { get { return m_nowait; } }
7055 public StreamCancel() {}
7056 public StreamCancel(
7057 string initConsumerTag,
7060 m_consumerTag = initConsumerTag;
7061 m_nowait = initNowait;
7064 public override int ProtocolClassId { get { return 80; } }
7065 public override int ProtocolMethodId { get { return 30; } }
7066 public override string ProtocolMethodName { get { return "stream.cancel"; } }
7067 public override bool HasContent { get { return false; } }
7069 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7070 m_consumerTag = reader.ReadShortstr();
7071 m_nowait = reader.ReadBit();
7074 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7075 writer.WriteShortstr(m_consumerTag);
7076 writer.WriteBit(m_nowait);
7079 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7081 sb.Append(m_consumerTag); sb.Append(",");
7082 sb.Append(m_nowait);
7086 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7087 public class StreamCancelOk: RabbitMQ.Client.Impl.MethodBase, IStreamCancelOk {
7088 public const int ClassId = 80;
7089 public const int MethodId = 31;
7091 public string m_consumerTag;
7093 string IStreamCancelOk.ConsumerTag { get { return m_consumerTag; } }
7095 public StreamCancelOk() {}
7096 public StreamCancelOk(
7097 string initConsumerTag)
7099 m_consumerTag = initConsumerTag;
7102 public override int ProtocolClassId { get { return 80; } }
7103 public override int ProtocolMethodId { get { return 31; } }
7104 public override string ProtocolMethodName { get { return "stream.cancel-ok"; } }
7105 public override bool HasContent { get { return false; } }
7107 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7108 m_consumerTag = reader.ReadShortstr();
7111 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7112 writer.WriteShortstr(m_consumerTag);
7115 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7117 sb.Append(m_consumerTag);
7121 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7122 public class StreamPublish: RabbitMQ.Client.Impl.MethodBase, IStreamPublish {
7123 public const int ClassId = 80;
7124 public const int MethodId = 40;
7126 public ushort m_ticket;
7127 public string m_exchange;
7128 public string m_routingKey;
7129 public bool m_mandatory;
7130 public bool m_immediate;
7132 ushort IStreamPublish.Ticket { get { return m_ticket; } }
7133 string IStreamPublish.Exchange { get { return m_exchange; } }
7134 string IStreamPublish.RoutingKey { get { return m_routingKey; } }
7135 bool IStreamPublish.Mandatory { get { return m_mandatory; } }
7136 bool IStreamPublish.Immediate { get { return m_immediate; } }
7138 public StreamPublish() {}
7139 public StreamPublish(
7141 string initExchange,
7142 string initRoutingKey,
7146 m_ticket = initTicket;
7147 m_exchange = initExchange;
7148 m_routingKey = initRoutingKey;
7149 m_mandatory = initMandatory;
7150 m_immediate = initImmediate;
7153 public override int ProtocolClassId { get { return 80; } }
7154 public override int ProtocolMethodId { get { return 40; } }
7155 public override string ProtocolMethodName { get { return "stream.publish"; } }
7156 public override bool HasContent { get { return true; } }
7158 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7159 m_ticket = reader.ReadShort();
7160 m_exchange = reader.ReadShortstr();
7161 m_routingKey = reader.ReadShortstr();
7162 m_mandatory = reader.ReadBit();
7163 m_immediate = reader.ReadBit();
7166 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7167 writer.WriteShort(m_ticket);
7168 writer.WriteShortstr(m_exchange);
7169 writer.WriteShortstr(m_routingKey);
7170 writer.WriteBit(m_mandatory);
7171 writer.WriteBit(m_immediate);
7174 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7176 sb.Append(m_ticket); sb.Append(",");
7177 sb.Append(m_exchange); sb.Append(",");
7178 sb.Append(m_routingKey); sb.Append(",");
7179 sb.Append(m_mandatory); sb.Append(",");
7180 sb.Append(m_immediate);
7184 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7185 public class StreamReturn: RabbitMQ.Client.Impl.MethodBase, IStreamReturn {
7186 public const int ClassId = 80;
7187 public const int MethodId = 50;
7189 public ushort m_replyCode;
7190 public string m_replyText;
7191 public string m_exchange;
7192 public string m_routingKey;
7194 ushort IStreamReturn.ReplyCode { get { return m_replyCode; } }
7195 string IStreamReturn.ReplyText { get { return m_replyText; } }
7196 string IStreamReturn.Exchange { get { return m_exchange; } }
7197 string IStreamReturn.RoutingKey { get { return m_routingKey; } }
7199 public StreamReturn() {}
7200 public StreamReturn(
7201 ushort initReplyCode,
7202 string initReplyText,
7203 string initExchange,
7204 string initRoutingKey)
7206 m_replyCode = initReplyCode;
7207 m_replyText = initReplyText;
7208 m_exchange = initExchange;
7209 m_routingKey = initRoutingKey;
7212 public override int ProtocolClassId { get { return 80; } }
7213 public override int ProtocolMethodId { get { return 50; } }
7214 public override string ProtocolMethodName { get { return "stream.return"; } }
7215 public override bool HasContent { get { return true; } }
7217 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7218 m_replyCode = reader.ReadShort();
7219 m_replyText = reader.ReadShortstr();
7220 m_exchange = reader.ReadShortstr();
7221 m_routingKey = reader.ReadShortstr();
7224 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7225 writer.WriteShort(m_replyCode);
7226 writer.WriteShortstr(m_replyText);
7227 writer.WriteShortstr(m_exchange);
7228 writer.WriteShortstr(m_routingKey);
7231 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7233 sb.Append(m_replyCode); sb.Append(",");
7234 sb.Append(m_replyText); sb.Append(",");
7235 sb.Append(m_exchange); sb.Append(",");
7236 sb.Append(m_routingKey);
7240 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7241 public class StreamDeliver: RabbitMQ.Client.Impl.MethodBase, IStreamDeliver {
7242 public const int ClassId = 80;
7243 public const int MethodId = 60;
7245 public string m_consumerTag;
7246 public ulong m_deliveryTag;
7247 public string m_exchange;
7248 public string m_queue;
7250 string IStreamDeliver.ConsumerTag { get { return m_consumerTag; } }
7251 ulong IStreamDeliver.DeliveryTag { get { return m_deliveryTag; } }
7252 string IStreamDeliver.Exchange { get { return m_exchange; } }
7253 string IStreamDeliver.Queue { get { return m_queue; } }
7255 public StreamDeliver() {}
7256 public StreamDeliver(
7257 string initConsumerTag,
7258 ulong initDeliveryTag,
7259 string initExchange,
7262 m_consumerTag = initConsumerTag;
7263 m_deliveryTag = initDeliveryTag;
7264 m_exchange = initExchange;
7265 m_queue = initQueue;
7268 public override int ProtocolClassId { get { return 80; } }
7269 public override int ProtocolMethodId { get { return 60; } }
7270 public override string ProtocolMethodName { get { return "stream.deliver"; } }
7271 public override bool HasContent { get { return true; } }
7273 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7274 m_consumerTag = reader.ReadShortstr();
7275 m_deliveryTag = reader.ReadLonglong();
7276 m_exchange = reader.ReadShortstr();
7277 m_queue = reader.ReadShortstr();
7280 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7281 writer.WriteShortstr(m_consumerTag);
7282 writer.WriteLonglong(m_deliveryTag);
7283 writer.WriteShortstr(m_exchange);
7284 writer.WriteShortstr(m_queue);
7287 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7289 sb.Append(m_consumerTag); sb.Append(",");
7290 sb.Append(m_deliveryTag); sb.Append(",");
7291 sb.Append(m_exchange); sb.Append(",");
7296 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7297 public class TxSelect: RabbitMQ.Client.Impl.MethodBase, ITxSelect {
7298 public const int ClassId = 90;
7299 public const int MethodId = 10;
7308 public override int ProtocolClassId { get { return 90; } }
7309 public override int ProtocolMethodId { get { return 10; } }
7310 public override string ProtocolMethodName { get { return "tx.select"; } }
7311 public override bool HasContent { get { return false; } }
7313 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7316 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7319 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7324 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7325 public class TxSelectOk: RabbitMQ.Client.Impl.MethodBase, ITxSelectOk {
7326 public const int ClassId = 90;
7327 public const int MethodId = 11;
7336 public override int ProtocolClassId { get { return 90; } }
7337 public override int ProtocolMethodId { get { return 11; } }
7338 public override string ProtocolMethodName { get { return "tx.select-ok"; } }
7339 public override bool HasContent { get { return false; } }
7341 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7344 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7347 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7352 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7353 public class TxCommit: RabbitMQ.Client.Impl.MethodBase, ITxCommit {
7354 public const int ClassId = 90;
7355 public const int MethodId = 20;
7364 public override int ProtocolClassId { get { return 90; } }
7365 public override int ProtocolMethodId { get { return 20; } }
7366 public override string ProtocolMethodName { get { return "tx.commit"; } }
7367 public override bool HasContent { get { return false; } }
7369 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7372 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7375 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7380 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7381 public class TxCommitOk: RabbitMQ.Client.Impl.MethodBase, ITxCommitOk {
7382 public const int ClassId = 90;
7383 public const int MethodId = 21;
7392 public override int ProtocolClassId { get { return 90; } }
7393 public override int ProtocolMethodId { get { return 21; } }
7394 public override string ProtocolMethodName { get { return "tx.commit-ok"; } }
7395 public override bool HasContent { get { return false; } }
7397 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7400 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7403 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7408 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7409 public class TxRollback: RabbitMQ.Client.Impl.MethodBase, ITxRollback {
7410 public const int ClassId = 90;
7411 public const int MethodId = 30;
7420 public override int ProtocolClassId { get { return 90; } }
7421 public override int ProtocolMethodId { get { return 30; } }
7422 public override string ProtocolMethodName { get { return "tx.rollback"; } }
7423 public override bool HasContent { get { return false; } }
7425 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7428 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7431 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7436 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7437 public class TxRollbackOk: RabbitMQ.Client.Impl.MethodBase, ITxRollbackOk {
7438 public const int ClassId = 90;
7439 public const int MethodId = 31;
7443 public TxRollbackOk(
7448 public override int ProtocolClassId { get { return 90; } }
7449 public override int ProtocolMethodId { get { return 31; } }
7450 public override string ProtocolMethodName { get { return "tx.rollback-ok"; } }
7451 public override bool HasContent { get { return false; } }
7453 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7456 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7459 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7464 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7465 public class DtxSelect: RabbitMQ.Client.Impl.MethodBase, IDtxSelect {
7466 public const int ClassId = 100;
7467 public const int MethodId = 10;
7476 public override int ProtocolClassId { get { return 100; } }
7477 public override int ProtocolMethodId { get { return 10; } }
7478 public override string ProtocolMethodName { get { return "dtx.select"; } }
7479 public override bool HasContent { get { return false; } }
7481 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7484 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7487 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7492 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7493 public class DtxSelectOk: RabbitMQ.Client.Impl.MethodBase, IDtxSelectOk {
7494 public const int ClassId = 100;
7495 public const int MethodId = 11;
7504 public override int ProtocolClassId { get { return 100; } }
7505 public override int ProtocolMethodId { get { return 11; } }
7506 public override string ProtocolMethodName { get { return "dtx.select-ok"; } }
7507 public override bool HasContent { get { return false; } }
7509 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7512 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7515 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7520 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7521 public class DtxStart: RabbitMQ.Client.Impl.MethodBase, IDtxStart {
7522 public const int ClassId = 100;
7523 public const int MethodId = 20;
7525 public string m_dtxIdentifier;
7527 string IDtxStart.DtxIdentifier { get { return m_dtxIdentifier; } }
7529 public DtxStart() {}
7531 string initDtxIdentifier)
7533 m_dtxIdentifier = initDtxIdentifier;
7536 public override int ProtocolClassId { get { return 100; } }
7537 public override int ProtocolMethodId { get { return 20; } }
7538 public override string ProtocolMethodName { get { return "dtx.start"; } }
7539 public override bool HasContent { get { return false; } }
7541 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7542 m_dtxIdentifier = reader.ReadShortstr();
7545 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7546 writer.WriteShortstr(m_dtxIdentifier);
7549 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7551 sb.Append(m_dtxIdentifier);
7555 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7556 public class DtxStartOk: RabbitMQ.Client.Impl.MethodBase, IDtxStartOk {
7557 public const int ClassId = 100;
7558 public const int MethodId = 21;
7567 public override int ProtocolClassId { get { return 100; } }
7568 public override int ProtocolMethodId { get { return 21; } }
7569 public override string ProtocolMethodName { get { return "dtx.start-ok"; } }
7570 public override bool HasContent { get { return false; } }
7572 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7575 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7578 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7583 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7584 public class TunnelRequest: RabbitMQ.Client.Impl.MethodBase, ITunnelRequest {
7585 public const int ClassId = 110;
7586 public const int MethodId = 10;
7588 public System.Collections.IDictionary m_metaData;
7590 System.Collections.IDictionary ITunnelRequest.MetaData { get { return m_metaData; } }
7592 public TunnelRequest() {}
7593 public TunnelRequest(
7594 System.Collections.IDictionary initMetaData)
7596 m_metaData = initMetaData;
7599 public override int ProtocolClassId { get { return 110; } }
7600 public override int ProtocolMethodId { get { return 10; } }
7601 public override string ProtocolMethodName { get { return "tunnel.request"; } }
7602 public override bool HasContent { get { return true; } }
7604 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7605 m_metaData = reader.ReadTable();
7608 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7609 writer.WriteTable(m_metaData);
7612 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7614 sb.Append(m_metaData);
7618 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7619 public class MessageTransfer: RabbitMQ.Client.Impl.MethodBase, IMessageTransfer {
7620 public const int ClassId = 120;
7621 public const int MethodId = 10;
7623 public ushort m_ticket;
7624 public string m_destination;
7625 public bool m_redelivered;
7626 public bool m_immediate;
7628 public byte m_priority;
7629 public AmqpTimestamp m_timestamp;
7630 public byte m_deliveryMode;
7631 public AmqpTimestamp m_expiration;
7632 public string m_exchange;
7633 public string m_routingKey;
7634 public string m_messageId;
7635 public string m_correlationId;
7636 public string m_replyTo;
7637 public string m_contentType;
7638 public string m_contentEncoding;
7639 public string m_userId;
7640 public string m_appId;
7641 public string m_transactionId;
7642 public byte[] m_securityToken;
7643 public System.Collections.IDictionary m_applicationHeaders;
7644 public byte[] m_body;
7646 ushort IMessageTransfer.Ticket { get { return m_ticket; } }
7647 string IMessageTransfer.Destination { get { return m_destination; } }
7648 bool IMessageTransfer.Redelivered { get { return m_redelivered; } }
7649 bool IMessageTransfer.Immediate { get { return m_immediate; } }
7650 ulong IMessageTransfer.Ttl { get { return m_ttl; } }
7651 byte IMessageTransfer.Priority { get { return m_priority; } }
7652 AmqpTimestamp IMessageTransfer.Timestamp { get { return m_timestamp; } }
7653 byte IMessageTransfer.DeliveryMode { get { return m_deliveryMode; } }
7654 AmqpTimestamp IMessageTransfer.Expiration { get { return m_expiration; } }
7655 string IMessageTransfer.Exchange { get { return m_exchange; } }
7656 string IMessageTransfer.RoutingKey { get { return m_routingKey; } }
7657 string IMessageTransfer.MessageId { get { return m_messageId; } }
7658 string IMessageTransfer.CorrelationId { get { return m_correlationId; } }
7659 string IMessageTransfer.ReplyTo { get { return m_replyTo; } }
7660 string IMessageTransfer.ContentType { get { return m_contentType; } }
7661 string IMessageTransfer.ContentEncoding { get { return m_contentEncoding; } }
7662 string IMessageTransfer.UserId { get { return m_userId; } }
7663 string IMessageTransfer.AppId { get { return m_appId; } }
7664 string IMessageTransfer.TransactionId { get { return m_transactionId; } }
7665 byte[] IMessageTransfer.SecurityToken { get { return m_securityToken; } }
7666 System.Collections.IDictionary IMessageTransfer.ApplicationHeaders { get { return m_applicationHeaders; } }
7667 byte[] IMessageTransfer.Body { get { return m_body; } }
7669 public MessageTransfer() {}
7670 public MessageTransfer(
7672 string initDestination,
7673 bool initRedelivered,
7677 AmqpTimestamp initTimestamp,
7678 byte initDeliveryMode,
7679 AmqpTimestamp initExpiration,
7680 string initExchange,
7681 string initRoutingKey,
7682 string initMessageId,
7683 string initCorrelationId,
7685 string initContentType,
7686 string initContentEncoding,
7689 string initTransactionId,
7690 byte[] initSecurityToken,
7691 System.Collections.IDictionary initApplicationHeaders,
7694 m_ticket = initTicket;
7695 m_destination = initDestination;
7696 m_redelivered = initRedelivered;
7697 m_immediate = initImmediate;
7699 m_priority = initPriority;
7700 m_timestamp = initTimestamp;
7701 m_deliveryMode = initDeliveryMode;
7702 m_expiration = initExpiration;
7703 m_exchange = initExchange;
7704 m_routingKey = initRoutingKey;
7705 m_messageId = initMessageId;
7706 m_correlationId = initCorrelationId;
7707 m_replyTo = initReplyTo;
7708 m_contentType = initContentType;
7709 m_contentEncoding = initContentEncoding;
7710 m_userId = initUserId;
7711 m_appId = initAppId;
7712 m_transactionId = initTransactionId;
7713 m_securityToken = initSecurityToken;
7714 m_applicationHeaders = initApplicationHeaders;
7718 public override int ProtocolClassId { get { return 120; } }
7719 public override int ProtocolMethodId { get { return 10; } }
7720 public override string ProtocolMethodName { get { return "message.transfer"; } }
7721 public override bool HasContent { get { return false; } }
7723 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7724 m_ticket = reader.ReadShort();
7725 m_destination = reader.ReadShortstr();
7726 m_redelivered = reader.ReadBit();
7727 m_immediate = reader.ReadBit();
7728 m_ttl = reader.ReadLonglong();
7729 m_priority = reader.ReadOctet();
7730 m_timestamp = reader.ReadTimestamp();
7731 m_deliveryMode = reader.ReadOctet();
7732 m_expiration = reader.ReadTimestamp();
7733 m_exchange = reader.ReadShortstr();
7734 m_routingKey = reader.ReadShortstr();
7735 m_messageId = reader.ReadShortstr();
7736 m_correlationId = reader.ReadShortstr();
7737 m_replyTo = reader.ReadShortstr();
7738 m_contentType = reader.ReadShortstr();
7739 m_contentEncoding = reader.ReadShortstr();
7740 m_userId = reader.ReadShortstr();
7741 m_appId = reader.ReadShortstr();
7742 m_transactionId = reader.ReadShortstr();
7743 m_securityToken = reader.ReadLongstr();
7744 m_applicationHeaders = reader.ReadTable();
7745 m_body = reader.ReadContent();
7748 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7749 writer.WriteShort(m_ticket);
7750 writer.WriteShortstr(m_destination);
7751 writer.WriteBit(m_redelivered);
7752 writer.WriteBit(m_immediate);
7753 writer.WriteLonglong(m_ttl);
7754 writer.WriteOctet(m_priority);
7755 writer.WriteTimestamp(m_timestamp);
7756 writer.WriteOctet(m_deliveryMode);
7757 writer.WriteTimestamp(m_expiration);
7758 writer.WriteShortstr(m_exchange);
7759 writer.WriteShortstr(m_routingKey);
7760 writer.WriteShortstr(m_messageId);
7761 writer.WriteShortstr(m_correlationId);
7762 writer.WriteShortstr(m_replyTo);
7763 writer.WriteShortstr(m_contentType);
7764 writer.WriteShortstr(m_contentEncoding);
7765 writer.WriteShortstr(m_userId);
7766 writer.WriteShortstr(m_appId);
7767 writer.WriteShortstr(m_transactionId);
7768 writer.WriteLongstr(m_securityToken);
7769 writer.WriteTable(m_applicationHeaders);
7770 writer.WriteContent(m_body);
7773 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7775 sb.Append(m_ticket); sb.Append(",");
7776 sb.Append(m_destination); sb.Append(",");
7777 sb.Append(m_redelivered); sb.Append(",");
7778 sb.Append(m_immediate); sb.Append(",");
7779 sb.Append(m_ttl); sb.Append(",");
7780 sb.Append(m_priority); sb.Append(",");
7781 sb.Append(m_timestamp); sb.Append(",");
7782 sb.Append(m_deliveryMode); sb.Append(",");
7783 sb.Append(m_expiration); sb.Append(",");
7784 sb.Append(m_exchange); sb.Append(",");
7785 sb.Append(m_routingKey); sb.Append(",");
7786 sb.Append(m_messageId); sb.Append(",");
7787 sb.Append(m_correlationId); sb.Append(",");
7788 sb.Append(m_replyTo); sb.Append(",");
7789 sb.Append(m_contentType); sb.Append(",");
7790 sb.Append(m_contentEncoding); sb.Append(",");
7791 sb.Append(m_userId); sb.Append(",");
7792 sb.Append(m_appId); sb.Append(",");
7793 sb.Append(m_transactionId); sb.Append(",");
7794 sb.Append(m_securityToken); sb.Append(",");
7795 sb.Append(m_applicationHeaders); sb.Append(",");
7800 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7801 public class MessageConsume: RabbitMQ.Client.Impl.MethodBase, IMessageConsume {
7802 public const int ClassId = 120;
7803 public const int MethodId = 20;
7805 public ushort m_ticket;
7806 public string m_queue;
7807 public string m_destination;
7808 public bool m_noLocal;
7809 public bool m_noAck;
7810 public bool m_exclusive;
7811 public System.Collections.IDictionary m_filter;
7813 ushort IMessageConsume.Ticket { get { return m_ticket; } }
7814 string IMessageConsume.Queue { get { return m_queue; } }
7815 string IMessageConsume.Destination { get { return m_destination; } }
7816 bool IMessageConsume.NoLocal { get { return m_noLocal; } }
7817 bool IMessageConsume.NoAck { get { return m_noAck; } }
7818 bool IMessageConsume.Exclusive { get { return m_exclusive; } }
7819 System.Collections.IDictionary IMessageConsume.Filter { get { return m_filter; } }
7821 public MessageConsume() {}
7822 public MessageConsume(
7825 string initDestination,
7829 System.Collections.IDictionary initFilter)
7831 m_ticket = initTicket;
7832 m_queue = initQueue;
7833 m_destination = initDestination;
7834 m_noLocal = initNoLocal;
7835 m_noAck = initNoAck;
7836 m_exclusive = initExclusive;
7837 m_filter = initFilter;
7840 public override int ProtocolClassId { get { return 120; } }
7841 public override int ProtocolMethodId { get { return 20; } }
7842 public override string ProtocolMethodName { get { return "message.consume"; } }
7843 public override bool HasContent { get { return false; } }
7845 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7846 m_ticket = reader.ReadShort();
7847 m_queue = reader.ReadShortstr();
7848 m_destination = reader.ReadShortstr();
7849 m_noLocal = reader.ReadBit();
7850 m_noAck = reader.ReadBit();
7851 m_exclusive = reader.ReadBit();
7852 m_filter = reader.ReadTable();
7855 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7856 writer.WriteShort(m_ticket);
7857 writer.WriteShortstr(m_queue);
7858 writer.WriteShortstr(m_destination);
7859 writer.WriteBit(m_noLocal);
7860 writer.WriteBit(m_noAck);
7861 writer.WriteBit(m_exclusive);
7862 writer.WriteTable(m_filter);
7865 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7867 sb.Append(m_ticket); sb.Append(",");
7868 sb.Append(m_queue); sb.Append(",");
7869 sb.Append(m_destination); sb.Append(",");
7870 sb.Append(m_noLocal); sb.Append(",");
7871 sb.Append(m_noAck); sb.Append(",");
7872 sb.Append(m_exclusive); sb.Append(",");
7873 sb.Append(m_filter);
7877 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7878 public class MessageCancel: RabbitMQ.Client.Impl.MethodBase, IMessageCancel {
7879 public const int ClassId = 120;
7880 public const int MethodId = 30;
7882 public string m_destination;
7884 string IMessageCancel.Destination { get { return m_destination; } }
7886 public MessageCancel() {}
7887 public MessageCancel(
7888 string initDestination)
7890 m_destination = initDestination;
7893 public override int ProtocolClassId { get { return 120; } }
7894 public override int ProtocolMethodId { get { return 30; } }
7895 public override string ProtocolMethodName { get { return "message.cancel"; } }
7896 public override bool HasContent { get { return false; } }
7898 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7899 m_destination = reader.ReadShortstr();
7902 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7903 writer.WriteShortstr(m_destination);
7906 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7908 sb.Append(m_destination);
7912 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7913 public class MessageGet: RabbitMQ.Client.Impl.MethodBase, IMessageGet {
7914 public const int ClassId = 120;
7915 public const int MethodId = 40;
7917 public ushort m_ticket;
7918 public string m_queue;
7919 public string m_destination;
7920 public bool m_noAck;
7922 ushort IMessageGet.Ticket { get { return m_ticket; } }
7923 string IMessageGet.Queue { get { return m_queue; } }
7924 string IMessageGet.Destination { get { return m_destination; } }
7925 bool IMessageGet.NoAck { get { return m_noAck; } }
7927 public MessageGet() {}
7931 string initDestination,
7934 m_ticket = initTicket;
7935 m_queue = initQueue;
7936 m_destination = initDestination;
7937 m_noAck = initNoAck;
7940 public override int ProtocolClassId { get { return 120; } }
7941 public override int ProtocolMethodId { get { return 40; } }
7942 public override string ProtocolMethodName { get { return "message.get"; } }
7943 public override bool HasContent { get { return false; } }
7945 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7946 m_ticket = reader.ReadShort();
7947 m_queue = reader.ReadShortstr();
7948 m_destination = reader.ReadShortstr();
7949 m_noAck = reader.ReadBit();
7952 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7953 writer.WriteShort(m_ticket);
7954 writer.WriteShortstr(m_queue);
7955 writer.WriteShortstr(m_destination);
7956 writer.WriteBit(m_noAck);
7959 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7961 sb.Append(m_ticket); sb.Append(",");
7962 sb.Append(m_queue); sb.Append(",");
7963 sb.Append(m_destination); sb.Append(",");
7968 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
7969 public class MessageRecover: RabbitMQ.Client.Impl.MethodBase, IMessageRecover {
7970 public const int ClassId = 120;
7971 public const int MethodId = 50;
7973 public bool m_requeue;
7975 bool IMessageRecover.Requeue { get { return m_requeue; } }
7977 public MessageRecover() {}
7978 public MessageRecover(
7981 m_requeue = initRequeue;
7984 public override int ProtocolClassId { get { return 120; } }
7985 public override int ProtocolMethodId { get { return 50; } }
7986 public override string ProtocolMethodName { get { return "message.recover"; } }
7987 public override bool HasContent { get { return false; } }
7989 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
7990 m_requeue = reader.ReadBit();
7993 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
7994 writer.WriteBit(m_requeue);
7997 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
7999 sb.Append(m_requeue);
8003 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
8004 public class MessageOpen: RabbitMQ.Client.Impl.MethodBase, IMessageOpen {
8005 public const int ClassId = 120;
8006 public const int MethodId = 60;
8008 public byte[] m_reference;
8010 byte[] IMessageOpen.Reference { get { return m_reference; } }
8012 public MessageOpen() {}
8014 byte[] initReference)
8016 m_reference = initReference;
8019 public override int ProtocolClassId { get { return 120; } }
8020 public override int ProtocolMethodId { get { return 60; } }
8021 public override string ProtocolMethodName { get { return "message.open"; } }
8022 public override bool HasContent { get { return false; } }
8024 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
8025 m_reference = reader.ReadLongstr();
8028 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
8029 writer.WriteLongstr(m_reference);
8032 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
8034 sb.Append(m_reference);
8038 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
8039 public class MessageClose: RabbitMQ.Client.Impl.MethodBase, IMessageClose {
8040 public const int ClassId = 120;
8041 public const int MethodId = 70;
8043 public byte[] m_reference;
8045 byte[] IMessageClose.Reference { get { return m_reference; } }
8047 public MessageClose() {}
8048 public MessageClose(
8049 byte[] initReference)
8051 m_reference = initReference;
8054 public override int ProtocolClassId { get { return 120; } }
8055 public override int ProtocolMethodId { get { return 70; } }
8056 public override string ProtocolMethodName { get { return "message.close"; } }
8057 public override bool HasContent { get { return false; } }
8059 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
8060 m_reference = reader.ReadLongstr();
8063 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
8064 writer.WriteLongstr(m_reference);
8067 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
8069 sb.Append(m_reference);
8073 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
8074 public class MessageAppend: RabbitMQ.Client.Impl.MethodBase, IMessageAppend {
8075 public const int ClassId = 120;
8076 public const int MethodId = 80;
8078 public byte[] m_reference;
8079 public byte[] m_bytes;
8081 byte[] IMessageAppend.Reference { get { return m_reference; } }
8082 byte[] IMessageAppend.Bytes { get { return m_bytes; } }
8084 public MessageAppend() {}
8085 public MessageAppend(
8086 byte[] initReference,
8089 m_reference = initReference;
8090 m_bytes = initBytes;
8093 public override int ProtocolClassId { get { return 120; } }
8094 public override int ProtocolMethodId { get { return 80; } }
8095 public override string ProtocolMethodName { get { return "message.append"; } }
8096 public override bool HasContent { get { return false; } }
8098 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
8099 m_reference = reader.ReadLongstr();
8100 m_bytes = reader.ReadLongstr();
8103 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
8104 writer.WriteLongstr(m_reference);
8105 writer.WriteLongstr(m_bytes);
8108 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
8110 sb.Append(m_reference); sb.Append(",");
8115 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
8116 public class MessageCheckpoint: RabbitMQ.Client.Impl.MethodBase, IMessageCheckpoint {
8117 public const int ClassId = 120;
8118 public const int MethodId = 90;
8120 public byte[] m_reference;
8121 public string m_identifier;
8123 byte[] IMessageCheckpoint.Reference { get { return m_reference; } }
8124 string IMessageCheckpoint.Identifier { get { return m_identifier; } }
8126 public MessageCheckpoint() {}
8127 public MessageCheckpoint(
8128 byte[] initReference,
8129 string initIdentifier)
8131 m_reference = initReference;
8132 m_identifier = initIdentifier;
8135 public override int ProtocolClassId { get { return 120; } }
8136 public override int ProtocolMethodId { get { return 90; } }
8137 public override string ProtocolMethodName { get { return "message.checkpoint"; } }
8138 public override bool HasContent { get { return false; } }
8140 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
8141 m_reference = reader.ReadLongstr();
8142 m_identifier = reader.ReadShortstr();
8145 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
8146 writer.WriteLongstr(m_reference);
8147 writer.WriteShortstr(m_identifier);
8150 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
8152 sb.Append(m_reference); sb.Append(",");
8153 sb.Append(m_identifier);
8157 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
8158 public class MessageResume: RabbitMQ.Client.Impl.MethodBase, IMessageResume {
8159 public const int ClassId = 120;
8160 public const int MethodId = 100;
8162 public byte[] m_reference;
8163 public string m_identifier;
8165 byte[] IMessageResume.Reference { get { return m_reference; } }
8166 string IMessageResume.Identifier { get { return m_identifier; } }
8168 public MessageResume() {}
8169 public MessageResume(
8170 byte[] initReference,
8171 string initIdentifier)
8173 m_reference = initReference;
8174 m_identifier = initIdentifier;
8177 public override int ProtocolClassId { get { return 120; } }
8178 public override int ProtocolMethodId { get { return 100; } }
8179 public override string ProtocolMethodName { get { return "message.resume"; } }
8180 public override bool HasContent { get { return false; } }
8182 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
8183 m_reference = reader.ReadLongstr();
8184 m_identifier = reader.ReadShortstr();
8187 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
8188 writer.WriteLongstr(m_reference);
8189 writer.WriteShortstr(m_identifier);
8192 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
8194 sb.Append(m_reference); sb.Append(",");
8195 sb.Append(m_identifier);
8199 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
8200 public class MessageQos: RabbitMQ.Client.Impl.MethodBase, IMessageQos {
8201 public const int ClassId = 120;
8202 public const int MethodId = 110;
8204 public uint m_prefetchSize;
8205 public ushort m_prefetchCount;
8206 public bool m_global;
8208 uint IMessageQos.PrefetchSize { get { return m_prefetchSize; } }
8209 ushort IMessageQos.PrefetchCount { get { return m_prefetchCount; } }
8210 bool IMessageQos.Global { get { return m_global; } }
8212 public MessageQos() {}
8214 uint initPrefetchSize,
8215 ushort initPrefetchCount,
8218 m_prefetchSize = initPrefetchSize;
8219 m_prefetchCount = initPrefetchCount;
8220 m_global = initGlobal;
8223 public override int ProtocolClassId { get { return 120; } }
8224 public override int ProtocolMethodId { get { return 110; } }
8225 public override string ProtocolMethodName { get { return "message.qos"; } }
8226 public override bool HasContent { get { return false; } }
8228 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
8229 m_prefetchSize = reader.ReadLong();
8230 m_prefetchCount = reader.ReadShort();
8231 m_global = reader.ReadBit();
8234 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
8235 writer.WriteLong(m_prefetchSize);
8236 writer.WriteShort(m_prefetchCount);
8237 writer.WriteBit(m_global);
8240 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
8242 sb.Append(m_prefetchSize); sb.Append(",");
8243 sb.Append(m_prefetchCount); sb.Append(",");
8244 sb.Append(m_global);
8248 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
8249 public class MessageOk: RabbitMQ.Client.Impl.MethodBase, IMessageOk {
8250 public const int ClassId = 120;
8251 public const int MethodId = 500;
8260 public override int ProtocolClassId { get { return 120; } }
8261 public override int ProtocolMethodId { get { return 500; } }
8262 public override string ProtocolMethodName { get { return "message.ok"; } }
8263 public override bool HasContent { get { return false; } }
8265 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
8268 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
8271 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
8276 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
8277 public class MessageEmpty: RabbitMQ.Client.Impl.MethodBase, IMessageEmpty {
8278 public const int ClassId = 120;
8279 public const int MethodId = 510;
8283 public MessageEmpty(
8288 public override int ProtocolClassId { get { return 120; } }
8289 public override int ProtocolMethodId { get { return 510; } }
8290 public override string ProtocolMethodName { get { return "message.empty"; } }
8291 public override bool HasContent { get { return false; } }
8293 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
8296 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
8299 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
8304 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
8305 public class MessageReject: RabbitMQ.Client.Impl.MethodBase, IMessageReject {
8306 public const int ClassId = 120;
8307 public const int MethodId = 520;
8309 public ushort m_code;
8310 public string m_text;
8312 ushort IMessageReject.Code { get { return m_code; } }
8313 string IMessageReject.Text { get { return m_text; } }
8315 public MessageReject() {}
8316 public MessageReject(
8324 public override int ProtocolClassId { get { return 120; } }
8325 public override int ProtocolMethodId { get { return 520; } }
8326 public override string ProtocolMethodName { get { return "message.reject"; } }
8327 public override bool HasContent { get { return false; } }
8329 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
8330 m_code = reader.ReadShort();
8331 m_text = reader.ReadShortstr();
8334 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
8335 writer.WriteShort(m_code);
8336 writer.WriteShortstr(m_text);
8339 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
8341 sb.Append(m_code); sb.Append(",");
8346 /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
8347 public class MessageOffset: RabbitMQ.Client.Impl.MethodBase, IMessageOffset {
8348 public const int ClassId = 120;
8349 public const int MethodId = 530;
8351 public ulong m_value;
8353 ulong IMessageOffset.Value { get { return m_value; } }
8355 public MessageOffset() {}
8356 public MessageOffset(
8359 m_value = initValue;
8362 public override int ProtocolClassId { get { return 120; } }
8363 public override int ProtocolMethodId { get { return 530; } }
8364 public override string ProtocolMethodName { get { return "message.offset"; } }
8365 public override bool HasContent { get { return false; } }
8367 public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
8368 m_value = reader.ReadLonglong();
8371 public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
8372 writer.WriteLonglong(m_value);
8375 public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
8382 public class Model: RabbitMQ.Client.Impl.ModelBase {
8383 public Model(RabbitMQ.Client.Impl.ISession session): base(session) {}
8384 public override void _Private_BasicPublish(
8385 System.String @exchange,
8386 System.String @routingKey,
8387 System.Boolean @mandatory,
8388 System.Boolean @immediate,
8389 RabbitMQ.Client.IBasicProperties @basicProperties,
8390 System.Byte[] @body)
8392 BasicPublish __req = new BasicPublish();
8393 __req.m_exchange = @exchange;
8394 __req.m_routingKey = @routingKey;
8395 __req.m_mandatory = @mandatory;
8396 __req.m_immediate = @immediate;
8397 ModelSend(__req, (BasicProperties) basicProperties,body);
8399 public override void _Private_BasicConsume(
8400 System.String @queue,
8401 System.String @consumerTag,
8402 System.Boolean @noLocal,
8403 System.Boolean @noAck,
8404 System.Boolean @exclusive,
8405 System.Boolean @nowait,
8406 System.Collections.IDictionary @filter)
8408 BasicConsume __req = new BasicConsume();
8409 __req.m_queue = @queue;
8410 __req.m_consumerTag = @consumerTag;
8411 __req.m_noLocal = @noLocal;
8412 __req.m_noAck = @noAck;
8413 __req.m_exclusive = @exclusive;
8414 __req.m_nowait = @nowait;
8415 __req.m_filter = @filter;
8416 ModelSend(__req,null,null);
8418 public override void _Private_BasicCancel(
8419 System.String @consumerTag,
8420 System.Boolean @nowait)
8422 BasicCancel __req = new BasicCancel();
8423 __req.m_consumerTag = @consumerTag;
8424 __req.m_nowait = @nowait;
8425 ModelSend(__req,null,null);
8427 public override void _Private_ChannelOpen(
8428 System.String @outOfBand)
8430 ChannelOpen __req = new ChannelOpen();
8431 __req.m_outOfBand = @outOfBand;
8432 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8433 ChannelOpenOk __rep = __repBase as ChannelOpenOk;
8434 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8436 public override void _Private_ChannelCloseOk()
8438 ChannelCloseOk __req = new ChannelCloseOk();
8439 ModelSend(__req,null,null);
8441 public override void _Private_ChannelClose(
8442 System.UInt16 @replyCode,
8443 System.String @replyText,
8444 System.UInt16 @classId,
8445 System.UInt16 @methodId)
8447 ChannelClose __req = new ChannelClose();
8448 __req.m_replyCode = @replyCode;
8449 __req.m_replyText = @replyText;
8450 __req.m_classId = @classId;
8451 __req.m_methodId = @methodId;
8452 ModelSend(__req,null,null);
8454 public override void _Private_BasicGet(
8455 System.String @queue,
8456 System.Boolean @noAck)
8458 BasicGet __req = new BasicGet();
8459 __req.m_queue = @queue;
8460 __req.m_noAck = @noAck;
8461 ModelSend(__req,null,null);
8463 public override void _Private_ChannelFlowOk()
8465 ChannelFlowOk __req = new ChannelFlowOk();
8466 ModelSend(__req,null,null);
8468 public override RabbitMQ.Client.Impl.ConnectionTuneDetails ConnectionStartOk(
8469 System.Collections.IDictionary @clientProperties,
8470 System.String @mechanism,
8471 System.Byte[] @response,
8472 System.String @locale)
8474 ConnectionStartOk __req = new ConnectionStartOk();
8475 __req.m_clientProperties = @clientProperties;
8476 __req.m_mechanism = @mechanism;
8477 __req.m_response = @response;
8478 __req.m_locale = @locale;
8479 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8480 ConnectionTune __rep = __repBase as ConnectionTune;
8481 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8482 RabbitMQ.Client.Impl.ConnectionTuneDetails __result = new RabbitMQ.Client.Impl.ConnectionTuneDetails();
8483 __result.channelMax = __rep.m_channelMax;
8484 __result.frameMax = __rep.m_frameMax;
8485 __result.heartbeat = __rep.m_heartbeat;
8488 public override void ConnectionTuneOk(
8489 System.UInt16 @channelMax,
8490 System.UInt32 @frameMax,
8491 System.UInt16 @heartbeat)
8493 ConnectionTuneOk __req = new ConnectionTuneOk();
8494 __req.m_channelMax = @channelMax;
8495 __req.m_frameMax = @frameMax;
8496 __req.m_heartbeat = @heartbeat;
8497 ModelSend(__req,null,null);
8499 public override void _Private_ConnectionOpen(
8500 System.String @virtualHost,
8501 System.String @capabilities,
8502 System.Boolean @insist)
8504 ConnectionOpen __req = new ConnectionOpen();
8505 __req.m_virtualHost = @virtualHost;
8506 __req.m_capabilities = @capabilities;
8507 __req.m_insist = @insist;
8508 ModelSend(__req,null,null);
8510 public override void _Private_ConnectionClose(
8511 System.UInt16 @replyCode,
8512 System.String @replyText,
8513 System.UInt16 @classId,
8514 System.UInt16 @methodId)
8516 ConnectionClose __req = new ConnectionClose();
8517 __req.m_replyCode = @replyCode;
8518 __req.m_replyText = @replyText;
8519 __req.m_classId = @classId;
8520 __req.m_methodId = @methodId;
8521 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8522 ConnectionCloseOk __rep = __repBase as ConnectionCloseOk;
8523 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8525 public override void _Private_ConnectionCloseOk()
8527 ConnectionCloseOk __req = new ConnectionCloseOk();
8528 ModelSend(__req,null,null);
8530 public override RabbitMQ.Client.IBasicProperties CreateBasicProperties()
8532 return new BasicProperties();
8534 public override RabbitMQ.Client.IFileProperties CreateFileProperties()
8536 return new FileProperties();
8538 public override RabbitMQ.Client.IStreamProperties CreateStreamProperties()
8540 return new StreamProperties();
8542 public override void ChannelFlow(
8543 System.Boolean @active)
8545 ChannelFlow __req = new ChannelFlow();
8546 __req.m_active = @active;
8547 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8548 ChannelFlowOk __rep = __repBase as ChannelFlowOk;
8549 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8551 public override void ExchangeDeclare(
8552 System.String @exchange,
8553 System.String @type,
8554 System.Boolean @passive,
8555 System.Boolean @durable,
8556 System.Boolean @autoDelete,
8557 System.Boolean @internal,
8558 System.Boolean @nowait,
8559 System.Collections.IDictionary @arguments)
8561 ExchangeDeclare __req = new ExchangeDeclare();
8562 __req.m_exchange = @exchange;
8563 __req.m_type = @type;
8564 __req.m_passive = @passive;
8565 __req.m_durable = @durable;
8566 __req.m_autoDelete = @autoDelete;
8567 __req.m_internal = @internal;
8568 __req.m_nowait = @nowait;
8569 __req.m_arguments = @arguments;
8571 ModelSend(__req,null,null);
8573 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8574 ExchangeDeclareOk __rep = __repBase as ExchangeDeclareOk;
8575 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8577 public override void ExchangeDelete(
8578 System.String @exchange,
8579 System.Boolean @ifUnused,
8580 System.Boolean @nowait)
8582 ExchangeDelete __req = new ExchangeDelete();
8583 __req.m_exchange = @exchange;
8584 __req.m_ifUnused = @ifUnused;
8585 __req.m_nowait = @nowait;
8587 ModelSend(__req,null,null);
8589 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8590 ExchangeDeleteOk __rep = __repBase as ExchangeDeleteOk;
8591 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8593 public override System.String QueueDeclare(
8594 System.String @queue,
8595 System.Boolean @passive,
8596 System.Boolean @durable,
8597 System.Boolean @exclusive,
8598 System.Boolean @autoDelete,
8599 System.Boolean @nowait,
8600 System.Collections.IDictionary @arguments)
8602 QueueDeclare __req = new QueueDeclare();
8603 __req.m_queue = @queue;
8604 __req.m_passive = @passive;
8605 __req.m_durable = @durable;
8606 __req.m_exclusive = @exclusive;
8607 __req.m_autoDelete = @autoDelete;
8608 __req.m_nowait = @nowait;
8609 __req.m_arguments = @arguments;
8611 ModelSend(__req,null,null);
8614 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8615 QueueDeclareOk __rep = __repBase as QueueDeclareOk;
8616 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8617 return __rep.m_queue;
8619 public override void QueueBind(
8620 System.String @queue,
8621 System.String @exchange,
8622 System.String @routingKey,
8623 System.Boolean @nowait,
8624 System.Collections.IDictionary @arguments)
8626 QueueBind __req = new QueueBind();
8627 __req.m_queue = @queue;
8628 __req.m_exchange = @exchange;
8629 __req.m_routingKey = @routingKey;
8630 __req.m_nowait = @nowait;
8631 __req.m_arguments = @arguments;
8633 ModelSend(__req,null,null);
8635 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8636 QueueBindOk __rep = __repBase as QueueBindOk;
8637 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8639 public override void QueueUnbind(
8640 System.String @queue,
8641 System.String @exchange,
8642 System.String @routingKey,
8643 System.Collections.IDictionary @arguments)
8645 QueueUnbind __req = new QueueUnbind();
8646 __req.m_queue = @queue;
8647 __req.m_exchange = @exchange;
8648 __req.m_routingKey = @routingKey;
8649 __req.m_arguments = @arguments;
8650 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8651 QueueUnbindOk __rep = __repBase as QueueUnbindOk;
8652 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8654 public override System.UInt32 QueuePurge(
8655 System.String @queue,
8656 System.Boolean @nowait)
8658 QueuePurge __req = new QueuePurge();
8659 __req.m_queue = @queue;
8660 __req.m_nowait = @nowait;
8662 ModelSend(__req,null,null);
8665 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8666 QueuePurgeOk __rep = __repBase as QueuePurgeOk;
8667 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8668 return __rep.m_messageCount;
8670 public override System.UInt32 QueueDelete(
8671 System.String @queue,
8672 System.Boolean @ifUnused,
8673 System.Boolean @ifEmpty,
8674 System.Boolean @nowait)
8676 QueueDelete __req = new QueueDelete();
8677 __req.m_queue = @queue;
8678 __req.m_ifUnused = @ifUnused;
8679 __req.m_ifEmpty = @ifEmpty;
8680 __req.m_nowait = @nowait;
8682 ModelSend(__req,null,null);
8685 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8686 QueueDeleteOk __rep = __repBase as QueueDeleteOk;
8687 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8688 return __rep.m_messageCount;
8690 public override void BasicQos(
8691 System.UInt32 @prefetchSize,
8692 System.UInt16 @prefetchCount,
8693 System.Boolean @global)
8695 BasicQos __req = new BasicQos();
8696 __req.m_prefetchSize = @prefetchSize;
8697 __req.m_prefetchCount = @prefetchCount;
8698 __req.m_global = @global;
8699 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8700 BasicQosOk __rep = __repBase as BasicQosOk;
8701 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8703 public override void BasicAck(
8704 System.UInt64 @deliveryTag,
8705 System.Boolean @multiple)
8707 BasicAck __req = new BasicAck();
8708 __req.m_deliveryTag = @deliveryTag;
8709 __req.m_multiple = @multiple;
8710 ModelSend(__req,null,null);
8712 public override void BasicReject(
8713 System.UInt64 @deliveryTag,
8714 System.Boolean @requeue)
8716 BasicReject __req = new BasicReject();
8717 __req.m_deliveryTag = @deliveryTag;
8718 __req.m_requeue = @requeue;
8719 ModelSend(__req,null,null);
8721 public override void BasicRecover(
8722 System.Boolean @requeue)
8724 BasicRecover __req = new BasicRecover();
8725 __req.m_requeue = @requeue;
8726 ModelSend(__req,null,null);
8728 public override void TxSelect()
8730 TxSelect __req = new TxSelect();
8731 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8732 TxSelectOk __rep = __repBase as TxSelectOk;
8733 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8735 public override void TxCommit()
8737 TxCommit __req = new TxCommit();
8738 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8739 TxCommitOk __rep = __repBase as TxCommitOk;
8740 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8742 public override void TxRollback()
8744 TxRollback __req = new TxRollback();
8745 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8746 TxRollbackOk __rep = __repBase as TxRollbackOk;
8747 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8749 public override void DtxSelect()
8751 DtxSelect __req = new DtxSelect();
8752 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8753 DtxSelectOk __rep = __repBase as DtxSelectOk;
8754 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8756 public override void DtxStart(
8757 System.String @dtxIdentifier)
8759 DtxStart __req = new DtxStart();
8760 __req.m_dtxIdentifier = @dtxIdentifier;
8761 RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
8762 DtxStartOk __rep = __repBase as DtxStartOk;
8763 if (__rep == null) throw new UnexpectedMethodException(__repBase);
8765 public override bool DispatchAsynchronous(RabbitMQ.Client.Impl.Command cmd) {
8766 RabbitMQ.Client.Impl.MethodBase __method = (RabbitMQ.Client.Impl.MethodBase) cmd.Method;
8767 switch ((__method.ProtocolClassId << 16) | __method.ProtocolMethodId) {
8769 BasicConsumeOk __impl = (BasicConsumeOk) __method;
8770 HandleBasicConsumeOk(
8771 __impl.m_consumerTag);
8775 BasicCancelOk __impl = (BasicCancelOk) __method;
8776 HandleBasicCancelOk(
8777 __impl.m_consumerTag);
8781 BasicGetOk __impl = (BasicGetOk) __method;
8783 __impl.m_deliveryTag,
8784 __impl.m_redelivered,
8786 __impl.m_routingKey,
8787 __impl.m_messageCount,
8788 (RabbitMQ.Client.IBasicProperties) cmd.Header,
8793 HandleBasicGetEmpty();
8797 BasicDeliver __impl = (BasicDeliver) __method;
8799 __impl.m_consumerTag,
8800 __impl.m_deliveryTag,
8801 __impl.m_redelivered,
8803 __impl.m_routingKey,
8804 (RabbitMQ.Client.IBasicProperties) cmd.Header,
8809 BasicReturn __impl = (BasicReturn) __method;
8814 __impl.m_routingKey,
8815 (RabbitMQ.Client.IBasicProperties) cmd.Header,
8820 ChannelFlow __impl = (ChannelFlow) __method;
8826 ChannelClose __impl = (ChannelClose) __method;
8835 HandleChannelCloseOk();
8839 ConnectionStart __impl = (ConnectionStart) __method;
8840 HandleConnectionStart(
8841 __impl.m_versionMajor,
8842 __impl.m_versionMinor,
8843 __impl.m_serverProperties,
8844 __impl.m_mechanisms,
8849 ConnectionOpenOk __impl = (ConnectionOpenOk) __method;
8850 HandleConnectionOpenOk(
8851 __impl.m_knownHosts);
8855 ConnectionRedirect __impl = (ConnectionRedirect) __method;
8856 HandleConnectionRedirect(
8858 __impl.m_knownHosts);
8862 ConnectionClose __impl = (ConnectionClose) __method;
8863 HandleConnectionClose(
8870 default: return false;