mcs/class/RabbitMQ.Client/docs/specs/autogenerated-api-0-9.cs

   1 // Autogenerated code. Do not edit.
   2
   3 using RabbitMQ.Client;
   4 using RabbitMQ.Client.Exceptions;
   5
   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; } }
  16
  17     public override RabbitMQ.Client.Impl.MethodBase DecodeMethodFrom(RabbitMQ.Util.NetworkBinaryReader reader) {
  18       ushort classId = reader.ReadUInt16();
  19       ushort methodId = reader.ReadUInt16();
  20
  21       switch (classId) {
  22         case 10: {
  23           switch (methodId) {
  24             case 10: {
  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));
  27               return result;
  28             }
  29             case 11: {
  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));
  32               return result;
  33             }
  34             case 20: {
  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));
  37               return result;
  38             }
  39             case 21: {
  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));
  42               return result;
  43             }
  44             case 30: {
  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));
  47               return result;
  48             }
  49             case 31: {
  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));
  52               return result;
  53             }
  54             case 40: {
  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));
  57               return result;
  58             }
  59             case 41: {
  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));
  62               return result;
  63             }
  64             case 42: {
  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));
  67               return result;
  68             }
  69             case 50: {
  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));
  72               return result;
  73             }
  74             case 51: {
  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));
  77               return result;
  78             }
  79             default: break;
  80           }
  81           break;
  82         }
  83         case 20: {
  84           switch (methodId) {
  85             case 10: {
  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));
  88               return result;
  89             }
  90             case 11: {
  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));
  93               return result;
  94             }
  95             case 20: {
  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));
  98               return result;
  99             }
 100             case 21: {
 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));
 103               return result;
 104             }
 105             case 40: {
 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));
 108               return result;
 109             }
 110             case 41: {
 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));
 113               return result;
 114             }
 115             case 50: {
 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));
 118               return result;
 119             }
 120             case 60: {
 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));
 123               return result;
 124             }
 125             case 70: {
 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));
 128               return result;
 129             }
 130             case 80: {
 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));
 133               return result;
 134             }
 135             default: break;
 136           }
 137           break;
 138         }
 139         case 30: {
 140           switch (methodId) {
 141             case 10: {
 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));
 144               return result;
 145             }
 146             case 11: {
 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));
 149               return result;
 150             }
 151             default: break;
 152           }
 153           break;
 154         }
 155         case 40: {
 156           switch (methodId) {
 157             case 10: {
 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));
 160               return result;
 161             }
 162             case 11: {
 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));
 165               return result;
 166             }
 167             case 20: {
 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));
 170               return result;
 171             }
 172             case 21: {
 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));
 175               return result;
 176             }
 177             default: break;
 178           }
 179           break;
 180         }
 181         case 50: {
 182           switch (methodId) {
 183             case 10: {
 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));
 186               return result;
 187             }
 188             case 11: {
 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));
 191               return result;
 192             }
 193             case 20: {
 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));
 196               return result;
 197             }
 198             case 21: {
 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));
 201               return result;
 202             }
 203             case 50: {
 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));
 206               return result;
 207             }
 208             case 51: {
 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));
 211               return result;
 212             }
 213             case 30: {
 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));
 216               return result;
 217             }
 218             case 31: {
 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));
 221               return result;
 222             }
 223             case 40: {
 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));
 226               return result;
 227             }
 228             case 41: {
 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));
 231               return result;
 232             }
 233             default: break;
 234           }
 235           break;
 236         }
 237         case 60: {
 238           switch (methodId) {
 239             case 10: {
 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));
 242               return result;
 243             }
 244             case 11: {
 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));
 247               return result;
 248             }
 249             case 20: {
 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));
 252               return result;
 253             }
 254             case 21: {
 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));
 257               return result;
 258             }
 259             case 30: {
 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));
 262               return result;
 263             }
 264             case 31: {
 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));
 267               return result;
 268             }
 269             case 40: {
 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));
 272               return result;
 273             }
 274             case 50: {
 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));
 277               return result;
 278             }
 279             case 60: {
 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));
 282               return result;
 283             }
 284             case 70: {
 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));
 287               return result;
 288             }
 289             case 71: {
 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));
 292               return result;
 293             }
 294             case 72: {
 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));
 297               return result;
 298             }
 299             case 80: {
 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));
 302               return result;
 303             }
 304             case 90: {
 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));
 307               return result;
 308             }
 309             case 100: {
 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));
 312               return result;
 313             }
 314             default: break;
 315           }
 316           break;
 317         }
 318         case 70: {
 319           switch (methodId) {
 320             case 10: {
 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));
 323               return result;
 324             }
 325             case 11: {
 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));
 328               return result;
 329             }
 330             case 20: {
 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));
 333               return result;
 334             }
 335             case 21: {
 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));
 338               return result;
 339             }
 340             case 30: {
 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));
 343               return result;
 344             }
 345             case 31: {
 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));
 348               return result;
 349             }
 350             case 40: {
 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));
 353               return result;
 354             }
 355             case 41: {
 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));
 358               return result;
 359             }
 360             case 50: {
 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));
 363               return result;
 364             }
 365             case 60: {
 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));
 368               return result;
 369             }
 370             case 70: {
 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));
 373               return result;
 374             }
 375             case 80: {
 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));
 378               return result;
 379             }
 380             case 90: {
 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));
 383               return result;
 384             }
 385             case 100: {
 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));
 388               return result;
 389             }
 390             default: break;
 391           }
 392           break;
 393         }
 394         case 80: {
 395           switch (methodId) {
 396             case 10: {
 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));
 399               return result;
 400             }
 401             case 11: {
 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));
 404               return result;
 405             }
 406             case 20: {
 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));
 409               return result;
 410             }
 411             case 21: {
 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));
 414               return result;
 415             }
 416             case 30: {
 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));
 419               return result;
 420             }
 421             case 31: {
 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));
 424               return result;
 425             }
 426             case 40: {
 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));
 429               return result;
 430             }
 431             case 50: {
 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));
 434               return result;
 435             }
 436             case 60: {
 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));
 439               return result;
 440             }
 441             default: break;
 442           }
 443           break;
 444         }
 445         case 90: {
 446           switch (methodId) {
 447             case 10: {
 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));
 450               return result;
 451             }
 452             case 11: {
 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));
 455               return result;
 456             }
 457             case 20: {
 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));
 460               return result;
 461             }
 462             case 21: {
 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));
 465               return result;
 466             }
 467             case 30: {
 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));
 470               return result;
 471             }
 472             case 31: {
 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));
 475               return result;
 476             }
 477             default: break;
 478           }
 479           break;
 480         }
 481         case 100: {
 482           switch (methodId) {
 483             case 10: {
 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));
 486               return result;
 487             }
 488             case 11: {
 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));
 491               return result;
 492             }
 493             case 20: {
 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));
 496               return result;
 497             }
 498             case 21: {
 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));
 501               return result;
 502             }
 503             default: break;
 504           }
 505           break;
 506         }
 507         case 110: {
 508           switch (methodId) {
 509             case 10: {
 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));
 512               return result;
 513             }
 514             default: break;
 515           }
 516           break;
 517         }
 518         case 120: {
 519           switch (methodId) {
 520             case 10: {
 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));
 523               return result;
 524             }
 525             case 20: {
 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));
 528               return result;
 529             }
 530             case 30: {
 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));
 533               return result;
 534             }
 535             case 40: {
 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));
 538               return result;
 539             }
 540             case 50: {
 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));
 543               return result;
 544             }
 545             case 60: {
 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));
 548               return result;
 549             }
 550             case 70: {
 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));
 553               return result;
 554             }
 555             case 80: {
 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));
 558               return result;
 559             }
 560             case 90: {
 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));
 563               return result;
 564             }
 565             case 100: {
 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));
 568               return result;
 569             }
 570             case 110: {
 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));
 573               return result;
 574             }
 575             case 500: {
 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));
 578               return result;
 579             }
 580             case 510: {
 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));
 583               return result;
 584             }
 585             case 520: {
 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));
 588               return result;
 589             }
 590             case 530: {
 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));
 593               return result;
 594             }
 595             default: break;
 596           }
 597           break;
 598         }
 599         default: break;
 600       }
 601       throw new RabbitMQ.Client.Impl.UnknownClassOrMethodException(classId, methodId);
 602     }
 603
 604     public override RabbitMQ.Client.Impl.ContentHeaderBase DecodeContentHeaderFrom(RabbitMQ.Util.NetworkBinaryReader reader) {
 605       ushort classId = reader.ReadUInt16();
 606
 607       switch (classId) {
 608         case 60: return new BasicProperties();
 609         case 70: return new FileProperties();
 610         case 80: return new StreamProperties();
 611         case 110: return new TunnelProperties();
 612         default: break;
 613       }
 614       throw new RabbitMQ.Client.Impl.UnknownClassOrMethodException(classId, 0);
 615     }
 616   }
 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;
 676   }
 677   /// <summary>Autogenerated type. AMQP specification method "connection.start".</summary>
 678   public interface IConnectionStart: IMethod {
 679     byte VersionMajor { get; }
 680     byte VersionMinor { get; }
 681     System.Collections.IDictionary ServerProperties { get; }
 682     byte[] Mechanisms { get; }
 683     byte[] Locales { get; }
 684   }
 685   /// <summary>Autogenerated type. AMQP specification method "connection.start-ok".</summary>
 686   public interface IConnectionStartOk: IMethod {
 687     System.Collections.IDictionary ClientProperties { get; }
 688     string Mechanism { get; }
 689     byte[] Response { get; }
 690     string Locale { get; }
 691   }
 692   /// <summary>Autogenerated type. AMQP specification method "connection.secure".</summary>
 693   public interface IConnectionSecure: IMethod {
 694     byte[] Challenge { get; }
 695   }
 696   /// <summary>Autogenerated type. AMQP specification method "connection.secure-ok".</summary>
 697   public interface IConnectionSecureOk: IMethod {
 698     byte[] Response { get; }
 699   }
 700   /// <summary>Autogenerated type. AMQP specification method "connection.tune".</summary>
 701   public interface IConnectionTune: IMethod {
 702     ushort ChannelMax { get; }
 703     uint FrameMax { get; }
 704     ushort Heartbeat { get; }
 705   }
 706   /// <summary>Autogenerated type. AMQP specification method "connection.tune-ok".</summary>
 707   public interface IConnectionTuneOk: IMethod {
 708     ushort ChannelMax { get; }
 709     uint FrameMax { get; }
 710     ushort Heartbeat { get; }
 711   }
 712   /// <summary>Autogenerated type. AMQP specification method "connection.open".</summary>
 713   public interface IConnectionOpen: IMethod {
 714     string VirtualHost { get; }
 715     string Capabilities { get; }
 716     bool Insist { get; }
 717   }
 718   /// <summary>Autogenerated type. AMQP specification method "connection.open-ok".</summary>
 719   public interface IConnectionOpenOk: IMethod {
 720     string KnownHosts { get; }
 721   }
 722   /// <summary>Autogenerated type. AMQP specification method "connection.redirect".</summary>
 723   public interface IConnectionRedirect: IMethod {
 724     string Host { get; }
 725     string KnownHosts { get; }
 726   }
 727   /// <summary>Autogenerated type. AMQP specification method "connection.close".</summary>
 728   public interface IConnectionClose: IMethod {
 729     ushort ReplyCode { get; }
 730     string ReplyText { get; }
 731     ushort ClassId { get; }
 732     ushort MethodId { get; }
 733   }
 734   /// <summary>Autogenerated type. AMQP specification method "connection.close-ok".</summary>
 735   public interface IConnectionCloseOk: IMethod {
 736   }
 737   /// <summary>Autogenerated type. AMQP specification method "channel.open".</summary>
 738   public interface IChannelOpen: IMethod {
 739     string OutOfBand { get; }
 740   }
 741   /// <summary>Autogenerated type. AMQP specification method "channel.open-ok".</summary>
 742   public interface IChannelOpenOk: IMethod {
 743     byte[] ChannelId { get; }
 744   }
 745   /// <summary>Autogenerated type. AMQP specification method "channel.flow".</summary>
 746   public interface IChannelFlow: IMethod {
 747     bool Active { get; }
 748   }
 749   /// <summary>Autogenerated type. AMQP specification method "channel.flow-ok".</summary>
 750   public interface IChannelFlowOk: IMethod {
 751     bool Active { get; }
 752   }
 753   /// <summary>Autogenerated type. AMQP specification method "channel.close".</summary>
 754   public interface IChannelClose: IMethod {
 755     ushort ReplyCode { get; }
 756     string ReplyText { get; }
 757     ushort ClassId { get; }
 758     ushort MethodId { get; }
 759   }
 760   /// <summary>Autogenerated type. AMQP specification method "channel.close-ok".</summary>
 761   public interface IChannelCloseOk: IMethod {
 762   }
 763   /// <summary>Autogenerated type. AMQP specification method "channel.resume".</summary>
 764   public interface IChannelResume: IMethod {
 765     byte[] ChannelId { get; }
 766   }
 767   /// <summary>Autogenerated type. AMQP specification method "channel.ping".</summary>
 768   public interface IChannelPing: IMethod {
 769   }
 770   /// <summary>Autogenerated type. AMQP specification method "channel.pong".</summary>
 771   public interface IChannelPong: IMethod {
 772   }
 773   /// <summary>Autogenerated type. AMQP specification method "channel.ok".</summary>
 774   public interface IChannelOk: IMethod {
 775   }
 776   /// <summary>Autogenerated type. AMQP specification method "access.request".</summary>
 777   public interface IAccessRequest: IMethod {
 778     string Realm { get; }
 779     bool Exclusive { get; }
 780     bool Passive { get; }
 781     bool Active { get; }
 782     bool Write { get; }
 783     bool Read { get; }
 784   }
 785   /// <summary>Autogenerated type. AMQP specification method "access.request-ok".</summary>
 786   public interface IAccessRequestOk: IMethod {
 787     ushort Ticket { get; }
 788   }
 789   /// <summary>Autogenerated type. AMQP specification method "exchange.declare".</summary>
 790   public interface IExchangeDeclare: IMethod {
 791     ushort Ticket { get; }
 792     string Exchange { get; }
 793     string Type { get; }
 794     bool Passive { get; }
 795     bool Durable { get; }
 796     bool AutoDelete { get; }
 797     bool Internal { get; }
 798     bool Nowait { get; }
 799     System.Collections.IDictionary Arguments { get; }
 800   }
 801   /// <summary>Autogenerated type. AMQP specification method "exchange.declare-ok".</summary>
 802   public interface IExchangeDeclareOk: IMethod {
 803   }
 804   /// <summary>Autogenerated type. AMQP specification method "exchange.delete".</summary>
 805   public interface IExchangeDelete: IMethod {
 806     ushort Ticket { get; }
 807     string Exchange { get; }
 808     bool IfUnused { get; }
 809     bool Nowait { get; }
 810   }
 811   /// <summary>Autogenerated type. AMQP specification method "exchange.delete-ok".</summary>
 812   public interface IExchangeDeleteOk: IMethod {
 813   }
 814   /// <summary>Autogenerated type. AMQP specification method "queue.declare".</summary>
 815   public interface IQueueDeclare: IMethod {
 816     ushort Ticket { get; }
 817     string Queue { get; }
 818     bool Passive { get; }
 819     bool Durable { get; }
 820     bool Exclusive { get; }
 821     bool AutoDelete { get; }
 822     bool Nowait { get; }
 823     System.Collections.IDictionary Arguments { get; }
 824   }
 825   /// <summary>Autogenerated type. AMQP specification method "queue.declare-ok".</summary>
 826   public interface IQueueDeclareOk: IMethod {
 827     string Queue { get; }
 828     uint MessageCount { get; }
 829     uint ConsumerCount { get; }
 830   }
 831   /// <summary>Autogenerated type. AMQP specification method "queue.bind".</summary>
 832   public interface IQueueBind: IMethod {
 833     ushort Ticket { get; }
 834     string Queue { get; }
 835     string Exchange { get; }
 836     string RoutingKey { get; }
 837     bool Nowait { get; }
 838     System.Collections.IDictionary Arguments { get; }
 839   }
 840   /// <summary>Autogenerated type. AMQP specification method "queue.bind-ok".</summary>
 841   public interface IQueueBindOk: IMethod {
 842   }
 843   /// <summary>Autogenerated type. AMQP specification method "queue.unbind".</summary>
 844   public interface IQueueUnbind: IMethod {
 845     ushort Ticket { get; }
 846     string Queue { get; }
 847     string Exchange { get; }
 848     string RoutingKey { get; }
 849     System.Collections.IDictionary Arguments { get; }
 850   }
 851   /// <summary>Autogenerated type. AMQP specification method "queue.unbind-ok".</summary>
 852   public interface IQueueUnbindOk: IMethod {
 853   }
 854   /// <summary>Autogenerated type. AMQP specification method "queue.purge".</summary>
 855   public interface IQueuePurge: IMethod {
 856     ushort Ticket { get; }
 857     string Queue { get; }
 858     bool Nowait { get; }
 859   }
 860   /// <summary>Autogenerated type. AMQP specification method "queue.purge-ok".</summary>
 861   public interface IQueuePurgeOk: IMethod {
 862     uint MessageCount { get; }
 863   }
 864   /// <summary>Autogenerated type. AMQP specification method "queue.delete".</summary>
 865   public interface IQueueDelete: IMethod {
 866     ushort Ticket { get; }
 867     string Queue { get; }
 868     bool IfUnused { get; }
 869     bool IfEmpty { get; }
 870     bool Nowait { get; }
 871   }
 872   /// <summary>Autogenerated type. AMQP specification method "queue.delete-ok".</summary>
 873   public interface IQueueDeleteOk: IMethod {
 874     uint MessageCount { get; }
 875   }
 876   /// <summary>Autogenerated type. AMQP specification method "basic.qos".</summary>
 877   public interface IBasicQos: IMethod {
 878     uint PrefetchSize { get; }
 879     ushort PrefetchCount { get; }
 880     bool Global { get; }
 881   }
 882   /// <summary>Autogenerated type. AMQP specification method "basic.qos-ok".</summary>
 883   public interface IBasicQosOk: IMethod {
 884   }
 885   /// <summary>Autogenerated type. AMQP specification method "basic.consume".</summary>
 886   public interface IBasicConsume: IMethod {
 887     ushort Ticket { get; }
 888     string Queue { get; }
 889     string ConsumerTag { get; }
 890     bool NoLocal { get; }
 891     bool NoAck { get; }
 892     bool Exclusive { get; }
 893     bool Nowait { get; }
 894     System.Collections.IDictionary Filter { get; }
 895   }
 896   /// <summary>Autogenerated type. AMQP specification method "basic.consume-ok".</summary>
 897   public interface IBasicConsumeOk: IMethod {
 898     string ConsumerTag { get; }
 899   }
 900   /// <summary>Autogenerated type. AMQP specification method "basic.cancel".</summary>
 901   public interface IBasicCancel: IMethod {
 902     string ConsumerTag { get; }
 903     bool Nowait { get; }
 904   }
 905   /// <summary>Autogenerated type. AMQP specification method "basic.cancel-ok".</summary>
 906   public interface IBasicCancelOk: IMethod {
 907     string ConsumerTag { get; }
 908   }
 909   /// <summary>Autogenerated type. AMQP specification method "basic.publish".</summary>
 910   public interface IBasicPublish: IMethod {
 911     ushort Ticket { get; }
 912     string Exchange { get; }
 913     string RoutingKey { get; }
 914     bool Mandatory { get; }
 915     bool Immediate { get; }
 916   }
 917   /// <summary>Autogenerated type. AMQP specification method "basic.return".</summary>
 918   public interface IBasicReturn: IMethod {
 919     ushort ReplyCode { get; }
 920     string ReplyText { get; }
 921     string Exchange { get; }
 922     string RoutingKey { get; }
 923   }
 924   /// <summary>Autogenerated type. AMQP specification method "basic.deliver".</summary>
 925   public interface IBasicDeliver: IMethod {
 926     string ConsumerTag { get; }
 927     ulong DeliveryTag { get; }
 928     bool Redelivered { get; }
 929     string Exchange { get; }
 930     string RoutingKey { get; }
 931   }
 932   /// <summary>Autogenerated type. AMQP specification method "basic.get".</summary>
 933   public interface IBasicGet: IMethod {
 934     ushort Ticket { get; }
 935     string Queue { get; }
 936     bool NoAck { get; }
 937   }
 938   /// <summary>Autogenerated type. AMQP specification method "basic.get-ok".</summary>
 939   public interface IBasicGetOk: IMethod {
 940     ulong DeliveryTag { get; }
 941     bool Redelivered { get; }
 942     string Exchange { get; }
 943     string RoutingKey { get; }
 944     uint MessageCount { get; }
 945   }
 946   /// <summary>Autogenerated type. AMQP specification method "basic.get-empty".</summary>
 947   public interface IBasicGetEmpty: IMethod {
 948     string ClusterId { get; }
 949   }
 950   /// <summary>Autogenerated type. AMQP specification method "basic.ack".</summary>
 951   public interface IBasicAck: IMethod {
 952     ulong DeliveryTag { get; }
 953     bool Multiple { get; }
 954   }
 955   /// <summary>Autogenerated type. AMQP specification method "basic.reject".</summary>
 956   public interface IBasicReject: IMethod {
 957     ulong DeliveryTag { get; }
 958     bool Requeue { get; }
 959   }
 960   /// <summary>Autogenerated type. AMQP specification method "basic.recover".</summary>
 961   public interface IBasicRecover: IMethod {
 962     bool Requeue { get; }
 963   }
 964   /// <summary>Autogenerated type. AMQP specification method "file.qos".</summary>
 965   public interface IFileQos: IMethod {
 966     uint PrefetchSize { get; }
 967     ushort PrefetchCount { get; }
 968     bool Global { get; }
 969   }
 970   /// <summary>Autogenerated type. AMQP specification method "file.qos-ok".</summary>
 971   public interface IFileQosOk: IMethod {
 972   }
 973   /// <summary>Autogenerated type. AMQP specification method "file.consume".</summary>
 974   public interface IFileConsume: IMethod {
 975     ushort Ticket { get; }
 976     string Queue { get; }
 977     string ConsumerTag { get; }
 978     bool NoLocal { get; }
 979     bool NoAck { get; }
 980     bool Exclusive { get; }
 981     bool Nowait { get; }
 982     System.Collections.IDictionary Filter { get; }
 983   }
 984   /// <summary>Autogenerated type. AMQP specification method "file.consume-ok".</summary>
 985   public interface IFileConsumeOk: IMethod {
 986     string ConsumerTag { get; }
 987   }
 988   /// <summary>Autogenerated type. AMQP specification method "file.cancel".</summary>
 989   public interface IFileCancel: IMethod {
 990     string ConsumerTag { get; }
 991     bool Nowait { get; }
 992   }
 993   /// <summary>Autogenerated type. AMQP specification method "file.cancel-ok".</summary>
 994   public interface IFileCancelOk: IMethod {
 995     string ConsumerTag { get; }
 996   }
 997   /// <summary>Autogenerated type. AMQP specification method "file.open".</summary>
 998   public interface IFileOpen: IMethod {
 999     string Identifier { get; }
1000     ulong ContentSize { get; }
1001   }
1002   /// <summary>Autogenerated type. AMQP specification method "file.open-ok".</summary>
1003   public interface IFileOpenOk: IMethod {
1004     ulong StagedSize { get; }
1005   }
1006   /// <summary>Autogenerated type. AMQP specification method "file.stage".</summary>
1007   public interface IFileStage: IMethod {
1008   }
1009   /// <summary>Autogenerated type. AMQP specification method "file.publish".</summary>
1010   public interface IFilePublish: IMethod {
1011     ushort Ticket { get; }
1012     string Exchange { get; }
1013     string RoutingKey { get; }
1014     bool Mandatory { get; }
1015     bool Immediate { get; }
1016     string Identifier { get; }
1017   }
1018   /// <summary>Autogenerated type. AMQP specification method "file.return".</summary>
1019   public interface IFileReturn: IMethod {
1020     ushort ReplyCode { get; }
1021     string ReplyText { get; }
1022     string Exchange { get; }
1023     string RoutingKey { get; }
1024   }
1025   /// <summary>Autogenerated type. AMQP specification method "file.deliver".</summary>
1026   public interface IFileDeliver: IMethod {
1027     string ConsumerTag { get; }
1028     ulong DeliveryTag { get; }
1029     bool Redelivered { get; }
1030     string Exchange { get; }
1031     string RoutingKey { get; }
1032     string Identifier { get; }
1033   }
1034   /// <summary>Autogenerated type. AMQP specification method "file.ack".</summary>
1035   public interface IFileAck: IMethod {
1036     ulong DeliveryTag { get; }
1037     bool Multiple { get; }
1038   }
1039   /// <summary>Autogenerated type. AMQP specification method "file.reject".</summary>
1040   public interface IFileReject: IMethod {
1041     ulong DeliveryTag { get; }
1042     bool Requeue { get; }
1043   }
1044   /// <summary>Autogenerated type. AMQP specification method "stream.qos".</summary>
1045   public interface IStreamQos: IMethod {
1046     uint PrefetchSize { get; }
1047     ushort PrefetchCount { get; }
1048     uint ConsumeRate { get; }
1049     bool Global { get; }
1050   }
1051   /// <summary>Autogenerated type. AMQP specification method "stream.qos-ok".</summary>
1052   public interface IStreamQosOk: IMethod {
1053   }
1054   /// <summary>Autogenerated type. AMQP specification method "stream.consume".</summary>
1055   public interface IStreamConsume: IMethod {
1056     ushort Ticket { get; }
1057     string Queue { get; }
1058     string ConsumerTag { get; }
1059     bool NoLocal { get; }
1060     bool Exclusive { get; }
1061     bool Nowait { get; }
1062     System.Collections.IDictionary Filter { get; }
1063   }
1064   /// <summary>Autogenerated type. AMQP specification method "stream.consume-ok".</summary>
1065   public interface IStreamConsumeOk: IMethod {
1066     string ConsumerTag { get; }
1067   }
1068   /// <summary>Autogenerated type. AMQP specification method "stream.cancel".</summary>
1069   public interface IStreamCancel: IMethod {
1070     string ConsumerTag { get; }
1071     bool Nowait { get; }
1072   }
1073   /// <summary>Autogenerated type. AMQP specification method "stream.cancel-ok".</summary>
1074   public interface IStreamCancelOk: IMethod {
1075     string ConsumerTag { get; }
1076   }
1077   /// <summary>Autogenerated type. AMQP specification method "stream.publish".</summary>
1078   public interface IStreamPublish: IMethod {
1079     ushort Ticket { get; }
1080     string Exchange { get; }
1081     string RoutingKey { get; }
1082     bool Mandatory { get; }
1083     bool Immediate { get; }
1084   }
1085   /// <summary>Autogenerated type. AMQP specification method "stream.return".</summary>
1086   public interface IStreamReturn: IMethod {
1087     ushort ReplyCode { get; }
1088     string ReplyText { get; }
1089     string Exchange { get; }
1090     string RoutingKey { get; }
1091   }
1092   /// <summary>Autogenerated type. AMQP specification method "stream.deliver".</summary>
1093   public interface IStreamDeliver: IMethod {
1094     string ConsumerTag { get; }
1095     ulong DeliveryTag { get; }
1096     string Exchange { get; }
1097     string Queue { get; }
1098   }
1099   /// <summary>Autogenerated type. AMQP specification method "tx.select".</summary>
1100   public interface ITxSelect: IMethod {
1101   }
1102   /// <summary>Autogenerated type. AMQP specification method "tx.select-ok".</summary>
1103   public interface ITxSelectOk: IMethod {
1104   }
1105   /// <summary>Autogenerated type. AMQP specification method "tx.commit".</summary>
1106   public interface ITxCommit: IMethod {
1107   }
1108   /// <summary>Autogenerated type. AMQP specification method "tx.commit-ok".</summary>
1109   public interface ITxCommitOk: IMethod {
1110   }
1111   /// <summary>Autogenerated type. AMQP specification method "tx.rollback".</summary>
1112   public interface ITxRollback: IMethod {
1113   }
1114   /// <summary>Autogenerated type. AMQP specification method "tx.rollback-ok".</summary>
1115   public interface ITxRollbackOk: IMethod {
1116   }
1117   /// <summary>Autogenerated type. AMQP specification method "dtx.select".</summary>
1118   public interface IDtxSelect: IMethod {
1119   }
1120   /// <summary>Autogenerated type. AMQP specification method "dtx.select-ok".</summary>
1121   public interface IDtxSelectOk: IMethod {
1122   }
1123   /// <summary>Autogenerated type. AMQP specification method "dtx.start".</summary>
1124   public interface IDtxStart: IMethod {
1125     string DtxIdentifier { get; }
1126   }
1127   /// <summary>Autogenerated type. AMQP specification method "dtx.start-ok".</summary>
1128   public interface IDtxStartOk: IMethod {
1129   }
1130   /// <summary>Autogenerated type. AMQP specification method "tunnel.request".</summary>
1131   public interface ITunnelRequest: IMethod {
1132     System.Collections.IDictionary MetaData { get; }
1133   }
1134   /// <summary>Autogenerated type. AMQP specification method "message.transfer".</summary>
1135   public interface IMessageTransfer: IMethod {
1136     ushort Ticket { get; }
1137     string Destination { get; }
1138     bool Redelivered { get; }
1139     bool Immediate { get; }
1140     ulong Ttl { get; }
1141     byte Priority { get; }
1142     AmqpTimestamp Timestamp { get; }
1143     byte DeliveryMode { get; }
1144     AmqpTimestamp Expiration { get; }
1145     string Exchange { get; }
1146     string RoutingKey { get; }
1147     string MessageId { get; }
1148     string CorrelationId { get; }
1149     string ReplyTo { get; }
1150     string ContentType { get; }
1151     string ContentEncoding { get; }
1152     string UserId { get; }
1153     string AppId { get; }
1154     string TransactionId { get; }
1155     byte[] SecurityToken { get; }
1156     System.Collections.IDictionary ApplicationHeaders { get; }
1157     byte[] Body { get; }
1158   }
1159   /// <summary>Autogenerated type. AMQP specification method "message.consume".</summary>
1160   public interface IMessageConsume: IMethod {
1161     ushort Ticket { get; }
1162     string Queue { get; }
1163     string Destination { get; }
1164     bool NoLocal { get; }
1165     bool NoAck { get; }
1166     bool Exclusive { get; }
1167     System.Collections.IDictionary Filter { get; }
1168   }
1169   /// <summary>Autogenerated type. AMQP specification method "message.cancel".</summary>
1170   public interface IMessageCancel: IMethod {
1171     string Destination { get; }
1172   }
1173   /// <summary>Autogenerated type. AMQP specification method "message.get".</summary>
1174   public interface IMessageGet: IMethod {
1175     ushort Ticket { get; }
1176     string Queue { get; }
1177     string Destination { get; }
1178     bool NoAck { get; }
1179   }
1180   /// <summary>Autogenerated type. AMQP specification method "message.recover".</summary>
1181   public interface IMessageRecover: IMethod {
1182     bool Requeue { get; }
1183   }
1184   /// <summary>Autogenerated type. AMQP specification method "message.open".</summary>
1185   public interface IMessageOpen: IMethod {
1186     byte[] Reference { get; }
1187   }
1188   /// <summary>Autogenerated type. AMQP specification method "message.close".</summary>
1189   public interface IMessageClose: IMethod {
1190     byte[] Reference { get; }
1191   }
1192   /// <summary>Autogenerated type. AMQP specification method "message.append".</summary>
1193   public interface IMessageAppend: IMethod {
1194     byte[] Reference { get; }
1195     byte[] Bytes { get; }
1196   }
1197   /// <summary>Autogenerated type. AMQP specification method "message.checkpoint".</summary>
1198   public interface IMessageCheckpoint: IMethod {
1199     byte[] Reference { get; }
1200     string Identifier { get; }
1201   }
1202   /// <summary>Autogenerated type. AMQP specification method "message.resume".</summary>
1203   public interface IMessageResume: IMethod {
1204     byte[] Reference { get; }
1205     string Identifier { get; }
1206   }
1207   /// <summary>Autogenerated type. AMQP specification method "message.qos".</summary>
1208   public interface IMessageQos: IMethod {
1209     uint PrefetchSize { get; }
1210     ushort PrefetchCount { get; }
1211     bool Global { get; }
1212   }
1213   /// <summary>Autogenerated type. AMQP specification method "message.ok".</summary>
1214   public interface IMessageOk: IMethod {
1215   }
1216   /// <summary>Autogenerated type. AMQP specification method "message.empty".</summary>
1217   public interface IMessageEmpty: IMethod {
1218   }
1219   /// <summary>Autogenerated type. AMQP specification method "message.reject".</summary>
1220   public interface IMessageReject: IMethod {
1221     ushort Code { get; }
1222     string Text { get; }
1223   }
1224   /// <summary>Autogenerated type. AMQP specification method "message.offset".</summary>
1225   public interface IMessageOffset: IMethod {
1226     ulong Value { get; }
1227   }
1228   /// <summary>Autogenerated type. AMQP specification content header properties for content class "basic"</summary>
1229   public class BasicProperties: RabbitMQ.Client.Impl.BasicProperties {
1230     private string m_contentType;
1231     private string m_contentEncoding;
1232     private System.Collections.IDictionary m_headers;
1233     private byte m_deliveryMode;
1234     private byte m_priority;
1235     private string m_correlationId;
1236     private string m_replyTo;
1237     private string m_expiration;
1238     private string m_messageId;
1239     private AmqpTimestamp m_timestamp;
1240     private string m_type;
1241     private string m_userId;
1242     private string m_appId;
1243     private string m_clusterId;
1244
1245     private bool m_contentType_present = false;
1246     private bool m_contentEncoding_present = false;
1247     private bool m_headers_present = false;
1248     private bool m_deliveryMode_present = false;
1249     private bool m_priority_present = false;
1250     private bool m_correlationId_present = false;
1251     private bool m_replyTo_present = false;
1252     private bool m_expiration_present = false;
1253     private bool m_messageId_present = false;
1254     private bool m_timestamp_present = false;
1255     private bool m_type_present = false;
1256     private bool m_userId_present = false;
1257     private bool m_appId_present = false;
1258     private bool m_clusterId_present = false;
1259
1260     public override string ContentType {
1261       get {
1262         return m_contentType;
1263       }
1264       set {
1265         m_contentType_present = true;
1266         m_contentType = value;
1267       }
1268     }
1269     public override string ContentEncoding {
1270       get {
1271         return m_contentEncoding;
1272       }
1273       set {
1274         m_contentEncoding_present = true;
1275         m_contentEncoding = value;
1276       }
1277     }
1278     public override System.Collections.IDictionary Headers {
1279       get {
1280         return m_headers;
1281       }
1282       set {
1283         m_headers_present = true;
1284         m_headers = value;
1285       }
1286     }
1287     public override byte DeliveryMode {
1288       get {
1289         return m_deliveryMode;
1290       }
1291       set {
1292         m_deliveryMode_present = true;
1293         m_deliveryMode = value;
1294       }
1295     }
1296     public override byte Priority {
1297       get {
1298         return m_priority;
1299       }
1300       set {
1301         m_priority_present = true;
1302         m_priority = value;
1303       }
1304     }
1305     public override string CorrelationId {
1306       get {
1307         return m_correlationId;
1308       }
1309       set {
1310         m_correlationId_present = true;
1311         m_correlationId = value;
1312       }
1313     }
1314     public override string ReplyTo {
1315       get {
1316         return m_replyTo;
1317       }
1318       set {
1319         m_replyTo_present = true;
1320         m_replyTo = value;
1321       }
1322     }
1323     public override string Expiration {
1324       get {
1325         return m_expiration;
1326       }
1327       set {
1328         m_expiration_present = true;
1329         m_expiration = value;
1330       }
1331     }
1332     public override string MessageId {
1333       get {
1334         return m_messageId;
1335       }
1336       set {
1337         m_messageId_present = true;
1338         m_messageId = value;
1339       }
1340     }
1341     public override AmqpTimestamp Timestamp {
1342       get {
1343         return m_timestamp;
1344       }
1345       set {
1346         m_timestamp_present = true;
1347         m_timestamp = value;
1348       }
1349     }
1350     public override string Type {
1351       get {
1352         return m_type;
1353       }
1354       set {
1355         m_type_present = true;
1356         m_type = value;
1357       }
1358     }
1359     public override string UserId {
1360       get {
1361         return m_userId;
1362       }
1363       set {
1364         m_userId_present = true;
1365         m_userId = value;
1366       }
1367     }
1368     public override string AppId {
1369       get {
1370         return m_appId;
1371       }
1372       set {
1373         m_appId_present = true;
1374         m_appId = value;
1375       }
1376     }
1377     public override string ClusterId {
1378       get {
1379         return m_clusterId;
1380       }
1381       set {
1382         m_clusterId_present = true;
1383         m_clusterId = value;
1384       }
1385     }
1386
1387     public override void ClearContentType() { m_contentType_present = false; }
1388     public override void ClearContentEncoding() { m_contentEncoding_present = false; }
1389     public override void ClearHeaders() { m_headers_present = false; }
1390     public override void ClearDeliveryMode() { m_deliveryMode_present = false; }
1391     public override void ClearPriority() { m_priority_present = false; }
1392     public override void ClearCorrelationId() { m_correlationId_present = false; }
1393     public override void ClearReplyTo() { m_replyTo_present = false; }
1394     public override void ClearExpiration() { m_expiration_present = false; }
1395     public override void ClearMessageId() { m_messageId_present = false; }
1396     public override void ClearTimestamp() { m_timestamp_present = false; }
1397     public override void ClearType() { m_type_present = false; }
1398     public override void ClearUserId() { m_userId_present = false; }
1399     public override void ClearAppId() { m_appId_present = false; }
1400     public override void ClearClusterId() { m_clusterId_present = false; }
1401
1402     public BasicProperties() {}
1403     public override int ProtocolClassId { get { return 60; } }
1404     public override string ProtocolClassName { get { return "basic"; } }
1405
1406     public override void ReadPropertiesFrom(RabbitMQ.Client.Impl.ContentHeaderPropertyReader reader) {
1407       m_contentType_present = reader.ReadPresence();
1408       m_contentEncoding_present = reader.ReadPresence();
1409       m_headers_present = reader.ReadPresence();
1410       m_deliveryMode_present = reader.ReadPresence();
1411       m_priority_present = reader.ReadPresence();
1412       m_correlationId_present = reader.ReadPresence();
1413       m_replyTo_present = reader.ReadPresence();
1414       m_expiration_present = reader.ReadPresence();
1415       m_messageId_present = reader.ReadPresence();
1416       m_timestamp_present = reader.ReadPresence();
1417       m_type_present = reader.ReadPresence();
1418       m_userId_present = reader.ReadPresence();
1419       m_appId_present = reader.ReadPresence();
1420       m_clusterId_present = reader.ReadPresence();
1421       reader.FinishPresence();
1422       if (m_contentType_present) { m_contentType = reader.ReadShortstr(); }
1423       if (m_contentEncoding_present) { m_contentEncoding = reader.ReadShortstr(); }
1424       if (m_headers_present) { m_headers = reader.ReadTable(); }
1425       if (m_deliveryMode_present) { m_deliveryMode = reader.ReadOctet(); }
1426       if (m_priority_present) { m_priority = reader.ReadOctet(); }
1427       if (m_correlationId_present) { m_correlationId = reader.ReadShortstr(); }
1428       if (m_replyTo_present) { m_replyTo = reader.ReadShortstr(); }
1429       if (m_expiration_present) { m_expiration = reader.ReadShortstr(); }
1430       if (m_messageId_present) { m_messageId = reader.ReadShortstr(); }
1431       if (m_timestamp_present) { m_timestamp = reader.ReadTimestamp(); }
1432       if (m_type_present) { m_type = reader.ReadShortstr(); }
1433       if (m_userId_present) { m_userId = reader.ReadShortstr(); }
1434       if (m_appId_present) { m_appId = reader.ReadShortstr(); }
1435       if (m_clusterId_present) { m_clusterId = reader.ReadShortstr(); }
1436     }
1437
1438     public override void WritePropertiesTo(RabbitMQ.Client.Impl.ContentHeaderPropertyWriter writer) {
1439       writer.WritePresence(m_contentType_present);
1440       writer.WritePresence(m_contentEncoding_present);
1441       writer.WritePresence(m_headers_present);
1442       writer.WritePresence(m_deliveryMode_present);
1443       writer.WritePresence(m_priority_present);
1444       writer.WritePresence(m_correlationId_present);
1445       writer.WritePresence(m_replyTo_present);
1446       writer.WritePresence(m_expiration_present);
1447       writer.WritePresence(m_messageId_present);
1448       writer.WritePresence(m_timestamp_present);
1449       writer.WritePresence(m_type_present);
1450       writer.WritePresence(m_userId_present);
1451       writer.WritePresence(m_appId_present);
1452       writer.WritePresence(m_clusterId_present);
1453       writer.FinishPresence();
1454       if (m_contentType_present) { writer.WriteShortstr(m_contentType); }
1455       if (m_contentEncoding_present) { writer.WriteShortstr(m_contentEncoding); }
1456       if (m_headers_present) { writer.WriteTable(m_headers); }
1457       if (m_deliveryMode_present) { writer.WriteOctet(m_deliveryMode); }
1458       if (m_priority_present) { writer.WriteOctet(m_priority); }
1459       if (m_correlationId_present) { writer.WriteShortstr(m_correlationId); }
1460       if (m_replyTo_present) { writer.WriteShortstr(m_replyTo); }
1461       if (m_expiration_present) { writer.WriteShortstr(m_expiration); }
1462       if (m_messageId_present) { writer.WriteShortstr(m_messageId); }
1463       if (m_timestamp_present) { writer.WriteTimestamp(m_timestamp); }
1464       if (m_type_present) { writer.WriteShortstr(m_type); }
1465       if (m_userId_present) { writer.WriteShortstr(m_userId); }
1466       if (m_appId_present) { writer.WriteShortstr(m_appId); }
1467       if (m_clusterId_present) { writer.WriteShortstr(m_clusterId); }
1468     }
1469
1470     public override void AppendPropertyDebugStringTo(System.Text.StringBuilder sb) {
1471       sb.Append("(");
1472       sb.Append("content-type="); sb.Append(m_contentType_present ? (m_contentType == null ? "(null)" : m_contentType.ToString()) : "_"); sb.Append(", ");
1473       sb.Append("content-encoding="); sb.Append(m_contentEncoding_present ? (m_contentEncoding == null ? "(null)" : m_contentEncoding.ToString()) : "_"); sb.Append(", ");
1474       sb.Append("headers="); sb.Append(m_headers_present ? (m_headers == null ? "(null)" : m_headers.ToString()) : "_"); sb.Append(", ");
1475       sb.Append("delivery-mode="); sb.Append(m_deliveryMode_present ? m_deliveryMode.ToString() : "_"); sb.Append(", ");
1476       sb.Append("priority="); sb.Append(m_priority_present ? m_priority.ToString() : "_"); sb.Append(", ");
1477       sb.Append("correlation-id="); sb.Append(m_correlationId_present ? (m_correlationId == null ? "(null)" : m_correlationId.ToString()) : "_"); sb.Append(", ");
1478       sb.Append("reply-to="); sb.Append(m_replyTo_present ? (m_replyTo == null ? "(null)" : m_replyTo.ToString()) : "_"); sb.Append(", ");
1479       sb.Append("expiration="); sb.Append(m_expiration_present ? (m_expiration == null ? "(null)" : m_expiration.ToString()) : "_"); sb.Append(", ");
1480       sb.Append("message-id="); sb.Append(m_messageId_present ? (m_messageId == null ? "(null)" : m_messageId.ToString()) : "_"); sb.Append(", ");
1481       sb.Append("timestamp="); sb.Append(m_timestamp_present ? m_timestamp.ToString() : "_"); sb.Append(", ");
1482       sb.Append("type="); sb.Append(m_type_present ? (m_type == null ? "(null)" : m_type.ToString()) : "_"); sb.Append(", ");
1483       sb.Append("user-id="); sb.Append(m_userId_present ? (m_userId == null ? "(null)" : m_userId.ToString()) : "_"); sb.Append(", ");
1484       sb.Append("app-id="); sb.Append(m_appId_present ? (m_appId == null ? "(null)" : m_appId.ToString()) : "_"); sb.Append(", ");
1485       sb.Append("cluster-id="); sb.Append(m_clusterId_present ? (m_clusterId == null ? "(null)" : m_clusterId.ToString()) : "_");
1486       sb.Append(")");
1487     }
1488   }
1489   /// <summary>Autogenerated type. AMQP specification content header properties for content class "file"</summary>
1490   public class FileProperties: RabbitMQ.Client.Impl.FileProperties {
1491     private string m_contentType;
1492     private string m_contentEncoding;
1493     private System.Collections.IDictionary m_headers;
1494     private byte m_priority;
1495     private string m_replyTo;
1496     private string m_messageId;
1497     private string m_filename;
1498     private AmqpTimestamp m_timestamp;
1499     private string m_clusterId;
1500
1501     private bool m_contentType_present = false;
1502     private bool m_contentEncoding_present = false;
1503     private bool m_headers_present = false;
1504     private bool m_priority_present = false;
1505     private bool m_replyTo_present = false;
1506     private bool m_messageId_present = false;
1507     private bool m_filename_present = false;
1508     private bool m_timestamp_present = false;
1509     private bool m_clusterId_present = false;
1510
1511     public override string ContentType {
1512       get {
1513         return m_contentType;
1514       }
1515       set {
1516         m_contentType_present = true;
1517         m_contentType = value;
1518       }
1519     }
1520     public override string ContentEncoding {
1521       get {
1522         return m_contentEncoding;
1523       }
1524       set {
1525         m_contentEncoding_present = true;
1526         m_contentEncoding = value;
1527       }
1528     }
1529     public override System.Collections.IDictionary Headers {
1530       get {
1531         return m_headers;
1532       }
1533       set {
1534         m_headers_present = true;
1535         m_headers = value;
1536       }
1537     }
1538     public override byte Priority {
1539       get {
1540         return m_priority;
1541       }
1542       set {
1543         m_priority_present = true;
1544         m_priority = value;
1545       }
1546     }
1547     public override string ReplyTo {
1548       get {
1549         return m_replyTo;
1550       }
1551       set {
1552         m_replyTo_present = true;
1553         m_replyTo = value;
1554       }
1555     }
1556     public override string MessageId {
1557       get {
1558         return m_messageId;
1559       }
1560       set {
1561         m_messageId_present = true;
1562         m_messageId = value;
1563       }
1564     }
1565     public override string Filename {
1566       get {
1567         return m_filename;
1568       }
1569       set {
1570         m_filename_present = true;
1571         m_filename = value;
1572       }
1573     }
1574     public override AmqpTimestamp Timestamp {
1575       get {
1576         return m_timestamp;
1577       }
1578       set {
1579         m_timestamp_present = true;
1580         m_timestamp = value;
1581       }
1582     }
1583     public override string ClusterId {
1584       get {
1585         return m_clusterId;
1586       }
1587       set {
1588         m_clusterId_present = true;
1589         m_clusterId = value;
1590       }
1591     }
1592
1593     public override void ClearContentType() { m_contentType_present = false; }
1594     public override void ClearContentEncoding() { m_contentEncoding_present = false; }
1595     public override void ClearHeaders() { m_headers_present = false; }
1596     public override void ClearPriority() { m_priority_present = false; }
1597     public override void ClearReplyTo() { m_replyTo_present = false; }
1598     public override void ClearMessageId() { m_messageId_present = false; }
1599     public override void ClearFilename() { m_filename_present = false; }
1600     public override void ClearTimestamp() { m_timestamp_present = false; }
1601     public override void ClearClusterId() { m_clusterId_present = false; }
1602
1603     public FileProperties() {}
1604     public override int ProtocolClassId { get { return 70; } }
1605     public override string ProtocolClassName { get { return "file"; } }
1606
1607     public override void ReadPropertiesFrom(RabbitMQ.Client.Impl.ContentHeaderPropertyReader reader) {
1608       m_contentType_present = reader.ReadPresence();
1609       m_contentEncoding_present = reader.ReadPresence();
1610       m_headers_present = reader.ReadPresence();
1611       m_priority_present = reader.ReadPresence();
1612       m_replyTo_present = reader.ReadPresence();
1613       m_messageId_present = reader.ReadPresence();
1614       m_filename_present = reader.ReadPresence();
1615       m_timestamp_present = reader.ReadPresence();
1616       m_clusterId_present = reader.ReadPresence();
1617       reader.FinishPresence();
1618       if (m_contentType_present) { m_contentType = reader.ReadShortstr(); }
1619       if (m_contentEncoding_present) { m_contentEncoding = reader.ReadShortstr(); }
1620       if (m_headers_present) { m_headers = reader.ReadTable(); }
1621       if (m_priority_present) { m_priority = reader.ReadOctet(); }
1622       if (m_replyTo_present) { m_replyTo = reader.ReadShortstr(); }
1623       if (m_messageId_present) { m_messageId = reader.ReadShortstr(); }
1624       if (m_filename_present) { m_filename = reader.ReadShortstr(); }
1625       if (m_timestamp_present) { m_timestamp = reader.ReadTimestamp(); }
1626       if (m_clusterId_present) { m_clusterId = reader.ReadShortstr(); }
1627     }
1628
1629     public override void WritePropertiesTo(RabbitMQ.Client.Impl.ContentHeaderPropertyWriter writer) {
1630       writer.WritePresence(m_contentType_present);
1631       writer.WritePresence(m_contentEncoding_present);
1632       writer.WritePresence(m_headers_present);
1633       writer.WritePresence(m_priority_present);
1634       writer.WritePresence(m_replyTo_present);
1635       writer.WritePresence(m_messageId_present);
1636       writer.WritePresence(m_filename_present);
1637       writer.WritePresence(m_timestamp_present);
1638       writer.WritePresence(m_clusterId_present);
1639       writer.FinishPresence();
1640       if (m_contentType_present) { writer.WriteShortstr(m_contentType); }
1641       if (m_contentEncoding_present) { writer.WriteShortstr(m_contentEncoding); }
1642       if (m_headers_present) { writer.WriteTable(m_headers); }
1643       if (m_priority_present) { writer.WriteOctet(m_priority); }
1644       if (m_replyTo_present) { writer.WriteShortstr(m_replyTo); }
1645       if (m_messageId_present) { writer.WriteShortstr(m_messageId); }
1646       if (m_filename_present) { writer.WriteShortstr(m_filename); }
1647       if (m_timestamp_present) { writer.WriteTimestamp(m_timestamp); }
1648       if (m_clusterId_present) { writer.WriteShortstr(m_clusterId); }
1649     }
1650
1651     public override void AppendPropertyDebugStringTo(System.Text.StringBuilder sb) {
1652       sb.Append("(");
1653       sb.Append("content-type="); sb.Append(m_contentType_present ? (m_contentType == null ? "(null)" : m_contentType.ToString()) : "_"); sb.Append(", ");
1654       sb.Append("content-encoding="); sb.Append(m_contentEncoding_present ? (m_contentEncoding == null ? "(null)" : m_contentEncoding.ToString()) : "_"); sb.Append(", ");
1655       sb.Append("headers="); sb.Append(m_headers_present ? (m_headers == null ? "(null)" : m_headers.ToString()) : "_"); sb.Append(", ");
1656       sb.Append("priority="); sb.Append(m_priority_present ? m_priority.ToString() : "_"); sb.Append(", ");
1657       sb.Append("reply-to="); sb.Append(m_replyTo_present ? (m_replyTo == null ? "(null)" : m_replyTo.ToString()) : "_"); sb.Append(", ");
1658       sb.Append("message-id="); sb.Append(m_messageId_present ? (m_messageId == null ? "(null)" : m_messageId.ToString()) : "_"); sb.Append(", ");
1659       sb.Append("filename="); sb.Append(m_filename_present ? (m_filename == null ? "(null)" : m_filename.ToString()) : "_"); sb.Append(", ");
1660       sb.Append("timestamp="); sb.Append(m_timestamp_present ? m_timestamp.ToString() : "_"); sb.Append(", ");
1661       sb.Append("cluster-id="); sb.Append(m_clusterId_present ? (m_clusterId == null ? "(null)" : m_clusterId.ToString()) : "_");
1662       sb.Append(")");
1663     }
1664   }
1665   /// <summary>Autogenerated type. AMQP specification content header properties for content class "stream"</summary>
1666   public class StreamProperties: RabbitMQ.Client.Impl.StreamProperties {
1667     private string m_contentType;
1668     private string m_contentEncoding;
1669     private System.Collections.IDictionary m_headers;
1670     private byte m_priority;
1671     private AmqpTimestamp m_timestamp;
1672
1673     private bool m_contentType_present = false;
1674     private bool m_contentEncoding_present = false;
1675     private bool m_headers_present = false;
1676     private bool m_priority_present = false;
1677     private bool m_timestamp_present = false;
1678
1679     public override string ContentType {
1680       get {
1681         return m_contentType;
1682       }
1683       set {
1684         m_contentType_present = true;
1685         m_contentType = value;
1686       }
1687     }
1688     public override string ContentEncoding {
1689       get {
1690         return m_contentEncoding;
1691       }
1692       set {
1693         m_contentEncoding_present = true;
1694         m_contentEncoding = value;
1695       }
1696     }
1697     public override System.Collections.IDictionary Headers {
1698       get {
1699         return m_headers;
1700       }
1701       set {
1702         m_headers_present = true;
1703         m_headers = value;
1704       }
1705     }
1706     public override byte Priority {
1707       get {
1708         return m_priority;
1709       }
1710       set {
1711         m_priority_present = true;
1712         m_priority = value;
1713       }
1714     }
1715     public override AmqpTimestamp Timestamp {
1716       get {
1717         return m_timestamp;
1718       }
1719       set {
1720         m_timestamp_present = true;
1721         m_timestamp = value;
1722       }
1723     }
1724
1725     public override void ClearContentType() { m_contentType_present = false; }
1726     public override void ClearContentEncoding() { m_contentEncoding_present = false; }
1727     public override void ClearHeaders() { m_headers_present = false; }
1728     public override void ClearPriority() { m_priority_present = false; }
1729     public override void ClearTimestamp() { m_timestamp_present = false; }
1730
1731     public StreamProperties() {}
1732     public override int ProtocolClassId { get { return 80; } }
1733     public override string ProtocolClassName { get { return "stream"; } }
1734
1735     public override void ReadPropertiesFrom(RabbitMQ.Client.Impl.ContentHeaderPropertyReader reader) {
1736       m_contentType_present = reader.ReadPresence();
1737       m_contentEncoding_present = reader.ReadPresence();
1738       m_headers_present = reader.ReadPresence();
1739       m_priority_present = reader.ReadPresence();
1740       m_timestamp_present = reader.ReadPresence();
1741       reader.FinishPresence();
1742       if (m_contentType_present) { m_contentType = reader.ReadShortstr(); }
1743       if (m_contentEncoding_present) { m_contentEncoding = reader.ReadShortstr(); }
1744       if (m_headers_present) { m_headers = reader.ReadTable(); }
1745       if (m_priority_present) { m_priority = reader.ReadOctet(); }
1746       if (m_timestamp_present) { m_timestamp = reader.ReadTimestamp(); }
1747     }
1748
1749     public override void WritePropertiesTo(RabbitMQ.Client.Impl.ContentHeaderPropertyWriter writer) {
1750       writer.WritePresence(m_contentType_present);
1751       writer.WritePresence(m_contentEncoding_present);
1752       writer.WritePresence(m_headers_present);
1753       writer.WritePresence(m_priority_present);
1754       writer.WritePresence(m_timestamp_present);
1755       writer.FinishPresence();
1756       if (m_contentType_present) { writer.WriteShortstr(m_contentType); }
1757       if (m_contentEncoding_present) { writer.WriteShortstr(m_contentEncoding); }
1758       if (m_headers_present) { writer.WriteTable(m_headers); }
1759       if (m_priority_present) { writer.WriteOctet(m_priority); }
1760       if (m_timestamp_present) { writer.WriteTimestamp(m_timestamp); }
1761     }
1762
1763     public override void AppendPropertyDebugStringTo(System.Text.StringBuilder sb) {
1764       sb.Append("(");
1765       sb.Append("content-type="); sb.Append(m_contentType_present ? (m_contentType == null ? "(null)" : m_contentType.ToString()) : "_"); sb.Append(", ");
1766       sb.Append("content-encoding="); sb.Append(m_contentEncoding_present ? (m_contentEncoding == null ? "(null)" : m_contentEncoding.ToString()) : "_"); sb.Append(", ");
1767       sb.Append("headers="); sb.Append(m_headers_present ? (m_headers == null ? "(null)" : m_headers.ToString()) : "_"); sb.Append(", ");
1768       sb.Append("priority="); sb.Append(m_priority_present ? m_priority.ToString() : "_"); sb.Append(", ");
1769       sb.Append("timestamp="); sb.Append(m_timestamp_present ? m_timestamp.ToString() : "_");
1770       sb.Append(")");
1771     }
1772   }
1773   /// <summary>Autogenerated type. AMQP specification content header properties for content class "tunnel"</summary>
1774   public class TunnelProperties: RabbitMQ.Client.Impl.ContentHeaderBase {
1775     private System.Collections.IDictionary m_headers;
1776     private string m_proxyName;
1777     private string m_dataName;
1778     private byte m_durable;
1779     private byte m_broadcast;
1780
1781     private bool m_headers_present = false;
1782     private bool m_proxyName_present = false;
1783     private bool m_dataName_present = false;
1784     private bool m_durable_present = false;
1785     private bool m_broadcast_present = false;
1786
1787     public System.Collections.IDictionary Headers {
1788       get {
1789         return m_headers;
1790       }
1791       set {
1792         m_headers_present = true;
1793         m_headers = value;
1794       }
1795     }
1796     public string ProxyName {
1797       get {
1798         return m_proxyName;
1799       }
1800       set {
1801         m_proxyName_present = true;
1802         m_proxyName = value;
1803       }
1804     }
1805     public string DataName {
1806       get {
1807         return m_dataName;
1808       }
1809       set {
1810         m_dataName_present = true;
1811         m_dataName = value;
1812       }
1813     }
1814     public byte Durable {
1815       get {
1816         return m_durable;
1817       }
1818       set {
1819         m_durable_present = true;
1820         m_durable = value;
1821       }
1822     }
1823     public byte Broadcast {
1824       get {
1825         return m_broadcast;
1826       }
1827       set {
1828         m_broadcast_present = true;
1829         m_broadcast = value;
1830       }
1831     }
1832
1833     public void ClearHeaders() { m_headers_present = false; }
1834     public void ClearProxyName() { m_proxyName_present = false; }
1835     public void ClearDataName() { m_dataName_present = false; }
1836     public void ClearDurable() { m_durable_present = false; }
1837     public void ClearBroadcast() { m_broadcast_present = false; }
1838
1839     public TunnelProperties() {}
1840     public override int ProtocolClassId { get { return 110; } }
1841     public override string ProtocolClassName { get { return "tunnel"; } }
1842
1843     public override void ReadPropertiesFrom(RabbitMQ.Client.Impl.ContentHeaderPropertyReader reader) {
1844       m_headers_present = reader.ReadPresence();
1845       m_proxyName_present = reader.ReadPresence();
1846       m_dataName_present = reader.ReadPresence();
1847       m_durable_present = reader.ReadPresence();
1848       m_broadcast_present = reader.ReadPresence();
1849       reader.FinishPresence();
1850       if (m_headers_present) { m_headers = reader.ReadTable(); }
1851       if (m_proxyName_present) { m_proxyName = reader.ReadShortstr(); }
1852       if (m_dataName_present) { m_dataName = reader.ReadShortstr(); }
1853       if (m_durable_present) { m_durable = reader.ReadOctet(); }
1854       if (m_broadcast_present) { m_broadcast = reader.ReadOctet(); }
1855     }
1856
1857     public override void WritePropertiesTo(RabbitMQ.Client.Impl.ContentHeaderPropertyWriter writer) {
1858       writer.WritePresence(m_headers_present);
1859       writer.WritePresence(m_proxyName_present);
1860       writer.WritePresence(m_dataName_present);
1861       writer.WritePresence(m_durable_present);
1862       writer.WritePresence(m_broadcast_present);
1863       writer.FinishPresence();
1864       if (m_headers_present) { writer.WriteTable(m_headers); }
1865       if (m_proxyName_present) { writer.WriteShortstr(m_proxyName); }
1866       if (m_dataName_present) { writer.WriteShortstr(m_dataName); }
1867       if (m_durable_present) { writer.WriteOctet(m_durable); }
1868       if (m_broadcast_present) { writer.WriteOctet(m_broadcast); }
1869     }
1870
1871     public override void AppendPropertyDebugStringTo(System.Text.StringBuilder sb) {
1872       sb.Append("(");
1873       sb.Append("headers="); sb.Append(m_headers_present ? (m_headers == null ? "(null)" : m_headers.ToString()) : "_"); sb.Append(", ");
1874       sb.Append("proxy-name="); sb.Append(m_proxyName_present ? (m_proxyName == null ? "(null)" : m_proxyName.ToString()) : "_"); sb.Append(", ");
1875       sb.Append("data-name="); sb.Append(m_dataName_present ? (m_dataName == null ? "(null)" : m_dataName.ToString()) : "_"); sb.Append(", ");
1876       sb.Append("durable="); sb.Append(m_durable_present ? m_durable.ToString() : "_"); sb.Append(", ");
1877       sb.Append("broadcast="); sb.Append(m_broadcast_present ? m_broadcast.ToString() : "_");
1878       sb.Append(")");
1879     }
1880   }
1881 }
1882 namespace RabbitMQ.Client.Framing.Impl.v0_9 {
1883   using RabbitMQ.Client.Framing.v0_9;
1884   public enum ClassId {
1885     Connection = 10,
1886     Channel = 20,
1887     Access = 30,
1888     Exchange = 40,
1889     Queue = 50,
1890     Basic = 60,
1891     File = 70,
1892     Stream = 80,
1893     Tx = 90,
1894     Dtx = 100,
1895     Tunnel = 110,
1896     Message = 120,
1897     Invalid = -1
1898   }
1899   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
1900   public class ConnectionStart: RabbitMQ.Client.Impl.MethodBase, IConnectionStart {
1901     public const int ClassId = 10;
1902     public const int MethodId = 10;
1903
1904     public byte m_versionMajor;
1905     public byte m_versionMinor;
1906     public System.Collections.IDictionary m_serverProperties;
1907     public byte[] m_mechanisms;
1908     public byte[] m_locales;
1909
1910     byte IConnectionStart.VersionMajor { get { return m_versionMajor; } }
1911     byte IConnectionStart.VersionMinor { get { return m_versionMinor; } }
1912     System.Collections.IDictionary IConnectionStart.ServerProperties { get { return m_serverProperties; } }
1913     byte[] IConnectionStart.Mechanisms { get { return m_mechanisms; } }
1914     byte[] IConnectionStart.Locales { get { return m_locales; } }
1915
1916     public ConnectionStart() {}
1917     public ConnectionStart(
1918       byte initVersionMajor,
1919       byte initVersionMinor,
1920       System.Collections.IDictionary initServerProperties,
1921       byte[] initMechanisms,
1922       byte[] initLocales)
1923     {
1924       m_versionMajor = initVersionMajor;
1925       m_versionMinor = initVersionMinor;
1926       m_serverProperties = initServerProperties;
1927       m_mechanisms = initMechanisms;
1928       m_locales = initLocales;
1929     }
1930
1931     public override int ProtocolClassId { get { return 10; } }
1932     public override int ProtocolMethodId { get { return 10; } }
1933     public override string ProtocolMethodName { get { return "connection.start"; } }
1934     public override bool HasContent { get { return false; } }
1935
1936     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
1937       m_versionMajor = reader.ReadOctet();
1938       m_versionMinor = reader.ReadOctet();
1939       m_serverProperties = reader.ReadTable();
1940       m_mechanisms = reader.ReadLongstr();
1941       m_locales = reader.ReadLongstr();
1942     }
1943
1944     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
1945       writer.WriteOctet(m_versionMajor);
1946       writer.WriteOctet(m_versionMinor);
1947       writer.WriteTable(m_serverProperties);
1948       writer.WriteLongstr(m_mechanisms);
1949       writer.WriteLongstr(m_locales);
1950     }
1951
1952     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
1953       sb.Append("(");
1954       sb.Append(m_versionMajor); sb.Append(",");
1955       sb.Append(m_versionMinor); sb.Append(",");
1956       sb.Append(m_serverProperties); sb.Append(",");
1957       sb.Append(m_mechanisms); sb.Append(",");
1958       sb.Append(m_locales);
1959       sb.Append(")");
1960     }
1961   }
1962   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
1963   public class ConnectionStartOk: RabbitMQ.Client.Impl.MethodBase, IConnectionStartOk {
1964     public const int ClassId = 10;
1965     public const int MethodId = 11;
1966
1967     public System.Collections.IDictionary m_clientProperties;
1968     public string m_mechanism;
1969     public byte[] m_response;
1970     public string m_locale;
1971
1972     System.Collections.IDictionary IConnectionStartOk.ClientProperties { get { return m_clientProperties; } }
1973     string IConnectionStartOk.Mechanism { get { return m_mechanism; } }
1974     byte[] IConnectionStartOk.Response { get { return m_response; } }
1975     string IConnectionStartOk.Locale { get { return m_locale; } }
1976
1977     public ConnectionStartOk() {}
1978     public ConnectionStartOk(
1979       System.Collections.IDictionary initClientProperties,
1980       string initMechanism,
1981       byte[] initResponse,
1982       string initLocale)
1983     {
1984       m_clientProperties = initClientProperties;
1985       m_mechanism = initMechanism;
1986       m_response = initResponse;
1987       m_locale = initLocale;
1988     }
1989
1990     public override int ProtocolClassId { get { return 10; } }
1991     public override int ProtocolMethodId { get { return 11; } }
1992     public override string ProtocolMethodName { get { return "connection.start-ok"; } }
1993     public override bool HasContent { get { return false; } }
1994
1995     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
1996       m_clientProperties = reader.ReadTable();
1997       m_mechanism = reader.ReadShortstr();
1998       m_response = reader.ReadLongstr();
1999       m_locale = reader.ReadShortstr();
2000     }
2001
2002     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2003       writer.WriteTable(m_clientProperties);
2004       writer.WriteShortstr(m_mechanism);
2005       writer.WriteLongstr(m_response);
2006       writer.WriteShortstr(m_locale);
2007     }
2008
2009     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2010       sb.Append("(");
2011       sb.Append(m_clientProperties); sb.Append(",");
2012       sb.Append(m_mechanism); sb.Append(",");
2013       sb.Append(m_response); sb.Append(",");
2014       sb.Append(m_locale);
2015       sb.Append(")");
2016     }
2017   }
2018   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2019   public class ConnectionSecure: RabbitMQ.Client.Impl.MethodBase, IConnectionSecure {
2020     public const int ClassId = 10;
2021     public const int MethodId = 20;
2022
2023     public byte[] m_challenge;
2024
2025     byte[] IConnectionSecure.Challenge { get { return m_challenge; } }
2026
2027     public ConnectionSecure() {}
2028     public ConnectionSecure(
2029       byte[] initChallenge)
2030     {
2031       m_challenge = initChallenge;
2032     }
2033
2034     public override int ProtocolClassId { get { return 10; } }
2035     public override int ProtocolMethodId { get { return 20; } }
2036     public override string ProtocolMethodName { get { return "connection.secure"; } }
2037     public override bool HasContent { get { return false; } }
2038
2039     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2040       m_challenge = reader.ReadLongstr();
2041     }
2042
2043     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2044       writer.WriteLongstr(m_challenge);
2045     }
2046
2047     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2048       sb.Append("(");
2049       sb.Append(m_challenge);
2050       sb.Append(")");
2051     }
2052   }
2053   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2054   public class ConnectionSecureOk: RabbitMQ.Client.Impl.MethodBase, IConnectionSecureOk {
2055     public const int ClassId = 10;
2056     public const int MethodId = 21;
2057
2058     public byte[] m_response;
2059
2060     byte[] IConnectionSecureOk.Response { get { return m_response; } }
2061
2062     public ConnectionSecureOk() {}
2063     public ConnectionSecureOk(
2064       byte[] initResponse)
2065     {
2066       m_response = initResponse;
2067     }
2068
2069     public override int ProtocolClassId { get { return 10; } }
2070     public override int ProtocolMethodId { get { return 21; } }
2071     public override string ProtocolMethodName { get { return "connection.secure-ok"; } }
2072     public override bool HasContent { get { return false; } }
2073
2074     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2075       m_response = reader.ReadLongstr();
2076     }
2077
2078     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2079       writer.WriteLongstr(m_response);
2080     }
2081
2082     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2083       sb.Append("(");
2084       sb.Append(m_response);
2085       sb.Append(")");
2086     }
2087   }
2088   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2089   public class ConnectionTune: RabbitMQ.Client.Impl.MethodBase, IConnectionTune {
2090     public const int ClassId = 10;
2091     public const int MethodId = 30;
2092
2093     public ushort m_channelMax;
2094     public uint m_frameMax;
2095     public ushort m_heartbeat;
2096
2097     ushort IConnectionTune.ChannelMax { get { return m_channelMax; } }
2098     uint IConnectionTune.FrameMax { get { return m_frameMax; } }
2099     ushort IConnectionTune.Heartbeat { get { return m_heartbeat; } }
2100
2101     public ConnectionTune() {}
2102     public ConnectionTune(
2103       ushort initChannelMax,
2104       uint initFrameMax,
2105       ushort initHeartbeat)
2106     {
2107       m_channelMax = initChannelMax;
2108       m_frameMax = initFrameMax;
2109       m_heartbeat = initHeartbeat;
2110     }
2111
2112     public override int ProtocolClassId { get { return 10; } }
2113     public override int ProtocolMethodId { get { return 30; } }
2114     public override string ProtocolMethodName { get { return "connection.tune"; } }
2115     public override bool HasContent { get { return false; } }
2116
2117     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2118       m_channelMax = reader.ReadShort();
2119       m_frameMax = reader.ReadLong();
2120       m_heartbeat = reader.ReadShort();
2121     }
2122
2123     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2124       writer.WriteShort(m_channelMax);
2125       writer.WriteLong(m_frameMax);
2126       writer.WriteShort(m_heartbeat);
2127     }
2128
2129     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2130       sb.Append("(");
2131       sb.Append(m_channelMax); sb.Append(",");
2132       sb.Append(m_frameMax); sb.Append(",");
2133       sb.Append(m_heartbeat);
2134       sb.Append(")");
2135     }
2136   }
2137   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2138   public class ConnectionTuneOk: RabbitMQ.Client.Impl.MethodBase, IConnectionTuneOk {
2139     public const int ClassId = 10;
2140     public const int MethodId = 31;
2141
2142     public ushort m_channelMax;
2143     public uint m_frameMax;
2144     public ushort m_heartbeat;
2145
2146     ushort IConnectionTuneOk.ChannelMax { get { return m_channelMax; } }
2147     uint IConnectionTuneOk.FrameMax { get { return m_frameMax; } }
2148     ushort IConnectionTuneOk.Heartbeat { get { return m_heartbeat; } }
2149
2150     public ConnectionTuneOk() {}
2151     public ConnectionTuneOk(
2152       ushort initChannelMax,
2153       uint initFrameMax,
2154       ushort initHeartbeat)
2155     {
2156       m_channelMax = initChannelMax;
2157       m_frameMax = initFrameMax;
2158       m_heartbeat = initHeartbeat;
2159     }
2160
2161     public override int ProtocolClassId { get { return 10; } }
2162     public override int ProtocolMethodId { get { return 31; } }
2163     public override string ProtocolMethodName { get { return "connection.tune-ok"; } }
2164     public override bool HasContent { get { return false; } }
2165
2166     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2167       m_channelMax = reader.ReadShort();
2168       m_frameMax = reader.ReadLong();
2169       m_heartbeat = reader.ReadShort();
2170     }
2171
2172     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2173       writer.WriteShort(m_channelMax);
2174       writer.WriteLong(m_frameMax);
2175       writer.WriteShort(m_heartbeat);
2176     }
2177
2178     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2179       sb.Append("(");
2180       sb.Append(m_channelMax); sb.Append(",");
2181       sb.Append(m_frameMax); sb.Append(",");
2182       sb.Append(m_heartbeat);
2183       sb.Append(")");
2184     }
2185   }
2186   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2187   public class ConnectionOpen: RabbitMQ.Client.Impl.MethodBase, IConnectionOpen {
2188     public const int ClassId = 10;
2189     public const int MethodId = 40;
2190
2191     public string m_virtualHost;
2192     public string m_capabilities;
2193     public bool m_insist;
2194
2195     string IConnectionOpen.VirtualHost { get { return m_virtualHost; } }
2196     string IConnectionOpen.Capabilities { get { return m_capabilities; } }
2197     bool IConnectionOpen.Insist { get { return m_insist; } }
2198
2199     public ConnectionOpen() {}
2200     public ConnectionOpen(
2201       string initVirtualHost,
2202       string initCapabilities,
2203       bool initInsist)
2204     {
2205       m_virtualHost = initVirtualHost;
2206       m_capabilities = initCapabilities;
2207       m_insist = initInsist;
2208     }
2209
2210     public override int ProtocolClassId { get { return 10; } }
2211     public override int ProtocolMethodId { get { return 40; } }
2212     public override string ProtocolMethodName { get { return "connection.open"; } }
2213     public override bool HasContent { get { return false; } }
2214
2215     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2216       m_virtualHost = reader.ReadShortstr();
2217       m_capabilities = reader.ReadShortstr();
2218       m_insist = reader.ReadBit();
2219     }
2220
2221     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2222       writer.WriteShortstr(m_virtualHost);
2223       writer.WriteShortstr(m_capabilities);
2224       writer.WriteBit(m_insist);
2225     }
2226
2227     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2228       sb.Append("(");
2229       sb.Append(m_virtualHost); sb.Append(",");
2230       sb.Append(m_capabilities); sb.Append(",");
2231       sb.Append(m_insist);
2232       sb.Append(")");
2233     }
2234   }
2235   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2236   public class ConnectionOpenOk: RabbitMQ.Client.Impl.MethodBase, IConnectionOpenOk {
2237     public const int ClassId = 10;
2238     public const int MethodId = 41;
2239
2240     public string m_knownHosts;
2241
2242     string IConnectionOpenOk.KnownHosts { get { return m_knownHosts; } }
2243
2244     public ConnectionOpenOk() {}
2245     public ConnectionOpenOk(
2246       string initKnownHosts)
2247     {
2248       m_knownHosts = initKnownHosts;
2249     }
2250
2251     public override int ProtocolClassId { get { return 10; } }
2252     public override int ProtocolMethodId { get { return 41; } }
2253     public override string ProtocolMethodName { get { return "connection.open-ok"; } }
2254     public override bool HasContent { get { return false; } }
2255
2256     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2257       m_knownHosts = reader.ReadShortstr();
2258     }
2259
2260     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2261       writer.WriteShortstr(m_knownHosts);
2262     }
2263
2264     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2265       sb.Append("(");
2266       sb.Append(m_knownHosts);
2267       sb.Append(")");
2268     }
2269   }
2270   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2271   public class ConnectionRedirect: RabbitMQ.Client.Impl.MethodBase, IConnectionRedirect {
2272     public const int ClassId = 10;
2273     public const int MethodId = 42;
2274
2275     public string m_host;
2276     public string m_knownHosts;
2277
2278     string IConnectionRedirect.Host { get { return m_host; } }
2279     string IConnectionRedirect.KnownHosts { get { return m_knownHosts; } }
2280
2281     public ConnectionRedirect() {}
2282     public ConnectionRedirect(
2283       string initHost,
2284       string initKnownHosts)
2285     {
2286       m_host = initHost;
2287       m_knownHosts = initKnownHosts;
2288     }
2289
2290     public override int ProtocolClassId { get { return 10; } }
2291     public override int ProtocolMethodId { get { return 42; } }
2292     public override string ProtocolMethodName { get { return "connection.redirect"; } }
2293     public override bool HasContent { get { return false; } }
2294
2295     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2296       m_host = reader.ReadShortstr();
2297       m_knownHosts = reader.ReadShortstr();
2298     }
2299
2300     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2301       writer.WriteShortstr(m_host);
2302       writer.WriteShortstr(m_knownHosts);
2303     }
2304
2305     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2306       sb.Append("(");
2307       sb.Append(m_host); sb.Append(",");
2308       sb.Append(m_knownHosts);
2309       sb.Append(")");
2310     }
2311   }
2312   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2313   public class ConnectionClose: RabbitMQ.Client.Impl.MethodBase, IConnectionClose {
2314     public const int ClassId = 10;
2315     public const int MethodId = 50;
2316
2317     public ushort m_replyCode;
2318     public string m_replyText;
2319     public ushort m_classId;
2320     public ushort m_methodId;
2321
2322     ushort IConnectionClose.ReplyCode { get { return m_replyCode; } }
2323     string IConnectionClose.ReplyText { get { return m_replyText; } }
2324     ushort IConnectionClose.ClassId { get { return m_classId; } }
2325     ushort IConnectionClose.MethodId { get { return m_methodId; } }
2326
2327     public ConnectionClose() {}
2328     public ConnectionClose(
2329       ushort initReplyCode,
2330       string initReplyText,
2331       ushort initClassId,
2332       ushort initMethodId)
2333     {
2334       m_replyCode = initReplyCode;
2335       m_replyText = initReplyText;
2336       m_classId = initClassId;
2337       m_methodId = initMethodId;
2338     }
2339
2340     public override int ProtocolClassId { get { return 10; } }
2341     public override int ProtocolMethodId { get { return 50; } }
2342     public override string ProtocolMethodName { get { return "connection.close"; } }
2343     public override bool HasContent { get { return false; } }
2344
2345     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2346       m_replyCode = reader.ReadShort();
2347       m_replyText = reader.ReadShortstr();
2348       m_classId = reader.ReadShort();
2349       m_methodId = reader.ReadShort();
2350     }
2351
2352     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2353       writer.WriteShort(m_replyCode);
2354       writer.WriteShortstr(m_replyText);
2355       writer.WriteShort(m_classId);
2356       writer.WriteShort(m_methodId);
2357     }
2358
2359     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2360       sb.Append("(");
2361       sb.Append(m_replyCode); sb.Append(",");
2362       sb.Append(m_replyText); sb.Append(",");
2363       sb.Append(m_classId); sb.Append(",");
2364       sb.Append(m_methodId);
2365       sb.Append(")");
2366     }
2367   }
2368   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2369   public class ConnectionCloseOk: RabbitMQ.Client.Impl.MethodBase, IConnectionCloseOk {
2370     public const int ClassId = 10;
2371     public const int MethodId = 51;
2372
2373
2374
2375     public ConnectionCloseOk(
2376 )
2377     {
2378     }
2379
2380     public override int ProtocolClassId { get { return 10; } }
2381     public override int ProtocolMethodId { get { return 51; } }
2382     public override string ProtocolMethodName { get { return "connection.close-ok"; } }
2383     public override bool HasContent { get { return false; } }
2384
2385     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2386     }
2387
2388     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2389     }
2390
2391     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2392       sb.Append("(");
2393       sb.Append(")");
2394     }
2395   }
2396   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2397   public class ChannelOpen: RabbitMQ.Client.Impl.MethodBase, IChannelOpen {
2398     public const int ClassId = 20;
2399     public const int MethodId = 10;
2400
2401     public string m_outOfBand;
2402
2403     string IChannelOpen.OutOfBand { get { return m_outOfBand; } }
2404
2405     public ChannelOpen() {}
2406     public ChannelOpen(
2407       string initOutOfBand)
2408     {
2409       m_outOfBand = initOutOfBand;
2410     }
2411
2412     public override int ProtocolClassId { get { return 20; } }
2413     public override int ProtocolMethodId { get { return 10; } }
2414     public override string ProtocolMethodName { get { return "channel.open"; } }
2415     public override bool HasContent { get { return false; } }
2416
2417     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2418       m_outOfBand = reader.ReadShortstr();
2419     }
2420
2421     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2422       writer.WriteShortstr(m_outOfBand);
2423     }
2424
2425     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2426       sb.Append("(");
2427       sb.Append(m_outOfBand);
2428       sb.Append(")");
2429     }
2430   }
2431   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2432   public class ChannelOpenOk: RabbitMQ.Client.Impl.MethodBase, IChannelOpenOk {
2433     public const int ClassId = 20;
2434     public const int MethodId = 11;
2435
2436     public byte[] m_channelId;
2437
2438     byte[] IChannelOpenOk.ChannelId { get { return m_channelId; } }
2439
2440     public ChannelOpenOk() {}
2441     public ChannelOpenOk(
2442       byte[] initChannelId)
2443     {
2444       m_channelId = initChannelId;
2445     }
2446
2447     public override int ProtocolClassId { get { return 20; } }
2448     public override int ProtocolMethodId { get { return 11; } }
2449     public override string ProtocolMethodName { get { return "channel.open-ok"; } }
2450     public override bool HasContent { get { return false; } }
2451
2452     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2453       m_channelId = reader.ReadLongstr();
2454     }
2455
2456     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2457       writer.WriteLongstr(m_channelId);
2458     }
2459
2460     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2461       sb.Append("(");
2462       sb.Append(m_channelId);
2463       sb.Append(")");
2464     }
2465   }
2466   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2467   public class ChannelFlow: RabbitMQ.Client.Impl.MethodBase, IChannelFlow {
2468     public const int ClassId = 20;
2469     public const int MethodId = 20;
2470
2471     public bool m_active;
2472
2473     bool IChannelFlow.Active { get { return m_active; } }
2474
2475     public ChannelFlow() {}
2476     public ChannelFlow(
2477       bool initActive)
2478     {
2479       m_active = initActive;
2480     }
2481
2482     public override int ProtocolClassId { get { return 20; } }
2483     public override int ProtocolMethodId { get { return 20; } }
2484     public override string ProtocolMethodName { get { return "channel.flow"; } }
2485     public override bool HasContent { get { return false; } }
2486
2487     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2488       m_active = reader.ReadBit();
2489     }
2490
2491     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2492       writer.WriteBit(m_active);
2493     }
2494
2495     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2496       sb.Append("(");
2497       sb.Append(m_active);
2498       sb.Append(")");
2499     }
2500   }
2501   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2502   public class ChannelFlowOk: RabbitMQ.Client.Impl.MethodBase, IChannelFlowOk {
2503     public const int ClassId = 20;
2504     public const int MethodId = 21;
2505
2506     public bool m_active;
2507
2508     bool IChannelFlowOk.Active { get { return m_active; } }
2509
2510     public ChannelFlowOk() {}
2511     public ChannelFlowOk(
2512       bool initActive)
2513     {
2514       m_active = initActive;
2515     }
2516
2517     public override int ProtocolClassId { get { return 20; } }
2518     public override int ProtocolMethodId { get { return 21; } }
2519     public override string ProtocolMethodName { get { return "channel.flow-ok"; } }
2520     public override bool HasContent { get { return false; } }
2521
2522     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2523       m_active = reader.ReadBit();
2524     }
2525
2526     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2527       writer.WriteBit(m_active);
2528     }
2529
2530     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2531       sb.Append("(");
2532       sb.Append(m_active);
2533       sb.Append(")");
2534     }
2535   }
2536   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2537   public class ChannelClose: RabbitMQ.Client.Impl.MethodBase, IChannelClose {
2538     public const int ClassId = 20;
2539     public const int MethodId = 40;
2540
2541     public ushort m_replyCode;
2542     public string m_replyText;
2543     public ushort m_classId;
2544     public ushort m_methodId;
2545
2546     ushort IChannelClose.ReplyCode { get { return m_replyCode; } }
2547     string IChannelClose.ReplyText { get { return m_replyText; } }
2548     ushort IChannelClose.ClassId { get { return m_classId; } }
2549     ushort IChannelClose.MethodId { get { return m_methodId; } }
2550
2551     public ChannelClose() {}
2552     public ChannelClose(
2553       ushort initReplyCode,
2554       string initReplyText,
2555       ushort initClassId,
2556       ushort initMethodId)
2557     {
2558       m_replyCode = initReplyCode;
2559       m_replyText = initReplyText;
2560       m_classId = initClassId;
2561       m_methodId = initMethodId;
2562     }
2563
2564     public override int ProtocolClassId { get { return 20; } }
2565     public override int ProtocolMethodId { get { return 40; } }
2566     public override string ProtocolMethodName { get { return "channel.close"; } }
2567     public override bool HasContent { get { return false; } }
2568
2569     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2570       m_replyCode = reader.ReadShort();
2571       m_replyText = reader.ReadShortstr();
2572       m_classId = reader.ReadShort();
2573       m_methodId = reader.ReadShort();
2574     }
2575
2576     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2577       writer.WriteShort(m_replyCode);
2578       writer.WriteShortstr(m_replyText);
2579       writer.WriteShort(m_classId);
2580       writer.WriteShort(m_methodId);
2581     }
2582
2583     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2584       sb.Append("(");
2585       sb.Append(m_replyCode); sb.Append(",");
2586       sb.Append(m_replyText); sb.Append(",");
2587       sb.Append(m_classId); sb.Append(",");
2588       sb.Append(m_methodId);
2589       sb.Append(")");
2590     }
2591   }
2592   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2593   public class ChannelCloseOk: RabbitMQ.Client.Impl.MethodBase, IChannelCloseOk {
2594     public const int ClassId = 20;
2595     public const int MethodId = 41;
2596
2597
2598
2599     public ChannelCloseOk(
2600 )
2601     {
2602     }
2603
2604     public override int ProtocolClassId { get { return 20; } }
2605     public override int ProtocolMethodId { get { return 41; } }
2606     public override string ProtocolMethodName { get { return "channel.close-ok"; } }
2607     public override bool HasContent { get { return false; } }
2608
2609     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2610     }
2611
2612     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2613     }
2614
2615     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2616       sb.Append("(");
2617       sb.Append(")");
2618     }
2619   }
2620   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2621   public class ChannelResume: RabbitMQ.Client.Impl.MethodBase, IChannelResume {
2622     public const int ClassId = 20;
2623     public const int MethodId = 50;
2624
2625     public byte[] m_channelId;
2626
2627     byte[] IChannelResume.ChannelId { get { return m_channelId; } }
2628
2629     public ChannelResume() {}
2630     public ChannelResume(
2631       byte[] initChannelId)
2632     {
2633       m_channelId = initChannelId;
2634     }
2635
2636     public override int ProtocolClassId { get { return 20; } }
2637     public override int ProtocolMethodId { get { return 50; } }
2638     public override string ProtocolMethodName { get { return "channel.resume"; } }
2639     public override bool HasContent { get { return false; } }
2640
2641     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2642       m_channelId = reader.ReadLongstr();
2643     }
2644
2645     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2646       writer.WriteLongstr(m_channelId);
2647     }
2648
2649     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2650       sb.Append("(");
2651       sb.Append(m_channelId);
2652       sb.Append(")");
2653     }
2654   }
2655   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2656   public class ChannelPing: RabbitMQ.Client.Impl.MethodBase, IChannelPing {
2657     public const int ClassId = 20;
2658     public const int MethodId = 60;
2659
2660
2661
2662     public ChannelPing(
2663 )
2664     {
2665     }
2666
2667     public override int ProtocolClassId { get { return 20; } }
2668     public override int ProtocolMethodId { get { return 60; } }
2669     public override string ProtocolMethodName { get { return "channel.ping"; } }
2670     public override bool HasContent { get { return false; } }
2671
2672     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2673     }
2674
2675     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2676     }
2677
2678     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2679       sb.Append("(");
2680       sb.Append(")");
2681     }
2682   }
2683   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2684   public class ChannelPong: RabbitMQ.Client.Impl.MethodBase, IChannelPong {
2685     public const int ClassId = 20;
2686     public const int MethodId = 70;
2687
2688
2689
2690     public ChannelPong(
2691 )
2692     {
2693     }
2694
2695     public override int ProtocolClassId { get { return 20; } }
2696     public override int ProtocolMethodId { get { return 70; } }
2697     public override string ProtocolMethodName { get { return "channel.pong"; } }
2698     public override bool HasContent { get { return false; } }
2699
2700     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2701     }
2702
2703     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2704     }
2705
2706     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2707       sb.Append("(");
2708       sb.Append(")");
2709     }
2710   }
2711   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2712   public class ChannelOk: RabbitMQ.Client.Impl.MethodBase, IChannelOk {
2713     public const int ClassId = 20;
2714     public const int MethodId = 80;
2715
2716
2717
2718     public ChannelOk(
2719 )
2720     {
2721     }
2722
2723     public override int ProtocolClassId { get { return 20; } }
2724     public override int ProtocolMethodId { get { return 80; } }
2725     public override string ProtocolMethodName { get { return "channel.ok"; } }
2726     public override bool HasContent { get { return false; } }
2727
2728     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2729     }
2730
2731     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2732     }
2733
2734     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2735       sb.Append("(");
2736       sb.Append(")");
2737     }
2738   }
2739   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2740   public class AccessRequest: RabbitMQ.Client.Impl.MethodBase, IAccessRequest {
2741     public const int ClassId = 30;
2742     public const int MethodId = 10;
2743
2744     public string m_realm;
2745     public bool m_exclusive;
2746     public bool m_passive;
2747     public bool m_active;
2748     public bool m_write;
2749     public bool m_read;
2750
2751     string IAccessRequest.Realm { get { return m_realm; } }
2752     bool IAccessRequest.Exclusive { get { return m_exclusive; } }
2753     bool IAccessRequest.Passive { get { return m_passive; } }
2754     bool IAccessRequest.Active { get { return m_active; } }
2755     bool IAccessRequest.Write { get { return m_write; } }
2756     bool IAccessRequest.Read { get { return m_read; } }
2757
2758     public AccessRequest() {}
2759     public AccessRequest(
2760       string initRealm,
2761       bool initExclusive,
2762       bool initPassive,
2763       bool initActive,
2764       bool initWrite,
2765       bool initRead)
2766     {
2767       m_realm = initRealm;
2768       m_exclusive = initExclusive;
2769       m_passive = initPassive;
2770       m_active = initActive;
2771       m_write = initWrite;
2772       m_read = initRead;
2773     }
2774
2775     public override int ProtocolClassId { get { return 30; } }
2776     public override int ProtocolMethodId { get { return 10; } }
2777     public override string ProtocolMethodName { get { return "access.request"; } }
2778     public override bool HasContent { get { return false; } }
2779
2780     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2781       m_realm = reader.ReadShortstr();
2782       m_exclusive = reader.ReadBit();
2783       m_passive = reader.ReadBit();
2784       m_active = reader.ReadBit();
2785       m_write = reader.ReadBit();
2786       m_read = reader.ReadBit();
2787     }
2788
2789     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2790       writer.WriteShortstr(m_realm);
2791       writer.WriteBit(m_exclusive);
2792       writer.WriteBit(m_passive);
2793       writer.WriteBit(m_active);
2794       writer.WriteBit(m_write);
2795       writer.WriteBit(m_read);
2796     }
2797
2798     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2799       sb.Append("(");
2800       sb.Append(m_realm); sb.Append(",");
2801       sb.Append(m_exclusive); sb.Append(",");
2802       sb.Append(m_passive); sb.Append(",");
2803       sb.Append(m_active); sb.Append(",");
2804       sb.Append(m_write); sb.Append(",");
2805       sb.Append(m_read);
2806       sb.Append(")");
2807     }
2808   }
2809   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2810   public class AccessRequestOk: RabbitMQ.Client.Impl.MethodBase, IAccessRequestOk {
2811     public const int ClassId = 30;
2812     public const int MethodId = 11;
2813
2814     public ushort m_ticket;
2815
2816     ushort IAccessRequestOk.Ticket { get { return m_ticket; } }
2817
2818     public AccessRequestOk() {}
2819     public AccessRequestOk(
2820       ushort initTicket)
2821     {
2822       m_ticket = initTicket;
2823     }
2824
2825     public override int ProtocolClassId { get { return 30; } }
2826     public override int ProtocolMethodId { get { return 11; } }
2827     public override string ProtocolMethodName { get { return "access.request-ok"; } }
2828     public override bool HasContent { get { return false; } }
2829
2830     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2831       m_ticket = reader.ReadShort();
2832     }
2833
2834     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2835       writer.WriteShort(m_ticket);
2836     }
2837
2838     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2839       sb.Append("(");
2840       sb.Append(m_ticket);
2841       sb.Append(")");
2842     }
2843   }
2844   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2845   public class ExchangeDeclare: RabbitMQ.Client.Impl.MethodBase, IExchangeDeclare {
2846     public const int ClassId = 40;
2847     public const int MethodId = 10;
2848
2849     public ushort m_ticket;
2850     public string m_exchange;
2851     public string m_type;
2852     public bool m_passive;
2853     public bool m_durable;
2854     public bool m_autoDelete;
2855     public bool m_internal;
2856     public bool m_nowait;
2857     public System.Collections.IDictionary m_arguments;
2858
2859     ushort IExchangeDeclare.Ticket { get { return m_ticket; } }
2860     string IExchangeDeclare.Exchange { get { return m_exchange; } }
2861     string IExchangeDeclare.Type { get { return m_type; } }
2862     bool IExchangeDeclare.Passive { get { return m_passive; } }
2863     bool IExchangeDeclare.Durable { get { return m_durable; } }
2864     bool IExchangeDeclare.AutoDelete { get { return m_autoDelete; } }
2865     bool IExchangeDeclare.Internal { get { return m_internal; } }
2866     bool IExchangeDeclare.Nowait { get { return m_nowait; } }
2867     System.Collections.IDictionary IExchangeDeclare.Arguments { get { return m_arguments; } }
2868
2869     public ExchangeDeclare() {}
2870     public ExchangeDeclare(
2871       ushort initTicket,
2872       string initExchange,
2873       string initType,
2874       bool initPassive,
2875       bool initDurable,
2876       bool initAutoDelete,
2877       bool initInternal,
2878       bool initNowait,
2879       System.Collections.IDictionary initArguments)
2880     {
2881       m_ticket = initTicket;
2882       m_exchange = initExchange;
2883       m_type = initType;
2884       m_passive = initPassive;
2885       m_durable = initDurable;
2886       m_autoDelete = initAutoDelete;
2887       m_internal = initInternal;
2888       m_nowait = initNowait;
2889       m_arguments = initArguments;
2890     }
2891
2892     public override int ProtocolClassId { get { return 40; } }
2893     public override int ProtocolMethodId { get { return 10; } }
2894     public override string ProtocolMethodName { get { return "exchange.declare"; } }
2895     public override bool HasContent { get { return false; } }
2896
2897     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2898       m_ticket = reader.ReadShort();
2899       m_exchange = reader.ReadShortstr();
2900       m_type = reader.ReadShortstr();
2901       m_passive = reader.ReadBit();
2902       m_durable = reader.ReadBit();
2903       m_autoDelete = reader.ReadBit();
2904       m_internal = reader.ReadBit();
2905       m_nowait = reader.ReadBit();
2906       m_arguments = reader.ReadTable();
2907     }
2908
2909     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2910       writer.WriteShort(m_ticket);
2911       writer.WriteShortstr(m_exchange);
2912       writer.WriteShortstr(m_type);
2913       writer.WriteBit(m_passive);
2914       writer.WriteBit(m_durable);
2915       writer.WriteBit(m_autoDelete);
2916       writer.WriteBit(m_internal);
2917       writer.WriteBit(m_nowait);
2918       writer.WriteTable(m_arguments);
2919     }
2920
2921     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2922       sb.Append("(");
2923       sb.Append(m_ticket); sb.Append(",");
2924       sb.Append(m_exchange); sb.Append(",");
2925       sb.Append(m_type); sb.Append(",");
2926       sb.Append(m_passive); sb.Append(",");
2927       sb.Append(m_durable); sb.Append(",");
2928       sb.Append(m_autoDelete); sb.Append(",");
2929       sb.Append(m_internal); sb.Append(",");
2930       sb.Append(m_nowait); sb.Append(",");
2931       sb.Append(m_arguments);
2932       sb.Append(")");
2933     }
2934   }
2935   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2936   public class ExchangeDeclareOk: RabbitMQ.Client.Impl.MethodBase, IExchangeDeclareOk {
2937     public const int ClassId = 40;
2938     public const int MethodId = 11;
2939
2940
2941
2942     public ExchangeDeclareOk(
2943 )
2944     {
2945     }
2946
2947     public override int ProtocolClassId { get { return 40; } }
2948     public override int ProtocolMethodId { get { return 11; } }
2949     public override string ProtocolMethodName { get { return "exchange.declare-ok"; } }
2950     public override bool HasContent { get { return false; } }
2951
2952     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2953     }
2954
2955     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
2956     }
2957
2958     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
2959       sb.Append("(");
2960       sb.Append(")");
2961     }
2962   }
2963   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
2964   public class ExchangeDelete: RabbitMQ.Client.Impl.MethodBase, IExchangeDelete {
2965     public const int ClassId = 40;
2966     public const int MethodId = 20;
2967
2968     public ushort m_ticket;
2969     public string m_exchange;
2970     public bool m_ifUnused;
2971     public bool m_nowait;
2972
2973     ushort IExchangeDelete.Ticket { get { return m_ticket; } }
2974     string IExchangeDelete.Exchange { get { return m_exchange; } }
2975     bool IExchangeDelete.IfUnused { get { return m_ifUnused; } }
2976     bool IExchangeDelete.Nowait { get { return m_nowait; } }
2977
2978     public ExchangeDelete() {}
2979     public ExchangeDelete(
2980       ushort initTicket,
2981       string initExchange,
2982       bool initIfUnused,
2983       bool initNowait)
2984     {
2985       m_ticket = initTicket;
2986       m_exchange = initExchange;
2987       m_ifUnused = initIfUnused;
2988       m_nowait = initNowait;
2989     }
2990
2991     public override int ProtocolClassId { get { return 40; } }
2992     public override int ProtocolMethodId { get { return 20; } }
2993     public override string ProtocolMethodName { get { return "exchange.delete"; } }
2994     public override bool HasContent { get { return false; } }
2995
2996     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
2997       m_ticket = reader.ReadShort();
2998       m_exchange = reader.ReadShortstr();
2999       m_ifUnused = reader.ReadBit();
3000       m_nowait = reader.ReadBit();
3001     }
3002
3003     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3004       writer.WriteShort(m_ticket);
3005       writer.WriteShortstr(m_exchange);
3006       writer.WriteBit(m_ifUnused);
3007       writer.WriteBit(m_nowait);
3008     }
3009
3010     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3011       sb.Append("(");
3012       sb.Append(m_ticket); sb.Append(",");
3013       sb.Append(m_exchange); sb.Append(",");
3014       sb.Append(m_ifUnused); sb.Append(",");
3015       sb.Append(m_nowait);
3016       sb.Append(")");
3017     }
3018   }
3019   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3020   public class ExchangeDeleteOk: RabbitMQ.Client.Impl.MethodBase, IExchangeDeleteOk {
3021     public const int ClassId = 40;
3022     public const int MethodId = 21;
3023
3024
3025
3026     public ExchangeDeleteOk(
3027 )
3028     {
3029     }
3030
3031     public override int ProtocolClassId { get { return 40; } }
3032     public override int ProtocolMethodId { get { return 21; } }
3033     public override string ProtocolMethodName { get { return "exchange.delete-ok"; } }
3034     public override bool HasContent { get { return false; } }
3035
3036     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3037     }
3038
3039     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3040     }
3041
3042     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3043       sb.Append("(");
3044       sb.Append(")");
3045     }
3046   }
3047   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3048   public class QueueDeclare: RabbitMQ.Client.Impl.MethodBase, IQueueDeclare {
3049     public const int ClassId = 50;
3050     public const int MethodId = 10;
3051
3052     public ushort m_ticket;
3053     public string m_queue;
3054     public bool m_passive;
3055     public bool m_durable;
3056     public bool m_exclusive;
3057     public bool m_autoDelete;
3058     public bool m_nowait;
3059     public System.Collections.IDictionary m_arguments;
3060
3061     ushort IQueueDeclare.Ticket { get { return m_ticket; } }
3062     string IQueueDeclare.Queue { get { return m_queue; } }
3063     bool IQueueDeclare.Passive { get { return m_passive; } }
3064     bool IQueueDeclare.Durable { get { return m_durable; } }
3065     bool IQueueDeclare.Exclusive { get { return m_exclusive; } }
3066     bool IQueueDeclare.AutoDelete { get { return m_autoDelete; } }
3067     bool IQueueDeclare.Nowait { get { return m_nowait; } }
3068     System.Collections.IDictionary IQueueDeclare.Arguments { get { return m_arguments; } }
3069
3070     public QueueDeclare() {}
3071     public QueueDeclare(
3072       ushort initTicket,
3073       string initQueue,
3074       bool initPassive,
3075       bool initDurable,
3076       bool initExclusive,
3077       bool initAutoDelete,
3078       bool initNowait,
3079       System.Collections.IDictionary initArguments)
3080     {
3081       m_ticket = initTicket;
3082       m_queue = initQueue;
3083       m_passive = initPassive;
3084       m_durable = initDurable;
3085       m_exclusive = initExclusive;
3086       m_autoDelete = initAutoDelete;
3087       m_nowait = initNowait;
3088       m_arguments = initArguments;
3089     }
3090
3091     public override int ProtocolClassId { get { return 50; } }
3092     public override int ProtocolMethodId { get { return 10; } }
3093     public override string ProtocolMethodName { get { return "queue.declare"; } }
3094     public override bool HasContent { get { return false; } }
3095
3096     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3097       m_ticket = reader.ReadShort();
3098       m_queue = reader.ReadShortstr();
3099       m_passive = reader.ReadBit();
3100       m_durable = reader.ReadBit();
3101       m_exclusive = reader.ReadBit();
3102       m_autoDelete = reader.ReadBit();
3103       m_nowait = reader.ReadBit();
3104       m_arguments = reader.ReadTable();
3105     }
3106
3107     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3108       writer.WriteShort(m_ticket);
3109       writer.WriteShortstr(m_queue);
3110       writer.WriteBit(m_passive);
3111       writer.WriteBit(m_durable);
3112       writer.WriteBit(m_exclusive);
3113       writer.WriteBit(m_autoDelete);
3114       writer.WriteBit(m_nowait);
3115       writer.WriteTable(m_arguments);
3116     }
3117
3118     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3119       sb.Append("(");
3120       sb.Append(m_ticket); sb.Append(",");
3121       sb.Append(m_queue); sb.Append(",");
3122       sb.Append(m_passive); sb.Append(",");
3123       sb.Append(m_durable); sb.Append(",");
3124       sb.Append(m_exclusive); sb.Append(",");
3125       sb.Append(m_autoDelete); sb.Append(",");
3126       sb.Append(m_nowait); sb.Append(",");
3127       sb.Append(m_arguments);
3128       sb.Append(")");
3129     }
3130   }
3131   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3132   public class QueueDeclareOk: RabbitMQ.Client.Impl.MethodBase, IQueueDeclareOk {
3133     public const int ClassId = 50;
3134     public const int MethodId = 11;
3135
3136     public string m_queue;
3137     public uint m_messageCount;
3138     public uint m_consumerCount;
3139
3140     string IQueueDeclareOk.Queue { get { return m_queue; } }
3141     uint IQueueDeclareOk.MessageCount { get { return m_messageCount; } }
3142     uint IQueueDeclareOk.ConsumerCount { get { return m_consumerCount; } }
3143
3144     public QueueDeclareOk() {}
3145     public QueueDeclareOk(
3146       string initQueue,
3147       uint initMessageCount,
3148       uint initConsumerCount)
3149     {
3150       m_queue = initQueue;
3151       m_messageCount = initMessageCount;
3152       m_consumerCount = initConsumerCount;
3153     }
3154
3155     public override int ProtocolClassId { get { return 50; } }
3156     public override int ProtocolMethodId { get { return 11; } }
3157     public override string ProtocolMethodName { get { return "queue.declare-ok"; } }
3158     public override bool HasContent { get { return false; } }
3159
3160     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3161       m_queue = reader.ReadShortstr();
3162       m_messageCount = reader.ReadLong();
3163       m_consumerCount = reader.ReadLong();
3164     }
3165
3166     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3167       writer.WriteShortstr(m_queue);
3168       writer.WriteLong(m_messageCount);
3169       writer.WriteLong(m_consumerCount);
3170     }
3171
3172     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3173       sb.Append("(");
3174       sb.Append(m_queue); sb.Append(",");
3175       sb.Append(m_messageCount); sb.Append(",");
3176       sb.Append(m_consumerCount);
3177       sb.Append(")");
3178     }
3179   }
3180   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3181   public class QueueBind: RabbitMQ.Client.Impl.MethodBase, IQueueBind {
3182     public const int ClassId = 50;
3183     public const int MethodId = 20;
3184
3185     public ushort m_ticket;
3186     public string m_queue;
3187     public string m_exchange;
3188     public string m_routingKey;
3189     public bool m_nowait;
3190     public System.Collections.IDictionary m_arguments;
3191
3192     ushort IQueueBind.Ticket { get { return m_ticket; } }
3193     string IQueueBind.Queue { get { return m_queue; } }
3194     string IQueueBind.Exchange { get { return m_exchange; } }
3195     string IQueueBind.RoutingKey { get { return m_routingKey; } }
3196     bool IQueueBind.Nowait { get { return m_nowait; } }
3197     System.Collections.IDictionary IQueueBind.Arguments { get { return m_arguments; } }
3198
3199     public QueueBind() {}
3200     public QueueBind(
3201       ushort initTicket,
3202       string initQueue,
3203       string initExchange,
3204       string initRoutingKey,
3205       bool initNowait,
3206       System.Collections.IDictionary initArguments)
3207     {
3208       m_ticket = initTicket;
3209       m_queue = initQueue;
3210       m_exchange = initExchange;
3211       m_routingKey = initRoutingKey;
3212       m_nowait = initNowait;
3213       m_arguments = initArguments;
3214     }
3215
3216     public override int ProtocolClassId { get { return 50; } }
3217     public override int ProtocolMethodId { get { return 20; } }
3218     public override string ProtocolMethodName { get { return "queue.bind"; } }
3219     public override bool HasContent { get { return false; } }
3220
3221     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3222       m_ticket = reader.ReadShort();
3223       m_queue = reader.ReadShortstr();
3224       m_exchange = reader.ReadShortstr();
3225       m_routingKey = reader.ReadShortstr();
3226       m_nowait = reader.ReadBit();
3227       m_arguments = reader.ReadTable();
3228     }
3229
3230     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3231       writer.WriteShort(m_ticket);
3232       writer.WriteShortstr(m_queue);
3233       writer.WriteShortstr(m_exchange);
3234       writer.WriteShortstr(m_routingKey);
3235       writer.WriteBit(m_nowait);
3236       writer.WriteTable(m_arguments);
3237     }
3238
3239     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3240       sb.Append("(");
3241       sb.Append(m_ticket); sb.Append(",");
3242       sb.Append(m_queue); sb.Append(",");
3243       sb.Append(m_exchange); sb.Append(",");
3244       sb.Append(m_routingKey); sb.Append(",");
3245       sb.Append(m_nowait); sb.Append(",");
3246       sb.Append(m_arguments);
3247       sb.Append(")");
3248     }
3249   }
3250   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3251   public class QueueBindOk: RabbitMQ.Client.Impl.MethodBase, IQueueBindOk {
3252     public const int ClassId = 50;
3253     public const int MethodId = 21;
3254
3255
3256
3257     public QueueBindOk(
3258 )
3259     {
3260     }
3261
3262     public override int ProtocolClassId { get { return 50; } }
3263     public override int ProtocolMethodId { get { return 21; } }
3264     public override string ProtocolMethodName { get { return "queue.bind-ok"; } }
3265     public override bool HasContent { get { return false; } }
3266
3267     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3268     }
3269
3270     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3271     }
3272
3273     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3274       sb.Append("(");
3275       sb.Append(")");
3276     }
3277   }
3278   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3279   public class QueueUnbind: RabbitMQ.Client.Impl.MethodBase, IQueueUnbind {
3280     public const int ClassId = 50;
3281     public const int MethodId = 50;
3282
3283     public ushort m_ticket;
3284     public string m_queue;
3285     public string m_exchange;
3286     public string m_routingKey;
3287     public System.Collections.IDictionary m_arguments;
3288
3289     ushort IQueueUnbind.Ticket { get { return m_ticket; } }
3290     string IQueueUnbind.Queue { get { return m_queue; } }
3291     string IQueueUnbind.Exchange { get { return m_exchange; } }
3292     string IQueueUnbind.RoutingKey { get { return m_routingKey; } }
3293     System.Collections.IDictionary IQueueUnbind.Arguments { get { return m_arguments; } }
3294
3295     public QueueUnbind() {}
3296     public QueueUnbind(
3297       ushort initTicket,
3298       string initQueue,
3299       string initExchange,
3300       string initRoutingKey,
3301       System.Collections.IDictionary initArguments)
3302     {
3303       m_ticket = initTicket;
3304       m_queue = initQueue;
3305       m_exchange = initExchange;
3306       m_routingKey = initRoutingKey;
3307       m_arguments = initArguments;
3308     }
3309
3310     public override int ProtocolClassId { get { return 50; } }
3311     public override int ProtocolMethodId { get { return 50; } }
3312     public override string ProtocolMethodName { get { return "queue.unbind"; } }
3313     public override bool HasContent { get { return false; } }
3314
3315     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3316       m_ticket = reader.ReadShort();
3317       m_queue = reader.ReadShortstr();
3318       m_exchange = reader.ReadShortstr();
3319       m_routingKey = reader.ReadShortstr();
3320       m_arguments = reader.ReadTable();
3321     }
3322
3323     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3324       writer.WriteShort(m_ticket);
3325       writer.WriteShortstr(m_queue);
3326       writer.WriteShortstr(m_exchange);
3327       writer.WriteShortstr(m_routingKey);
3328       writer.WriteTable(m_arguments);
3329     }
3330
3331     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3332       sb.Append("(");
3333       sb.Append(m_ticket); sb.Append(",");
3334       sb.Append(m_queue); sb.Append(",");
3335       sb.Append(m_exchange); sb.Append(",");
3336       sb.Append(m_routingKey); sb.Append(",");
3337       sb.Append(m_arguments);
3338       sb.Append(")");
3339     }
3340   }
3341   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3342   public class QueueUnbindOk: RabbitMQ.Client.Impl.MethodBase, IQueueUnbindOk {
3343     public const int ClassId = 50;
3344     public const int MethodId = 51;
3345
3346
3347
3348     public QueueUnbindOk(
3349 )
3350     {
3351     }
3352
3353     public override int ProtocolClassId { get { return 50; } }
3354     public override int ProtocolMethodId { get { return 51; } }
3355     public override string ProtocolMethodName { get { return "queue.unbind-ok"; } }
3356     public override bool HasContent { get { return false; } }
3357
3358     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3359     }
3360
3361     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3362     }
3363
3364     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3365       sb.Append("(");
3366       sb.Append(")");
3367     }
3368   }
3369   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3370   public class QueuePurge: RabbitMQ.Client.Impl.MethodBase, IQueuePurge {
3371     public const int ClassId = 50;
3372     public const int MethodId = 30;
3373
3374     public ushort m_ticket;
3375     public string m_queue;
3376     public bool m_nowait;
3377
3378     ushort IQueuePurge.Ticket { get { return m_ticket; } }
3379     string IQueuePurge.Queue { get { return m_queue; } }
3380     bool IQueuePurge.Nowait { get { return m_nowait; } }
3381
3382     public QueuePurge() {}
3383     public QueuePurge(
3384       ushort initTicket,
3385       string initQueue,
3386       bool initNowait)
3387     {
3388       m_ticket = initTicket;
3389       m_queue = initQueue;
3390       m_nowait = initNowait;
3391     }
3392
3393     public override int ProtocolClassId { get { return 50; } }
3394     public override int ProtocolMethodId { get { return 30; } }
3395     public override string ProtocolMethodName { get { return "queue.purge"; } }
3396     public override bool HasContent { get { return false; } }
3397
3398     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3399       m_ticket = reader.ReadShort();
3400       m_queue = reader.ReadShortstr();
3401       m_nowait = reader.ReadBit();
3402     }
3403
3404     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3405       writer.WriteShort(m_ticket);
3406       writer.WriteShortstr(m_queue);
3407       writer.WriteBit(m_nowait);
3408     }
3409
3410     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3411       sb.Append("(");
3412       sb.Append(m_ticket); sb.Append(",");
3413       sb.Append(m_queue); sb.Append(",");
3414       sb.Append(m_nowait);
3415       sb.Append(")");
3416     }
3417   }
3418   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3419   public class QueuePurgeOk: RabbitMQ.Client.Impl.MethodBase, IQueuePurgeOk {
3420     public const int ClassId = 50;
3421     public const int MethodId = 31;
3422
3423     public uint m_messageCount;
3424
3425     uint IQueuePurgeOk.MessageCount { get { return m_messageCount; } }
3426
3427     public QueuePurgeOk() {}
3428     public QueuePurgeOk(
3429       uint initMessageCount)
3430     {
3431       m_messageCount = initMessageCount;
3432     }
3433
3434     public override int ProtocolClassId { get { return 50; } }
3435     public override int ProtocolMethodId { get { return 31; } }
3436     public override string ProtocolMethodName { get { return "queue.purge-ok"; } }
3437     public override bool HasContent { get { return false; } }
3438
3439     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3440       m_messageCount = reader.ReadLong();
3441     }
3442
3443     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3444       writer.WriteLong(m_messageCount);
3445     }
3446
3447     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3448       sb.Append("(");
3449       sb.Append(m_messageCount);
3450       sb.Append(")");
3451     }
3452   }
3453   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3454   public class QueueDelete: RabbitMQ.Client.Impl.MethodBase, IQueueDelete {
3455     public const int ClassId = 50;
3456     public const int MethodId = 40;
3457
3458     public ushort m_ticket;
3459     public string m_queue;
3460     public bool m_ifUnused;
3461     public bool m_ifEmpty;
3462     public bool m_nowait;
3463
3464     ushort IQueueDelete.Ticket { get { return m_ticket; } }
3465     string IQueueDelete.Queue { get { return m_queue; } }
3466     bool IQueueDelete.IfUnused { get { return m_ifUnused; } }
3467     bool IQueueDelete.IfEmpty { get { return m_ifEmpty; } }
3468     bool IQueueDelete.Nowait { get { return m_nowait; } }
3469
3470     public QueueDelete() {}
3471     public QueueDelete(
3472       ushort initTicket,
3473       string initQueue,
3474       bool initIfUnused,
3475       bool initIfEmpty,
3476       bool initNowait)
3477     {
3478       m_ticket = initTicket;
3479       m_queue = initQueue;
3480       m_ifUnused = initIfUnused;
3481       m_ifEmpty = initIfEmpty;
3482       m_nowait = initNowait;
3483     }
3484
3485     public override int ProtocolClassId { get { return 50; } }
3486     public override int ProtocolMethodId { get { return 40; } }
3487     public override string ProtocolMethodName { get { return "queue.delete"; } }
3488     public override bool HasContent { get { return false; } }
3489
3490     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3491       m_ticket = reader.ReadShort();
3492       m_queue = reader.ReadShortstr();
3493       m_ifUnused = reader.ReadBit();
3494       m_ifEmpty = reader.ReadBit();
3495       m_nowait = reader.ReadBit();
3496     }
3497
3498     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3499       writer.WriteShort(m_ticket);
3500       writer.WriteShortstr(m_queue);
3501       writer.WriteBit(m_ifUnused);
3502       writer.WriteBit(m_ifEmpty);
3503       writer.WriteBit(m_nowait);
3504     }
3505
3506     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3507       sb.Append("(");
3508       sb.Append(m_ticket); sb.Append(",");
3509       sb.Append(m_queue); sb.Append(",");
3510       sb.Append(m_ifUnused); sb.Append(",");
3511       sb.Append(m_ifEmpty); sb.Append(",");
3512       sb.Append(m_nowait);
3513       sb.Append(")");
3514     }
3515   }
3516   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3517   public class QueueDeleteOk: RabbitMQ.Client.Impl.MethodBase, IQueueDeleteOk {
3518     public const int ClassId = 50;
3519     public const int MethodId = 41;
3520
3521     public uint m_messageCount;
3522
3523     uint IQueueDeleteOk.MessageCount { get { return m_messageCount; } }
3524
3525     public QueueDeleteOk() {}
3526     public QueueDeleteOk(
3527       uint initMessageCount)
3528     {
3529       m_messageCount = initMessageCount;
3530     }
3531
3532     public override int ProtocolClassId { get { return 50; } }
3533     public override int ProtocolMethodId { get { return 41; } }
3534     public override string ProtocolMethodName { get { return "queue.delete-ok"; } }
3535     public override bool HasContent { get { return false; } }
3536
3537     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3538       m_messageCount = reader.ReadLong();
3539     }
3540
3541     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3542       writer.WriteLong(m_messageCount);
3543     }
3544
3545     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3546       sb.Append("(");
3547       sb.Append(m_messageCount);
3548       sb.Append(")");
3549     }
3550   }
3551   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3552   public class BasicQos: RabbitMQ.Client.Impl.MethodBase, IBasicQos {
3553     public const int ClassId = 60;
3554     public const int MethodId = 10;
3555
3556     public uint m_prefetchSize;
3557     public ushort m_prefetchCount;
3558     public bool m_global;
3559
3560     uint IBasicQos.PrefetchSize { get { return m_prefetchSize; } }
3561     ushort IBasicQos.PrefetchCount { get { return m_prefetchCount; } }
3562     bool IBasicQos.Global { get { return m_global; } }
3563
3564     public BasicQos() {}
3565     public BasicQos(
3566       uint initPrefetchSize,
3567       ushort initPrefetchCount,
3568       bool initGlobal)
3569     {
3570       m_prefetchSize = initPrefetchSize;
3571       m_prefetchCount = initPrefetchCount;
3572       m_global = initGlobal;
3573     }
3574
3575     public override int ProtocolClassId { get { return 60; } }
3576     public override int ProtocolMethodId { get { return 10; } }
3577     public override string ProtocolMethodName { get { return "basic.qos"; } }
3578     public override bool HasContent { get { return false; } }
3579
3580     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3581       m_prefetchSize = reader.ReadLong();
3582       m_prefetchCount = reader.ReadShort();
3583       m_global = reader.ReadBit();
3584     }
3585
3586     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3587       writer.WriteLong(m_prefetchSize);
3588       writer.WriteShort(m_prefetchCount);
3589       writer.WriteBit(m_global);
3590     }
3591
3592     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3593       sb.Append("(");
3594       sb.Append(m_prefetchSize); sb.Append(",");
3595       sb.Append(m_prefetchCount); sb.Append(",");
3596       sb.Append(m_global);
3597       sb.Append(")");
3598     }
3599   }
3600   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3601   public class BasicQosOk: RabbitMQ.Client.Impl.MethodBase, IBasicQosOk {
3602     public const int ClassId = 60;
3603     public const int MethodId = 11;
3604
3605
3606
3607     public BasicQosOk(
3608 )
3609     {
3610     }
3611
3612     public override int ProtocolClassId { get { return 60; } }
3613     public override int ProtocolMethodId { get { return 11; } }
3614     public override string ProtocolMethodName { get { return "basic.qos-ok"; } }
3615     public override bool HasContent { get { return false; } }
3616
3617     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3618     }
3619
3620     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3621     }
3622
3623     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3624       sb.Append("(");
3625       sb.Append(")");
3626     }
3627   }
3628   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3629   public class BasicConsume: RabbitMQ.Client.Impl.MethodBase, IBasicConsume {
3630     public const int ClassId = 60;
3631     public const int MethodId = 20;
3632
3633     public ushort m_ticket;
3634     public string m_queue;
3635     public string m_consumerTag;
3636     public bool m_noLocal;
3637     public bool m_noAck;
3638     public bool m_exclusive;
3639     public bool m_nowait;
3640     public System.Collections.IDictionary m_filter;
3641
3642     ushort IBasicConsume.Ticket { get { return m_ticket; } }
3643     string IBasicConsume.Queue { get { return m_queue; } }
3644     string IBasicConsume.ConsumerTag { get { return m_consumerTag; } }
3645     bool IBasicConsume.NoLocal { get { return m_noLocal; } }
3646     bool IBasicConsume.NoAck { get { return m_noAck; } }
3647     bool IBasicConsume.Exclusive { get { return m_exclusive; } }
3648     bool IBasicConsume.Nowait { get { return m_nowait; } }
3649     System.Collections.IDictionary IBasicConsume.Filter { get { return m_filter; } }
3650
3651     public BasicConsume() {}
3652     public BasicConsume(
3653       ushort initTicket,
3654       string initQueue,
3655       string initConsumerTag,
3656       bool initNoLocal,
3657       bool initNoAck,
3658       bool initExclusive,
3659       bool initNowait,
3660       System.Collections.IDictionary initFilter)
3661     {
3662       m_ticket = initTicket;
3663       m_queue = initQueue;
3664       m_consumerTag = initConsumerTag;
3665       m_noLocal = initNoLocal;
3666       m_noAck = initNoAck;
3667       m_exclusive = initExclusive;
3668       m_nowait = initNowait;
3669       m_filter = initFilter;
3670     }
3671
3672     public override int ProtocolClassId { get { return 60; } }
3673     public override int ProtocolMethodId { get { return 20; } }
3674     public override string ProtocolMethodName { get { return "basic.consume"; } }
3675     public override bool HasContent { get { return false; } }
3676
3677     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3678       m_ticket = reader.ReadShort();
3679       m_queue = reader.ReadShortstr();
3680       m_consumerTag = reader.ReadShortstr();
3681       m_noLocal = reader.ReadBit();
3682       m_noAck = reader.ReadBit();
3683       m_exclusive = reader.ReadBit();
3684       m_nowait = reader.ReadBit();
3685       m_filter = reader.ReadTable();
3686     }
3687
3688     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3689       writer.WriteShort(m_ticket);
3690       writer.WriteShortstr(m_queue);
3691       writer.WriteShortstr(m_consumerTag);
3692       writer.WriteBit(m_noLocal);
3693       writer.WriteBit(m_noAck);
3694       writer.WriteBit(m_exclusive);
3695       writer.WriteBit(m_nowait);
3696       writer.WriteTable(m_filter);
3697     }
3698
3699     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3700       sb.Append("(");
3701       sb.Append(m_ticket); sb.Append(",");
3702       sb.Append(m_queue); sb.Append(",");
3703       sb.Append(m_consumerTag); sb.Append(",");
3704       sb.Append(m_noLocal); sb.Append(",");
3705       sb.Append(m_noAck); sb.Append(",");
3706       sb.Append(m_exclusive); sb.Append(",");
3707       sb.Append(m_nowait); sb.Append(",");
3708       sb.Append(m_filter);
3709       sb.Append(")");
3710     }
3711   }
3712   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3713   public class BasicConsumeOk: RabbitMQ.Client.Impl.MethodBase, IBasicConsumeOk {
3714     public const int ClassId = 60;
3715     public const int MethodId = 21;
3716
3717     public string m_consumerTag;
3718
3719     string IBasicConsumeOk.ConsumerTag { get { return m_consumerTag; } }
3720
3721     public BasicConsumeOk() {}
3722     public BasicConsumeOk(
3723       string initConsumerTag)
3724     {
3725       m_consumerTag = initConsumerTag;
3726     }
3727
3728     public override int ProtocolClassId { get { return 60; } }
3729     public override int ProtocolMethodId { get { return 21; } }
3730     public override string ProtocolMethodName { get { return "basic.consume-ok"; } }
3731     public override bool HasContent { get { return false; } }
3732
3733     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3734       m_consumerTag = reader.ReadShortstr();
3735     }
3736
3737     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3738       writer.WriteShortstr(m_consumerTag);
3739     }
3740
3741     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3742       sb.Append("(");
3743       sb.Append(m_consumerTag);
3744       sb.Append(")");
3745     }
3746   }
3747   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3748   public class BasicCancel: RabbitMQ.Client.Impl.MethodBase, IBasicCancel {
3749     public const int ClassId = 60;
3750     public const int MethodId = 30;
3751
3752     public string m_consumerTag;
3753     public bool m_nowait;
3754
3755     string IBasicCancel.ConsumerTag { get { return m_consumerTag; } }
3756     bool IBasicCancel.Nowait { get { return m_nowait; } }
3757
3758     public BasicCancel() {}
3759     public BasicCancel(
3760       string initConsumerTag,
3761       bool initNowait)
3762     {
3763       m_consumerTag = initConsumerTag;
3764       m_nowait = initNowait;
3765     }
3766
3767     public override int ProtocolClassId { get { return 60; } }
3768     public override int ProtocolMethodId { get { return 30; } }
3769     public override string ProtocolMethodName { get { return "basic.cancel"; } }
3770     public override bool HasContent { get { return false; } }
3771
3772     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3773       m_consumerTag = reader.ReadShortstr();
3774       m_nowait = reader.ReadBit();
3775     }
3776
3777     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3778       writer.WriteShortstr(m_consumerTag);
3779       writer.WriteBit(m_nowait);
3780     }
3781
3782     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3783       sb.Append("(");
3784       sb.Append(m_consumerTag); sb.Append(",");
3785       sb.Append(m_nowait);
3786       sb.Append(")");
3787     }
3788   }
3789   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3790   public class BasicCancelOk: RabbitMQ.Client.Impl.MethodBase, IBasicCancelOk {
3791     public const int ClassId = 60;
3792     public const int MethodId = 31;
3793
3794     public string m_consumerTag;
3795
3796     string IBasicCancelOk.ConsumerTag { get { return m_consumerTag; } }
3797
3798     public BasicCancelOk() {}
3799     public BasicCancelOk(
3800       string initConsumerTag)
3801     {
3802       m_consumerTag = initConsumerTag;
3803     }
3804
3805     public override int ProtocolClassId { get { return 60; } }
3806     public override int ProtocolMethodId { get { return 31; } }
3807     public override string ProtocolMethodName { get { return "basic.cancel-ok"; } }
3808     public override bool HasContent { get { return false; } }
3809
3810     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3811       m_consumerTag = reader.ReadShortstr();
3812     }
3813
3814     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3815       writer.WriteShortstr(m_consumerTag);
3816     }
3817
3818     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3819       sb.Append("(");
3820       sb.Append(m_consumerTag);
3821       sb.Append(")");
3822     }
3823   }
3824   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3825   public class BasicPublish: RabbitMQ.Client.Impl.MethodBase, IBasicPublish {
3826     public const int ClassId = 60;
3827     public const int MethodId = 40;
3828
3829     public ushort m_ticket;
3830     public string m_exchange;
3831     public string m_routingKey;
3832     public bool m_mandatory;
3833     public bool m_immediate;
3834
3835     ushort IBasicPublish.Ticket { get { return m_ticket; } }
3836     string IBasicPublish.Exchange { get { return m_exchange; } }
3837     string IBasicPublish.RoutingKey { get { return m_routingKey; } }
3838     bool IBasicPublish.Mandatory { get { return m_mandatory; } }
3839     bool IBasicPublish.Immediate { get { return m_immediate; } }
3840
3841     public BasicPublish() {}
3842     public BasicPublish(
3843       ushort initTicket,
3844       string initExchange,
3845       string initRoutingKey,
3846       bool initMandatory,
3847       bool initImmediate)
3848     {
3849       m_ticket = initTicket;
3850       m_exchange = initExchange;
3851       m_routingKey = initRoutingKey;
3852       m_mandatory = initMandatory;
3853       m_immediate = initImmediate;
3854     }
3855
3856     public override int ProtocolClassId { get { return 60; } }
3857     public override int ProtocolMethodId { get { return 40; } }
3858     public override string ProtocolMethodName { get { return "basic.publish"; } }
3859     public override bool HasContent { get { return true; } }
3860
3861     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3862       m_ticket = reader.ReadShort();
3863       m_exchange = reader.ReadShortstr();
3864       m_routingKey = reader.ReadShortstr();
3865       m_mandatory = reader.ReadBit();
3866       m_immediate = reader.ReadBit();
3867     }
3868
3869     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3870       writer.WriteShort(m_ticket);
3871       writer.WriteShortstr(m_exchange);
3872       writer.WriteShortstr(m_routingKey);
3873       writer.WriteBit(m_mandatory);
3874       writer.WriteBit(m_immediate);
3875     }
3876
3877     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3878       sb.Append("(");
3879       sb.Append(m_ticket); sb.Append(",");
3880       sb.Append(m_exchange); sb.Append(",");
3881       sb.Append(m_routingKey); sb.Append(",");
3882       sb.Append(m_mandatory); sb.Append(",");
3883       sb.Append(m_immediate);
3884       sb.Append(")");
3885     }
3886   }
3887   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3888   public class BasicReturn: RabbitMQ.Client.Impl.MethodBase, IBasicReturn {
3889     public const int ClassId = 60;
3890     public const int MethodId = 50;
3891
3892     public ushort m_replyCode;
3893     public string m_replyText;
3894     public string m_exchange;
3895     public string m_routingKey;
3896
3897     ushort IBasicReturn.ReplyCode { get { return m_replyCode; } }
3898     string IBasicReturn.ReplyText { get { return m_replyText; } }
3899     string IBasicReturn.Exchange { get { return m_exchange; } }
3900     string IBasicReturn.RoutingKey { get { return m_routingKey; } }
3901
3902     public BasicReturn() {}
3903     public BasicReturn(
3904       ushort initReplyCode,
3905       string initReplyText,
3906       string initExchange,
3907       string initRoutingKey)
3908     {
3909       m_replyCode = initReplyCode;
3910       m_replyText = initReplyText;
3911       m_exchange = initExchange;
3912       m_routingKey = initRoutingKey;
3913     }
3914
3915     public override int ProtocolClassId { get { return 60; } }
3916     public override int ProtocolMethodId { get { return 50; } }
3917     public override string ProtocolMethodName { get { return "basic.return"; } }
3918     public override bool HasContent { get { return true; } }
3919
3920     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3921       m_replyCode = reader.ReadShort();
3922       m_replyText = reader.ReadShortstr();
3923       m_exchange = reader.ReadShortstr();
3924       m_routingKey = reader.ReadShortstr();
3925     }
3926
3927     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3928       writer.WriteShort(m_replyCode);
3929       writer.WriteShortstr(m_replyText);
3930       writer.WriteShortstr(m_exchange);
3931       writer.WriteShortstr(m_routingKey);
3932     }
3933
3934     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3935       sb.Append("(");
3936       sb.Append(m_replyCode); sb.Append(",");
3937       sb.Append(m_replyText); sb.Append(",");
3938       sb.Append(m_exchange); sb.Append(",");
3939       sb.Append(m_routingKey);
3940       sb.Append(")");
3941     }
3942   }
3943   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
3944   public class BasicDeliver: RabbitMQ.Client.Impl.MethodBase, IBasicDeliver {
3945     public const int ClassId = 60;
3946     public const int MethodId = 60;
3947
3948     public string m_consumerTag;
3949     public ulong m_deliveryTag;
3950     public bool m_redelivered;
3951     public string m_exchange;
3952     public string m_routingKey;
3953
3954     string IBasicDeliver.ConsumerTag { get { return m_consumerTag; } }
3955     ulong IBasicDeliver.DeliveryTag { get { return m_deliveryTag; } }
3956     bool IBasicDeliver.Redelivered { get { return m_redelivered; } }
3957     string IBasicDeliver.Exchange { get { return m_exchange; } }
3958     string IBasicDeliver.RoutingKey { get { return m_routingKey; } }
3959
3960     public BasicDeliver() {}
3961     public BasicDeliver(
3962       string initConsumerTag,
3963       ulong initDeliveryTag,
3964       bool initRedelivered,
3965       string initExchange,
3966       string initRoutingKey)
3967     {
3968       m_consumerTag = initConsumerTag;
3969       m_deliveryTag = initDeliveryTag;
3970       m_redelivered = initRedelivered;
3971       m_exchange = initExchange;
3972       m_routingKey = initRoutingKey;
3973     }
3974
3975     public override int ProtocolClassId { get { return 60; } }
3976     public override int ProtocolMethodId { get { return 60; } }
3977     public override string ProtocolMethodName { get { return "basic.deliver"; } }
3978     public override bool HasContent { get { return true; } }
3979
3980     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
3981       m_consumerTag = reader.ReadShortstr();
3982       m_deliveryTag = reader.ReadLonglong();
3983       m_redelivered = reader.ReadBit();
3984       m_exchange = reader.ReadShortstr();
3985       m_routingKey = reader.ReadShortstr();
3986     }
3987
3988     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
3989       writer.WriteShortstr(m_consumerTag);
3990       writer.WriteLonglong(m_deliveryTag);
3991       writer.WriteBit(m_redelivered);
3992       writer.WriteShortstr(m_exchange);
3993       writer.WriteShortstr(m_routingKey);
3994     }
3995
3996     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
3997       sb.Append("(");
3998       sb.Append(m_consumerTag); sb.Append(",");
3999       sb.Append(m_deliveryTag); sb.Append(",");
4000       sb.Append(m_redelivered); sb.Append(",");
4001       sb.Append(m_exchange); sb.Append(",");
4002       sb.Append(m_routingKey);
4003       sb.Append(")");
4004     }
4005   }
4006   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4007   public class BasicGet: RabbitMQ.Client.Impl.MethodBase, IBasicGet {
4008     public const int ClassId = 60;
4009     public const int MethodId = 70;
4010
4011     public ushort m_ticket;
4012     public string m_queue;
4013     public bool m_noAck;
4014
4015     ushort IBasicGet.Ticket { get { return m_ticket; } }
4016     string IBasicGet.Queue { get { return m_queue; } }
4017     bool IBasicGet.NoAck { get { return m_noAck; } }
4018
4019     public BasicGet() {}
4020     public BasicGet(
4021       ushort initTicket,
4022       string initQueue,
4023       bool initNoAck)
4024     {
4025       m_ticket = initTicket;
4026       m_queue = initQueue;
4027       m_noAck = initNoAck;
4028     }
4029
4030     public override int ProtocolClassId { get { return 60; } }
4031     public override int ProtocolMethodId { get { return 70; } }
4032     public override string ProtocolMethodName { get { return "basic.get"; } }
4033     public override bool HasContent { get { return false; } }
4034
4035     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4036       m_ticket = reader.ReadShort();
4037       m_queue = reader.ReadShortstr();
4038       m_noAck = reader.ReadBit();
4039     }
4040
4041     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4042       writer.WriteShort(m_ticket);
4043       writer.WriteShortstr(m_queue);
4044       writer.WriteBit(m_noAck);
4045     }
4046
4047     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4048       sb.Append("(");
4049       sb.Append(m_ticket); sb.Append(",");
4050       sb.Append(m_queue); sb.Append(",");
4051       sb.Append(m_noAck);
4052       sb.Append(")");
4053     }
4054   }
4055   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4056   public class BasicGetOk: RabbitMQ.Client.Impl.MethodBase, IBasicGetOk {
4057     public const int ClassId = 60;
4058     public const int MethodId = 71;
4059
4060     public ulong m_deliveryTag;
4061     public bool m_redelivered;
4062     public string m_exchange;
4063     public string m_routingKey;
4064     public uint m_messageCount;
4065
4066     ulong IBasicGetOk.DeliveryTag { get { return m_deliveryTag; } }
4067     bool IBasicGetOk.Redelivered { get { return m_redelivered; } }
4068     string IBasicGetOk.Exchange { get { return m_exchange; } }
4069     string IBasicGetOk.RoutingKey { get { return m_routingKey; } }
4070     uint IBasicGetOk.MessageCount { get { return m_messageCount; } }
4071
4072     public BasicGetOk() {}
4073     public BasicGetOk(
4074       ulong initDeliveryTag,
4075       bool initRedelivered,
4076       string initExchange,
4077       string initRoutingKey,
4078       uint initMessageCount)
4079     {
4080       m_deliveryTag = initDeliveryTag;
4081       m_redelivered = initRedelivered;
4082       m_exchange = initExchange;
4083       m_routingKey = initRoutingKey;
4084       m_messageCount = initMessageCount;
4085     }
4086
4087     public override int ProtocolClassId { get { return 60; } }
4088     public override int ProtocolMethodId { get { return 71; } }
4089     public override string ProtocolMethodName { get { return "basic.get-ok"; } }
4090     public override bool HasContent { get { return true; } }
4091
4092     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4093       m_deliveryTag = reader.ReadLonglong();
4094       m_redelivered = reader.ReadBit();
4095       m_exchange = reader.ReadShortstr();
4096       m_routingKey = reader.ReadShortstr();
4097       m_messageCount = reader.ReadLong();
4098     }
4099
4100     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4101       writer.WriteLonglong(m_deliveryTag);
4102       writer.WriteBit(m_redelivered);
4103       writer.WriteShortstr(m_exchange);
4104       writer.WriteShortstr(m_routingKey);
4105       writer.WriteLong(m_messageCount);
4106     }
4107
4108     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4109       sb.Append("(");
4110       sb.Append(m_deliveryTag); sb.Append(",");
4111       sb.Append(m_redelivered); sb.Append(",");
4112       sb.Append(m_exchange); sb.Append(",");
4113       sb.Append(m_routingKey); sb.Append(",");
4114       sb.Append(m_messageCount);
4115       sb.Append(")");
4116     }
4117   }
4118   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4119   public class BasicGetEmpty: RabbitMQ.Client.Impl.MethodBase, IBasicGetEmpty {
4120     public const int ClassId = 60;
4121     public const int MethodId = 72;
4122
4123     public string m_clusterId;
4124
4125     string IBasicGetEmpty.ClusterId { get { return m_clusterId; } }
4126
4127     public BasicGetEmpty() {}
4128     public BasicGetEmpty(
4129       string initClusterId)
4130     {
4131       m_clusterId = initClusterId;
4132     }
4133
4134     public override int ProtocolClassId { get { return 60; } }
4135     public override int ProtocolMethodId { get { return 72; } }
4136     public override string ProtocolMethodName { get { return "basic.get-empty"; } }
4137     public override bool HasContent { get { return false; } }
4138
4139     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4140       m_clusterId = reader.ReadShortstr();
4141     }
4142
4143     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4144       writer.WriteShortstr(m_clusterId);
4145     }
4146
4147     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4148       sb.Append("(");
4149       sb.Append(m_clusterId);
4150       sb.Append(")");
4151     }
4152   }
4153   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4154   public class BasicAck: RabbitMQ.Client.Impl.MethodBase, IBasicAck {
4155     public const int ClassId = 60;
4156     public const int MethodId = 80;
4157
4158     public ulong m_deliveryTag;
4159     public bool m_multiple;
4160
4161     ulong IBasicAck.DeliveryTag { get { return m_deliveryTag; } }
4162     bool IBasicAck.Multiple { get { return m_multiple; } }
4163
4164     public BasicAck() {}
4165     public BasicAck(
4166       ulong initDeliveryTag,
4167       bool initMultiple)
4168     {
4169       m_deliveryTag = initDeliveryTag;
4170       m_multiple = initMultiple;
4171     }
4172
4173     public override int ProtocolClassId { get { return 60; } }
4174     public override int ProtocolMethodId { get { return 80; } }
4175     public override string ProtocolMethodName { get { return "basic.ack"; } }
4176     public override bool HasContent { get { return false; } }
4177
4178     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4179       m_deliveryTag = reader.ReadLonglong();
4180       m_multiple = reader.ReadBit();
4181     }
4182
4183     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4184       writer.WriteLonglong(m_deliveryTag);
4185       writer.WriteBit(m_multiple);
4186     }
4187
4188     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4189       sb.Append("(");
4190       sb.Append(m_deliveryTag); sb.Append(",");
4191       sb.Append(m_multiple);
4192       sb.Append(")");
4193     }
4194   }
4195   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4196   public class BasicReject: RabbitMQ.Client.Impl.MethodBase, IBasicReject {
4197     public const int ClassId = 60;
4198     public const int MethodId = 90;
4199
4200     public ulong m_deliveryTag;
4201     public bool m_requeue;
4202
4203     ulong IBasicReject.DeliveryTag { get { return m_deliveryTag; } }
4204     bool IBasicReject.Requeue { get { return m_requeue; } }
4205
4206     public BasicReject() {}
4207     public BasicReject(
4208       ulong initDeliveryTag,
4209       bool initRequeue)
4210     {
4211       m_deliveryTag = initDeliveryTag;
4212       m_requeue = initRequeue;
4213     }
4214
4215     public override int ProtocolClassId { get { return 60; } }
4216     public override int ProtocolMethodId { get { return 90; } }
4217     public override string ProtocolMethodName { get { return "basic.reject"; } }
4218     public override bool HasContent { get { return false; } }
4219
4220     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4221       m_deliveryTag = reader.ReadLonglong();
4222       m_requeue = reader.ReadBit();
4223     }
4224
4225     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4226       writer.WriteLonglong(m_deliveryTag);
4227       writer.WriteBit(m_requeue);
4228     }
4229
4230     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4231       sb.Append("(");
4232       sb.Append(m_deliveryTag); sb.Append(",");
4233       sb.Append(m_requeue);
4234       sb.Append(")");
4235     }
4236   }
4237   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4238   public class BasicRecover: RabbitMQ.Client.Impl.MethodBase, IBasicRecover {
4239     public const int ClassId = 60;
4240     public const int MethodId = 100;
4241
4242     public bool m_requeue;
4243
4244     bool IBasicRecover.Requeue { get { return m_requeue; } }
4245
4246     public BasicRecover() {}
4247     public BasicRecover(
4248       bool initRequeue)
4249     {
4250       m_requeue = initRequeue;
4251     }
4252
4253     public override int ProtocolClassId { get { return 60; } }
4254     public override int ProtocolMethodId { get { return 100; } }
4255     public override string ProtocolMethodName { get { return "basic.recover"; } }
4256     public override bool HasContent { get { return false; } }
4257
4258     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4259       m_requeue = reader.ReadBit();
4260     }
4261
4262     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4263       writer.WriteBit(m_requeue);
4264     }
4265
4266     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4267       sb.Append("(");
4268       sb.Append(m_requeue);
4269       sb.Append(")");
4270     }
4271   }
4272   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4273   public class FileQos: RabbitMQ.Client.Impl.MethodBase, IFileQos {
4274     public const int ClassId = 70;
4275     public const int MethodId = 10;
4276
4277     public uint m_prefetchSize;
4278     public ushort m_prefetchCount;
4279     public bool m_global;
4280
4281     uint IFileQos.PrefetchSize { get { return m_prefetchSize; } }
4282     ushort IFileQos.PrefetchCount { get { return m_prefetchCount; } }
4283     bool IFileQos.Global { get { return m_global; } }
4284
4285     public FileQos() {}
4286     public FileQos(
4287       uint initPrefetchSize,
4288       ushort initPrefetchCount,
4289       bool initGlobal)
4290     {
4291       m_prefetchSize = initPrefetchSize;
4292       m_prefetchCount = initPrefetchCount;
4293       m_global = initGlobal;
4294     }
4295
4296     public override int ProtocolClassId { get { return 70; } }
4297     public override int ProtocolMethodId { get { return 10; } }
4298     public override string ProtocolMethodName { get { return "file.qos"; } }
4299     public override bool HasContent { get { return false; } }
4300
4301     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4302       m_prefetchSize = reader.ReadLong();
4303       m_prefetchCount = reader.ReadShort();
4304       m_global = reader.ReadBit();
4305     }
4306
4307     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4308       writer.WriteLong(m_prefetchSize);
4309       writer.WriteShort(m_prefetchCount);
4310       writer.WriteBit(m_global);
4311     }
4312
4313     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4314       sb.Append("(");
4315       sb.Append(m_prefetchSize); sb.Append(",");
4316       sb.Append(m_prefetchCount); sb.Append(",");
4317       sb.Append(m_global);
4318       sb.Append(")");
4319     }
4320   }
4321   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4322   public class FileQosOk: RabbitMQ.Client.Impl.MethodBase, IFileQosOk {
4323     public const int ClassId = 70;
4324     public const int MethodId = 11;
4325
4326
4327
4328     public FileQosOk(
4329 )
4330     {
4331     }
4332
4333     public override int ProtocolClassId { get { return 70; } }
4334     public override int ProtocolMethodId { get { return 11; } }
4335     public override string ProtocolMethodName { get { return "file.qos-ok"; } }
4336     public override bool HasContent { get { return false; } }
4337
4338     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4339     }
4340
4341     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4342     }
4343
4344     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4345       sb.Append("(");
4346       sb.Append(")");
4347     }
4348   }
4349   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4350   public class FileConsume: RabbitMQ.Client.Impl.MethodBase, IFileConsume {
4351     public const int ClassId = 70;
4352     public const int MethodId = 20;
4353
4354     public ushort m_ticket;
4355     public string m_queue;
4356     public string m_consumerTag;
4357     public bool m_noLocal;
4358     public bool m_noAck;
4359     public bool m_exclusive;
4360     public bool m_nowait;
4361     public System.Collections.IDictionary m_filter;
4362
4363     ushort IFileConsume.Ticket { get { return m_ticket; } }
4364     string IFileConsume.Queue { get { return m_queue; } }
4365     string IFileConsume.ConsumerTag { get { return m_consumerTag; } }
4366     bool IFileConsume.NoLocal { get { return m_noLocal; } }
4367     bool IFileConsume.NoAck { get { return m_noAck; } }
4368     bool IFileConsume.Exclusive { get { return m_exclusive; } }
4369     bool IFileConsume.Nowait { get { return m_nowait; } }
4370     System.Collections.IDictionary IFileConsume.Filter { get { return m_filter; } }
4371
4372     public FileConsume() {}
4373     public FileConsume(
4374       ushort initTicket,
4375       string initQueue,
4376       string initConsumerTag,
4377       bool initNoLocal,
4378       bool initNoAck,
4379       bool initExclusive,
4380       bool initNowait,
4381       System.Collections.IDictionary initFilter)
4382     {
4383       m_ticket = initTicket;
4384       m_queue = initQueue;
4385       m_consumerTag = initConsumerTag;
4386       m_noLocal = initNoLocal;
4387       m_noAck = initNoAck;
4388       m_exclusive = initExclusive;
4389       m_nowait = initNowait;
4390       m_filter = initFilter;
4391     }
4392
4393     public override int ProtocolClassId { get { return 70; } }
4394     public override int ProtocolMethodId { get { return 20; } }
4395     public override string ProtocolMethodName { get { return "file.consume"; } }
4396     public override bool HasContent { get { return false; } }
4397
4398     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4399       m_ticket = reader.ReadShort();
4400       m_queue = reader.ReadShortstr();
4401       m_consumerTag = reader.ReadShortstr();
4402       m_noLocal = reader.ReadBit();
4403       m_noAck = reader.ReadBit();
4404       m_exclusive = reader.ReadBit();
4405       m_nowait = reader.ReadBit();
4406       m_filter = reader.ReadTable();
4407     }
4408
4409     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4410       writer.WriteShort(m_ticket);
4411       writer.WriteShortstr(m_queue);
4412       writer.WriteShortstr(m_consumerTag);
4413       writer.WriteBit(m_noLocal);
4414       writer.WriteBit(m_noAck);
4415       writer.WriteBit(m_exclusive);
4416       writer.WriteBit(m_nowait);
4417       writer.WriteTable(m_filter);
4418     }
4419
4420     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4421       sb.Append("(");
4422       sb.Append(m_ticket); sb.Append(",");
4423       sb.Append(m_queue); sb.Append(",");
4424       sb.Append(m_consumerTag); sb.Append(",");
4425       sb.Append(m_noLocal); sb.Append(",");
4426       sb.Append(m_noAck); sb.Append(",");
4427       sb.Append(m_exclusive); sb.Append(",");
4428       sb.Append(m_nowait); sb.Append(",");
4429       sb.Append(m_filter);
4430       sb.Append(")");
4431     }
4432   }
4433   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4434   public class FileConsumeOk: RabbitMQ.Client.Impl.MethodBase, IFileConsumeOk {
4435     public const int ClassId = 70;
4436     public const int MethodId = 21;
4437
4438     public string m_consumerTag;
4439
4440     string IFileConsumeOk.ConsumerTag { get { return m_consumerTag; } }
4441
4442     public FileConsumeOk() {}
4443     public FileConsumeOk(
4444       string initConsumerTag)
4445     {
4446       m_consumerTag = initConsumerTag;
4447     }
4448
4449     public override int ProtocolClassId { get { return 70; } }
4450     public override int ProtocolMethodId { get { return 21; } }
4451     public override string ProtocolMethodName { get { return "file.consume-ok"; } }
4452     public override bool HasContent { get { return false; } }
4453
4454     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4455       m_consumerTag = reader.ReadShortstr();
4456     }
4457
4458     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4459       writer.WriteShortstr(m_consumerTag);
4460     }
4461
4462     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4463       sb.Append("(");
4464       sb.Append(m_consumerTag);
4465       sb.Append(")");
4466     }
4467   }
4468   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4469   public class FileCancel: RabbitMQ.Client.Impl.MethodBase, IFileCancel {
4470     public const int ClassId = 70;
4471     public const int MethodId = 30;
4472
4473     public string m_consumerTag;
4474     public bool m_nowait;
4475
4476     string IFileCancel.ConsumerTag { get { return m_consumerTag; } }
4477     bool IFileCancel.Nowait { get { return m_nowait; } }
4478
4479     public FileCancel() {}
4480     public FileCancel(
4481       string initConsumerTag,
4482       bool initNowait)
4483     {
4484       m_consumerTag = initConsumerTag;
4485       m_nowait = initNowait;
4486     }
4487
4488     public override int ProtocolClassId { get { return 70; } }
4489     public override int ProtocolMethodId { get { return 30; } }
4490     public override string ProtocolMethodName { get { return "file.cancel"; } }
4491     public override bool HasContent { get { return false; } }
4492
4493     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4494       m_consumerTag = reader.ReadShortstr();
4495       m_nowait = reader.ReadBit();
4496     }
4497
4498     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4499       writer.WriteShortstr(m_consumerTag);
4500       writer.WriteBit(m_nowait);
4501     }
4502
4503     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4504       sb.Append("(");
4505       sb.Append(m_consumerTag); sb.Append(",");
4506       sb.Append(m_nowait);
4507       sb.Append(")");
4508     }
4509   }
4510   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4511   public class FileCancelOk: RabbitMQ.Client.Impl.MethodBase, IFileCancelOk {
4512     public const int ClassId = 70;
4513     public const int MethodId = 31;
4514
4515     public string m_consumerTag;
4516
4517     string IFileCancelOk.ConsumerTag { get { return m_consumerTag; } }
4518
4519     public FileCancelOk() {}
4520     public FileCancelOk(
4521       string initConsumerTag)
4522     {
4523       m_consumerTag = initConsumerTag;
4524     }
4525
4526     public override int ProtocolClassId { get { return 70; } }
4527     public override int ProtocolMethodId { get { return 31; } }
4528     public override string ProtocolMethodName { get { return "file.cancel-ok"; } }
4529     public override bool HasContent { get { return false; } }
4530
4531     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4532       m_consumerTag = reader.ReadShortstr();
4533     }
4534
4535     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4536       writer.WriteShortstr(m_consumerTag);
4537     }
4538
4539     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4540       sb.Append("(");
4541       sb.Append(m_consumerTag);
4542       sb.Append(")");
4543     }
4544   }
4545   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4546   public class FileOpen: RabbitMQ.Client.Impl.MethodBase, IFileOpen {
4547     public const int ClassId = 70;
4548     public const int MethodId = 40;
4549
4550     public string m_identifier;
4551     public ulong m_contentSize;
4552
4553     string IFileOpen.Identifier { get { return m_identifier; } }
4554     ulong IFileOpen.ContentSize { get { return m_contentSize; } }
4555
4556     public FileOpen() {}
4557     public FileOpen(
4558       string initIdentifier,
4559       ulong initContentSize)
4560     {
4561       m_identifier = initIdentifier;
4562       m_contentSize = initContentSize;
4563     }
4564
4565     public override int ProtocolClassId { get { return 70; } }
4566     public override int ProtocolMethodId { get { return 40; } }
4567     public override string ProtocolMethodName { get { return "file.open"; } }
4568     public override bool HasContent { get { return false; } }
4569
4570     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4571       m_identifier = reader.ReadShortstr();
4572       m_contentSize = reader.ReadLonglong();
4573     }
4574
4575     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4576       writer.WriteShortstr(m_identifier);
4577       writer.WriteLonglong(m_contentSize);
4578     }
4579
4580     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4581       sb.Append("(");
4582       sb.Append(m_identifier); sb.Append(",");
4583       sb.Append(m_contentSize);
4584       sb.Append(")");
4585     }
4586   }
4587   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4588   public class FileOpenOk: RabbitMQ.Client.Impl.MethodBase, IFileOpenOk {
4589     public const int ClassId = 70;
4590     public const int MethodId = 41;
4591
4592     public ulong m_stagedSize;
4593
4594     ulong IFileOpenOk.StagedSize { get { return m_stagedSize; } }
4595
4596     public FileOpenOk() {}
4597     public FileOpenOk(
4598       ulong initStagedSize)
4599     {
4600       m_stagedSize = initStagedSize;
4601     }
4602
4603     public override int ProtocolClassId { get { return 70; } }
4604     public override int ProtocolMethodId { get { return 41; } }
4605     public override string ProtocolMethodName { get { return "file.open-ok"; } }
4606     public override bool HasContent { get { return false; } }
4607
4608     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4609       m_stagedSize = reader.ReadLonglong();
4610     }
4611
4612     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4613       writer.WriteLonglong(m_stagedSize);
4614     }
4615
4616     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4617       sb.Append("(");
4618       sb.Append(m_stagedSize);
4619       sb.Append(")");
4620     }
4621   }
4622   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4623   public class FileStage: RabbitMQ.Client.Impl.MethodBase, IFileStage {
4624     public const int ClassId = 70;
4625     public const int MethodId = 50;
4626
4627
4628
4629     public FileStage(
4630 )
4631     {
4632     }
4633
4634     public override int ProtocolClassId { get { return 70; } }
4635     public override int ProtocolMethodId { get { return 50; } }
4636     public override string ProtocolMethodName { get { return "file.stage"; } }
4637     public override bool HasContent { get { return true; } }
4638
4639     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4640     }
4641
4642     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4643     }
4644
4645     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4646       sb.Append("(");
4647       sb.Append(")");
4648     }
4649   }
4650   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4651   public class FilePublish: RabbitMQ.Client.Impl.MethodBase, IFilePublish {
4652     public const int ClassId = 70;
4653     public const int MethodId = 60;
4654
4655     public ushort m_ticket;
4656     public string m_exchange;
4657     public string m_routingKey;
4658     public bool m_mandatory;
4659     public bool m_immediate;
4660     public string m_identifier;
4661
4662     ushort IFilePublish.Ticket { get { return m_ticket; } }
4663     string IFilePublish.Exchange { get { return m_exchange; } }
4664     string IFilePublish.RoutingKey { get { return m_routingKey; } }
4665     bool IFilePublish.Mandatory { get { return m_mandatory; } }
4666     bool IFilePublish.Immediate { get { return m_immediate; } }
4667     string IFilePublish.Identifier { get { return m_identifier; } }
4668
4669     public FilePublish() {}
4670     public FilePublish(
4671       ushort initTicket,
4672       string initExchange,
4673       string initRoutingKey,
4674       bool initMandatory,
4675       bool initImmediate,
4676       string initIdentifier)
4677     {
4678       m_ticket = initTicket;
4679       m_exchange = initExchange;
4680       m_routingKey = initRoutingKey;
4681       m_mandatory = initMandatory;
4682       m_immediate = initImmediate;
4683       m_identifier = initIdentifier;
4684     }
4685
4686     public override int ProtocolClassId { get { return 70; } }
4687     public override int ProtocolMethodId { get { return 60; } }
4688     public override string ProtocolMethodName { get { return "file.publish"; } }
4689     public override bool HasContent { get { return false; } }
4690
4691     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4692       m_ticket = reader.ReadShort();
4693       m_exchange = reader.ReadShortstr();
4694       m_routingKey = reader.ReadShortstr();
4695       m_mandatory = reader.ReadBit();
4696       m_immediate = reader.ReadBit();
4697       m_identifier = reader.ReadShortstr();
4698     }
4699
4700     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4701       writer.WriteShort(m_ticket);
4702       writer.WriteShortstr(m_exchange);
4703       writer.WriteShortstr(m_routingKey);
4704       writer.WriteBit(m_mandatory);
4705       writer.WriteBit(m_immediate);
4706       writer.WriteShortstr(m_identifier);
4707     }
4708
4709     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4710       sb.Append("(");
4711       sb.Append(m_ticket); sb.Append(",");
4712       sb.Append(m_exchange); sb.Append(",");
4713       sb.Append(m_routingKey); sb.Append(",");
4714       sb.Append(m_mandatory); sb.Append(",");
4715       sb.Append(m_immediate); sb.Append(",");
4716       sb.Append(m_identifier);
4717       sb.Append(")");
4718     }
4719   }
4720   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4721   public class FileReturn: RabbitMQ.Client.Impl.MethodBase, IFileReturn {
4722     public const int ClassId = 70;
4723     public const int MethodId = 70;
4724
4725     public ushort m_replyCode;
4726     public string m_replyText;
4727     public string m_exchange;
4728     public string m_routingKey;
4729
4730     ushort IFileReturn.ReplyCode { get { return m_replyCode; } }
4731     string IFileReturn.ReplyText { get { return m_replyText; } }
4732     string IFileReturn.Exchange { get { return m_exchange; } }
4733     string IFileReturn.RoutingKey { get { return m_routingKey; } }
4734
4735     public FileReturn() {}
4736     public FileReturn(
4737       ushort initReplyCode,
4738       string initReplyText,
4739       string initExchange,
4740       string initRoutingKey)
4741     {
4742       m_replyCode = initReplyCode;
4743       m_replyText = initReplyText;
4744       m_exchange = initExchange;
4745       m_routingKey = initRoutingKey;
4746     }
4747
4748     public override int ProtocolClassId { get { return 70; } }
4749     public override int ProtocolMethodId { get { return 70; } }
4750     public override string ProtocolMethodName { get { return "file.return"; } }
4751     public override bool HasContent { get { return true; } }
4752
4753     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4754       m_replyCode = reader.ReadShort();
4755       m_replyText = reader.ReadShortstr();
4756       m_exchange = reader.ReadShortstr();
4757       m_routingKey = reader.ReadShortstr();
4758     }
4759
4760     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4761       writer.WriteShort(m_replyCode);
4762       writer.WriteShortstr(m_replyText);
4763       writer.WriteShortstr(m_exchange);
4764       writer.WriteShortstr(m_routingKey);
4765     }
4766
4767     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4768       sb.Append("(");
4769       sb.Append(m_replyCode); sb.Append(",");
4770       sb.Append(m_replyText); sb.Append(",");
4771       sb.Append(m_exchange); sb.Append(",");
4772       sb.Append(m_routingKey);
4773       sb.Append(")");
4774     }
4775   }
4776   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4777   public class FileDeliver: RabbitMQ.Client.Impl.MethodBase, IFileDeliver {
4778     public const int ClassId = 70;
4779     public const int MethodId = 80;
4780
4781     public string m_consumerTag;
4782     public ulong m_deliveryTag;
4783     public bool m_redelivered;
4784     public string m_exchange;
4785     public string m_routingKey;
4786     public string m_identifier;
4787
4788     string IFileDeliver.ConsumerTag { get { return m_consumerTag; } }
4789     ulong IFileDeliver.DeliveryTag { get { return m_deliveryTag; } }
4790     bool IFileDeliver.Redelivered { get { return m_redelivered; } }
4791     string IFileDeliver.Exchange { get { return m_exchange; } }
4792     string IFileDeliver.RoutingKey { get { return m_routingKey; } }
4793     string IFileDeliver.Identifier { get { return m_identifier; } }
4794
4795     public FileDeliver() {}
4796     public FileDeliver(
4797       string initConsumerTag,
4798       ulong initDeliveryTag,
4799       bool initRedelivered,
4800       string initExchange,
4801       string initRoutingKey,
4802       string initIdentifier)
4803     {
4804       m_consumerTag = initConsumerTag;
4805       m_deliveryTag = initDeliveryTag;
4806       m_redelivered = initRedelivered;
4807       m_exchange = initExchange;
4808       m_routingKey = initRoutingKey;
4809       m_identifier = initIdentifier;
4810     }
4811
4812     public override int ProtocolClassId { get { return 70; } }
4813     public override int ProtocolMethodId { get { return 80; } }
4814     public override string ProtocolMethodName { get { return "file.deliver"; } }
4815     public override bool HasContent { get { return false; } }
4816
4817     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4818       m_consumerTag = reader.ReadShortstr();
4819       m_deliveryTag = reader.ReadLonglong();
4820       m_redelivered = reader.ReadBit();
4821       m_exchange = reader.ReadShortstr();
4822       m_routingKey = reader.ReadShortstr();
4823       m_identifier = reader.ReadShortstr();
4824     }
4825
4826     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4827       writer.WriteShortstr(m_consumerTag);
4828       writer.WriteLonglong(m_deliveryTag);
4829       writer.WriteBit(m_redelivered);
4830       writer.WriteShortstr(m_exchange);
4831       writer.WriteShortstr(m_routingKey);
4832       writer.WriteShortstr(m_identifier);
4833     }
4834
4835     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4836       sb.Append("(");
4837       sb.Append(m_consumerTag); sb.Append(",");
4838       sb.Append(m_deliveryTag); sb.Append(",");
4839       sb.Append(m_redelivered); sb.Append(",");
4840       sb.Append(m_exchange); sb.Append(",");
4841       sb.Append(m_routingKey); sb.Append(",");
4842       sb.Append(m_identifier);
4843       sb.Append(")");
4844     }
4845   }
4846   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4847   public class FileAck: RabbitMQ.Client.Impl.MethodBase, IFileAck {
4848     public const int ClassId = 70;
4849     public const int MethodId = 90;
4850
4851     public ulong m_deliveryTag;
4852     public bool m_multiple;
4853
4854     ulong IFileAck.DeliveryTag { get { return m_deliveryTag; } }
4855     bool IFileAck.Multiple { get { return m_multiple; } }
4856
4857     public FileAck() {}
4858     public FileAck(
4859       ulong initDeliveryTag,
4860       bool initMultiple)
4861     {
4862       m_deliveryTag = initDeliveryTag;
4863       m_multiple = initMultiple;
4864     }
4865
4866     public override int ProtocolClassId { get { return 70; } }
4867     public override int ProtocolMethodId { get { return 90; } }
4868     public override string ProtocolMethodName { get { return "file.ack"; } }
4869     public override bool HasContent { get { return false; } }
4870
4871     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4872       m_deliveryTag = reader.ReadLonglong();
4873       m_multiple = reader.ReadBit();
4874     }
4875
4876     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4877       writer.WriteLonglong(m_deliveryTag);
4878       writer.WriteBit(m_multiple);
4879     }
4880
4881     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4882       sb.Append("(");
4883       sb.Append(m_deliveryTag); sb.Append(",");
4884       sb.Append(m_multiple);
4885       sb.Append(")");
4886     }
4887   }
4888   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4889   public class FileReject: RabbitMQ.Client.Impl.MethodBase, IFileReject {
4890     public const int ClassId = 70;
4891     public const int MethodId = 100;
4892
4893     public ulong m_deliveryTag;
4894     public bool m_requeue;
4895
4896     ulong IFileReject.DeliveryTag { get { return m_deliveryTag; } }
4897     bool IFileReject.Requeue { get { return m_requeue; } }
4898
4899     public FileReject() {}
4900     public FileReject(
4901       ulong initDeliveryTag,
4902       bool initRequeue)
4903     {
4904       m_deliveryTag = initDeliveryTag;
4905       m_requeue = initRequeue;
4906     }
4907
4908     public override int ProtocolClassId { get { return 70; } }
4909     public override int ProtocolMethodId { get { return 100; } }
4910     public override string ProtocolMethodName { get { return "file.reject"; } }
4911     public override bool HasContent { get { return false; } }
4912
4913     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4914       m_deliveryTag = reader.ReadLonglong();
4915       m_requeue = reader.ReadBit();
4916     }
4917
4918     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4919       writer.WriteLonglong(m_deliveryTag);
4920       writer.WriteBit(m_requeue);
4921     }
4922
4923     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4924       sb.Append("(");
4925       sb.Append(m_deliveryTag); sb.Append(",");
4926       sb.Append(m_requeue);
4927       sb.Append(")");
4928     }
4929   }
4930   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4931   public class StreamQos: RabbitMQ.Client.Impl.MethodBase, IStreamQos {
4932     public const int ClassId = 80;
4933     public const int MethodId = 10;
4934
4935     public uint m_prefetchSize;
4936     public ushort m_prefetchCount;
4937     public uint m_consumeRate;
4938     public bool m_global;
4939
4940     uint IStreamQos.PrefetchSize { get { return m_prefetchSize; } }
4941     ushort IStreamQos.PrefetchCount { get { return m_prefetchCount; } }
4942     uint IStreamQos.ConsumeRate { get { return m_consumeRate; } }
4943     bool IStreamQos.Global { get { return m_global; } }
4944
4945     public StreamQos() {}
4946     public StreamQos(
4947       uint initPrefetchSize,
4948       ushort initPrefetchCount,
4949       uint initConsumeRate,
4950       bool initGlobal)
4951     {
4952       m_prefetchSize = initPrefetchSize;
4953       m_prefetchCount = initPrefetchCount;
4954       m_consumeRate = initConsumeRate;
4955       m_global = initGlobal;
4956     }
4957
4958     public override int ProtocolClassId { get { return 80; } }
4959     public override int ProtocolMethodId { get { return 10; } }
4960     public override string ProtocolMethodName { get { return "stream.qos"; } }
4961     public override bool HasContent { get { return false; } }
4962
4963     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
4964       m_prefetchSize = reader.ReadLong();
4965       m_prefetchCount = reader.ReadShort();
4966       m_consumeRate = reader.ReadLong();
4967       m_global = reader.ReadBit();
4968     }
4969
4970     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
4971       writer.WriteLong(m_prefetchSize);
4972       writer.WriteShort(m_prefetchCount);
4973       writer.WriteLong(m_consumeRate);
4974       writer.WriteBit(m_global);
4975     }
4976
4977     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
4978       sb.Append("(");
4979       sb.Append(m_prefetchSize); sb.Append(",");
4980       sb.Append(m_prefetchCount); sb.Append(",");
4981       sb.Append(m_consumeRate); sb.Append(",");
4982       sb.Append(m_global);
4983       sb.Append(")");
4984     }
4985   }
4986   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
4987   public class StreamQosOk: RabbitMQ.Client.Impl.MethodBase, IStreamQosOk {
4988     public const int ClassId = 80;
4989     public const int MethodId = 11;
4990
4991
4992
4993     public StreamQosOk(
4994 )
4995     {
4996     }
4997
4998     public override int ProtocolClassId { get { return 80; } }
4999     public override int ProtocolMethodId { get { return 11; } }
5000     public override string ProtocolMethodName { get { return "stream.qos-ok"; } }
5001     public override bool HasContent { get { return false; } }
5002
5003     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5004     }
5005
5006     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5007     }
5008
5009     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5010       sb.Append("(");
5011       sb.Append(")");
5012     }
5013   }
5014   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5015   public class StreamConsume: RabbitMQ.Client.Impl.MethodBase, IStreamConsume {
5016     public const int ClassId = 80;
5017     public const int MethodId = 20;
5018
5019     public ushort m_ticket;
5020     public string m_queue;
5021     public string m_consumerTag;
5022     public bool m_noLocal;
5023     public bool m_exclusive;
5024     public bool m_nowait;
5025     public System.Collections.IDictionary m_filter;
5026
5027     ushort IStreamConsume.Ticket { get { return m_ticket; } }
5028     string IStreamConsume.Queue { get { return m_queue; } }
5029     string IStreamConsume.ConsumerTag { get { return m_consumerTag; } }
5030     bool IStreamConsume.NoLocal { get { return m_noLocal; } }
5031     bool IStreamConsume.Exclusive { get { return m_exclusive; } }
5032     bool IStreamConsume.Nowait { get { return m_nowait; } }
5033     System.Collections.IDictionary IStreamConsume.Filter { get { return m_filter; } }
5034
5035     public StreamConsume() {}
5036     public StreamConsume(
5037       ushort initTicket,
5038       string initQueue,
5039       string initConsumerTag,
5040       bool initNoLocal,
5041       bool initExclusive,
5042       bool initNowait,
5043       System.Collections.IDictionary initFilter)
5044     {
5045       m_ticket = initTicket;
5046       m_queue = initQueue;
5047       m_consumerTag = initConsumerTag;
5048       m_noLocal = initNoLocal;
5049       m_exclusive = initExclusive;
5050       m_nowait = initNowait;
5051       m_filter = initFilter;
5052     }
5053
5054     public override int ProtocolClassId { get { return 80; } }
5055     public override int ProtocolMethodId { get { return 20; } }
5056     public override string ProtocolMethodName { get { return "stream.consume"; } }
5057     public override bool HasContent { get { return false; } }
5058
5059     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5060       m_ticket = reader.ReadShort();
5061       m_queue = reader.ReadShortstr();
5062       m_consumerTag = reader.ReadShortstr();
5063       m_noLocal = reader.ReadBit();
5064       m_exclusive = reader.ReadBit();
5065       m_nowait = reader.ReadBit();
5066       m_filter = reader.ReadTable();
5067     }
5068
5069     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5070       writer.WriteShort(m_ticket);
5071       writer.WriteShortstr(m_queue);
5072       writer.WriteShortstr(m_consumerTag);
5073       writer.WriteBit(m_noLocal);
5074       writer.WriteBit(m_exclusive);
5075       writer.WriteBit(m_nowait);
5076       writer.WriteTable(m_filter);
5077     }
5078
5079     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5080       sb.Append("(");
5081       sb.Append(m_ticket); sb.Append(",");
5082       sb.Append(m_queue); sb.Append(",");
5083       sb.Append(m_consumerTag); sb.Append(",");
5084       sb.Append(m_noLocal); sb.Append(",");
5085       sb.Append(m_exclusive); sb.Append(",");
5086       sb.Append(m_nowait); sb.Append(",");
5087       sb.Append(m_filter);
5088       sb.Append(")");
5089     }
5090   }
5091   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5092   public class StreamConsumeOk: RabbitMQ.Client.Impl.MethodBase, IStreamConsumeOk {
5093     public const int ClassId = 80;
5094     public const int MethodId = 21;
5095
5096     public string m_consumerTag;
5097
5098     string IStreamConsumeOk.ConsumerTag { get { return m_consumerTag; } }
5099
5100     public StreamConsumeOk() {}
5101     public StreamConsumeOk(
5102       string initConsumerTag)
5103     {
5104       m_consumerTag = initConsumerTag;
5105     }
5106
5107     public override int ProtocolClassId { get { return 80; } }
5108     public override int ProtocolMethodId { get { return 21; } }
5109     public override string ProtocolMethodName { get { return "stream.consume-ok"; } }
5110     public override bool HasContent { get { return false; } }
5111
5112     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5113       m_consumerTag = reader.ReadShortstr();
5114     }
5115
5116     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5117       writer.WriteShortstr(m_consumerTag);
5118     }
5119
5120     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5121       sb.Append("(");
5122       sb.Append(m_consumerTag);
5123       sb.Append(")");
5124     }
5125   }
5126   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5127   public class StreamCancel: RabbitMQ.Client.Impl.MethodBase, IStreamCancel {
5128     public const int ClassId = 80;
5129     public const int MethodId = 30;
5130
5131     public string m_consumerTag;
5132     public bool m_nowait;
5133
5134     string IStreamCancel.ConsumerTag { get { return m_consumerTag; } }
5135     bool IStreamCancel.Nowait { get { return m_nowait; } }
5136
5137     public StreamCancel() {}
5138     public StreamCancel(
5139       string initConsumerTag,
5140       bool initNowait)
5141     {
5142       m_consumerTag = initConsumerTag;
5143       m_nowait = initNowait;
5144     }
5145
5146     public override int ProtocolClassId { get { return 80; } }
5147     public override int ProtocolMethodId { get { return 30; } }
5148     public override string ProtocolMethodName { get { return "stream.cancel"; } }
5149     public override bool HasContent { get { return false; } }
5150
5151     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5152       m_consumerTag = reader.ReadShortstr();
5153       m_nowait = reader.ReadBit();
5154     }
5155
5156     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5157       writer.WriteShortstr(m_consumerTag);
5158       writer.WriteBit(m_nowait);
5159     }
5160
5161     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5162       sb.Append("(");
5163       sb.Append(m_consumerTag); sb.Append(",");
5164       sb.Append(m_nowait);
5165       sb.Append(")");
5166     }
5167   }
5168   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5169   public class StreamCancelOk: RabbitMQ.Client.Impl.MethodBase, IStreamCancelOk {
5170     public const int ClassId = 80;
5171     public const int MethodId = 31;
5172
5173     public string m_consumerTag;
5174
5175     string IStreamCancelOk.ConsumerTag { get { return m_consumerTag; } }
5176
5177     public StreamCancelOk() {}
5178     public StreamCancelOk(
5179       string initConsumerTag)
5180     {
5181       m_consumerTag = initConsumerTag;
5182     }
5183
5184     public override int ProtocolClassId { get { return 80; } }
5185     public override int ProtocolMethodId { get { return 31; } }
5186     public override string ProtocolMethodName { get { return "stream.cancel-ok"; } }
5187     public override bool HasContent { get { return false; } }
5188
5189     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5190       m_consumerTag = reader.ReadShortstr();
5191     }
5192
5193     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5194       writer.WriteShortstr(m_consumerTag);
5195     }
5196
5197     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5198       sb.Append("(");
5199       sb.Append(m_consumerTag);
5200       sb.Append(")");
5201     }
5202   }
5203   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5204   public class StreamPublish: RabbitMQ.Client.Impl.MethodBase, IStreamPublish {
5205     public const int ClassId = 80;
5206     public const int MethodId = 40;
5207
5208     public ushort m_ticket;
5209     public string m_exchange;
5210     public string m_routingKey;
5211     public bool m_mandatory;
5212     public bool m_immediate;
5213
5214     ushort IStreamPublish.Ticket { get { return m_ticket; } }
5215     string IStreamPublish.Exchange { get { return m_exchange; } }
5216     string IStreamPublish.RoutingKey { get { return m_routingKey; } }
5217     bool IStreamPublish.Mandatory { get { return m_mandatory; } }
5218     bool IStreamPublish.Immediate { get { return m_immediate; } }
5219
5220     public StreamPublish() {}
5221     public StreamPublish(
5222       ushort initTicket,
5223       string initExchange,
5224       string initRoutingKey,
5225       bool initMandatory,
5226       bool initImmediate)
5227     {
5228       m_ticket = initTicket;
5229       m_exchange = initExchange;
5230       m_routingKey = initRoutingKey;
5231       m_mandatory = initMandatory;
5232       m_immediate = initImmediate;
5233     }
5234
5235     public override int ProtocolClassId { get { return 80; } }
5236     public override int ProtocolMethodId { get { return 40; } }
5237     public override string ProtocolMethodName { get { return "stream.publish"; } }
5238     public override bool HasContent { get { return true; } }
5239
5240     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5241       m_ticket = reader.ReadShort();
5242       m_exchange = reader.ReadShortstr();
5243       m_routingKey = reader.ReadShortstr();
5244       m_mandatory = reader.ReadBit();
5245       m_immediate = reader.ReadBit();
5246     }
5247
5248     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5249       writer.WriteShort(m_ticket);
5250       writer.WriteShortstr(m_exchange);
5251       writer.WriteShortstr(m_routingKey);
5252       writer.WriteBit(m_mandatory);
5253       writer.WriteBit(m_immediate);
5254     }
5255
5256     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5257       sb.Append("(");
5258       sb.Append(m_ticket); sb.Append(",");
5259       sb.Append(m_exchange); sb.Append(",");
5260       sb.Append(m_routingKey); sb.Append(",");
5261       sb.Append(m_mandatory); sb.Append(",");
5262       sb.Append(m_immediate);
5263       sb.Append(")");
5264     }
5265   }
5266   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5267   public class StreamReturn: RabbitMQ.Client.Impl.MethodBase, IStreamReturn {
5268     public const int ClassId = 80;
5269     public const int MethodId = 50;
5270
5271     public ushort m_replyCode;
5272     public string m_replyText;
5273     public string m_exchange;
5274     public string m_routingKey;
5275
5276     ushort IStreamReturn.ReplyCode { get { return m_replyCode; } }
5277     string IStreamReturn.ReplyText { get { return m_replyText; } }
5278     string IStreamReturn.Exchange { get { return m_exchange; } }
5279     string IStreamReturn.RoutingKey { get { return m_routingKey; } }
5280
5281     public StreamReturn() {}
5282     public StreamReturn(
5283       ushort initReplyCode,
5284       string initReplyText,
5285       string initExchange,
5286       string initRoutingKey)
5287     {
5288       m_replyCode = initReplyCode;
5289       m_replyText = initReplyText;
5290       m_exchange = initExchange;
5291       m_routingKey = initRoutingKey;
5292     }
5293
5294     public override int ProtocolClassId { get { return 80; } }
5295     public override int ProtocolMethodId { get { return 50; } }
5296     public override string ProtocolMethodName { get { return "stream.return"; } }
5297     public override bool HasContent { get { return true; } }
5298
5299     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5300       m_replyCode = reader.ReadShort();
5301       m_replyText = reader.ReadShortstr();
5302       m_exchange = reader.ReadShortstr();
5303       m_routingKey = reader.ReadShortstr();
5304     }
5305
5306     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5307       writer.WriteShort(m_replyCode);
5308       writer.WriteShortstr(m_replyText);
5309       writer.WriteShortstr(m_exchange);
5310       writer.WriteShortstr(m_routingKey);
5311     }
5312
5313     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5314       sb.Append("(");
5315       sb.Append(m_replyCode); sb.Append(",");
5316       sb.Append(m_replyText); sb.Append(",");
5317       sb.Append(m_exchange); sb.Append(",");
5318       sb.Append(m_routingKey);
5319       sb.Append(")");
5320     }
5321   }
5322   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5323   public class StreamDeliver: RabbitMQ.Client.Impl.MethodBase, IStreamDeliver {
5324     public const int ClassId = 80;
5325     public const int MethodId = 60;
5326
5327     public string m_consumerTag;
5328     public ulong m_deliveryTag;
5329     public string m_exchange;
5330     public string m_queue;
5331
5332     string IStreamDeliver.ConsumerTag { get { return m_consumerTag; } }
5333     ulong IStreamDeliver.DeliveryTag { get { return m_deliveryTag; } }
5334     string IStreamDeliver.Exchange { get { return m_exchange; } }
5335     string IStreamDeliver.Queue { get { return m_queue; } }
5336
5337     public StreamDeliver() {}
5338     public StreamDeliver(
5339       string initConsumerTag,
5340       ulong initDeliveryTag,
5341       string initExchange,
5342       string initQueue)
5343     {
5344       m_consumerTag = initConsumerTag;
5345       m_deliveryTag = initDeliveryTag;
5346       m_exchange = initExchange;
5347       m_queue = initQueue;
5348     }
5349
5350     public override int ProtocolClassId { get { return 80; } }
5351     public override int ProtocolMethodId { get { return 60; } }
5352     public override string ProtocolMethodName { get { return "stream.deliver"; } }
5353     public override bool HasContent { get { return true; } }
5354
5355     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5356       m_consumerTag = reader.ReadShortstr();
5357       m_deliveryTag = reader.ReadLonglong();
5358       m_exchange = reader.ReadShortstr();
5359       m_queue = reader.ReadShortstr();
5360     }
5361
5362     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5363       writer.WriteShortstr(m_consumerTag);
5364       writer.WriteLonglong(m_deliveryTag);
5365       writer.WriteShortstr(m_exchange);
5366       writer.WriteShortstr(m_queue);
5367     }
5368
5369     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5370       sb.Append("(");
5371       sb.Append(m_consumerTag); sb.Append(",");
5372       sb.Append(m_deliveryTag); sb.Append(",");
5373       sb.Append(m_exchange); sb.Append(",");
5374       sb.Append(m_queue);
5375       sb.Append(")");
5376     }
5377   }
5378   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5379   public class TxSelect: RabbitMQ.Client.Impl.MethodBase, ITxSelect {
5380     public const int ClassId = 90;
5381     public const int MethodId = 10;
5382
5383
5384
5385     public TxSelect(
5386 )
5387     {
5388     }
5389
5390     public override int ProtocolClassId { get { return 90; } }
5391     public override int ProtocolMethodId { get { return 10; } }
5392     public override string ProtocolMethodName { get { return "tx.select"; } }
5393     public override bool HasContent { get { return false; } }
5394
5395     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5396     }
5397
5398     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5399     }
5400
5401     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5402       sb.Append("(");
5403       sb.Append(")");
5404     }
5405   }
5406   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5407   public class TxSelectOk: RabbitMQ.Client.Impl.MethodBase, ITxSelectOk {
5408     public const int ClassId = 90;
5409     public const int MethodId = 11;
5410
5411
5412
5413     public TxSelectOk(
5414 )
5415     {
5416     }
5417
5418     public override int ProtocolClassId { get { return 90; } }
5419     public override int ProtocolMethodId { get { return 11; } }
5420     public override string ProtocolMethodName { get { return "tx.select-ok"; } }
5421     public override bool HasContent { get { return false; } }
5422
5423     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5424     }
5425
5426     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5427     }
5428
5429     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5430       sb.Append("(");
5431       sb.Append(")");
5432     }
5433   }
5434   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5435   public class TxCommit: RabbitMQ.Client.Impl.MethodBase, ITxCommit {
5436     public const int ClassId = 90;
5437     public const int MethodId = 20;
5438
5439
5440
5441     public TxCommit(
5442 )
5443     {
5444     }
5445
5446     public override int ProtocolClassId { get { return 90; } }
5447     public override int ProtocolMethodId { get { return 20; } }
5448     public override string ProtocolMethodName { get { return "tx.commit"; } }
5449     public override bool HasContent { get { return false; } }
5450
5451     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5452     }
5453
5454     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5455     }
5456
5457     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5458       sb.Append("(");
5459       sb.Append(")");
5460     }
5461   }
5462   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5463   public class TxCommitOk: RabbitMQ.Client.Impl.MethodBase, ITxCommitOk {
5464     public const int ClassId = 90;
5465     public const int MethodId = 21;
5466
5467
5468
5469     public TxCommitOk(
5470 )
5471     {
5472     }
5473
5474     public override int ProtocolClassId { get { return 90; } }
5475     public override int ProtocolMethodId { get { return 21; } }
5476     public override string ProtocolMethodName { get { return "tx.commit-ok"; } }
5477     public override bool HasContent { get { return false; } }
5478
5479     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5480     }
5481
5482     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5483     }
5484
5485     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5486       sb.Append("(");
5487       sb.Append(")");
5488     }
5489   }
5490   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5491   public class TxRollback: RabbitMQ.Client.Impl.MethodBase, ITxRollback {
5492     public const int ClassId = 90;
5493     public const int MethodId = 30;
5494
5495
5496
5497     public TxRollback(
5498 )
5499     {
5500     }
5501
5502     public override int ProtocolClassId { get { return 90; } }
5503     public override int ProtocolMethodId { get { return 30; } }
5504     public override string ProtocolMethodName { get { return "tx.rollback"; } }
5505     public override bool HasContent { get { return false; } }
5506
5507     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5508     }
5509
5510     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5511     }
5512
5513     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5514       sb.Append("(");
5515       sb.Append(")");
5516     }
5517   }
5518   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5519   public class TxRollbackOk: RabbitMQ.Client.Impl.MethodBase, ITxRollbackOk {
5520     public const int ClassId = 90;
5521     public const int MethodId = 31;
5522
5523
5524
5525     public TxRollbackOk(
5526 )
5527     {
5528     }
5529
5530     public override int ProtocolClassId { get { return 90; } }
5531     public override int ProtocolMethodId { get { return 31; } }
5532     public override string ProtocolMethodName { get { return "tx.rollback-ok"; } }
5533     public override bool HasContent { get { return false; } }
5534
5535     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5536     }
5537
5538     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5539     }
5540
5541     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5542       sb.Append("(");
5543       sb.Append(")");
5544     }
5545   }
5546   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5547   public class DtxSelect: RabbitMQ.Client.Impl.MethodBase, IDtxSelect {
5548     public const int ClassId = 100;
5549     public const int MethodId = 10;
5550
5551
5552
5553     public DtxSelect(
5554 )
5555     {
5556     }
5557
5558     public override int ProtocolClassId { get { return 100; } }
5559     public override int ProtocolMethodId { get { return 10; } }
5560     public override string ProtocolMethodName { get { return "dtx.select"; } }
5561     public override bool HasContent { get { return false; } }
5562
5563     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5564     }
5565
5566     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5567     }
5568
5569     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5570       sb.Append("(");
5571       sb.Append(")");
5572     }
5573   }
5574   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5575   public class DtxSelectOk: RabbitMQ.Client.Impl.MethodBase, IDtxSelectOk {
5576     public const int ClassId = 100;
5577     public const int MethodId = 11;
5578
5579
5580
5581     public DtxSelectOk(
5582 )
5583     {
5584     }
5585
5586     public override int ProtocolClassId { get { return 100; } }
5587     public override int ProtocolMethodId { get { return 11; } }
5588     public override string ProtocolMethodName { get { return "dtx.select-ok"; } }
5589     public override bool HasContent { get { return false; } }
5590
5591     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5592     }
5593
5594     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5595     }
5596
5597     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5598       sb.Append("(");
5599       sb.Append(")");
5600     }
5601   }
5602   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5603   public class DtxStart: RabbitMQ.Client.Impl.MethodBase, IDtxStart {
5604     public const int ClassId = 100;
5605     public const int MethodId = 20;
5606
5607     public string m_dtxIdentifier;
5608
5609     string IDtxStart.DtxIdentifier { get { return m_dtxIdentifier; } }
5610
5611     public DtxStart() {}
5612     public DtxStart(
5613       string initDtxIdentifier)
5614     {
5615       m_dtxIdentifier = initDtxIdentifier;
5616     }
5617
5618     public override int ProtocolClassId { get { return 100; } }
5619     public override int ProtocolMethodId { get { return 20; } }
5620     public override string ProtocolMethodName { get { return "dtx.start"; } }
5621     public override bool HasContent { get { return false; } }
5622
5623     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5624       m_dtxIdentifier = reader.ReadShortstr();
5625     }
5626
5627     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5628       writer.WriteShortstr(m_dtxIdentifier);
5629     }
5630
5631     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5632       sb.Append("(");
5633       sb.Append(m_dtxIdentifier);
5634       sb.Append(")");
5635     }
5636   }
5637   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5638   public class DtxStartOk: RabbitMQ.Client.Impl.MethodBase, IDtxStartOk {
5639     public const int ClassId = 100;
5640     public const int MethodId = 21;
5641
5642
5643
5644     public DtxStartOk(
5645 )
5646     {
5647     }
5648
5649     public override int ProtocolClassId { get { return 100; } }
5650     public override int ProtocolMethodId { get { return 21; } }
5651     public override string ProtocolMethodName { get { return "dtx.start-ok"; } }
5652     public override bool HasContent { get { return false; } }
5653
5654     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5655     }
5656
5657     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5658     }
5659
5660     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5661       sb.Append("(");
5662       sb.Append(")");
5663     }
5664   }
5665   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5666   public class TunnelRequest: RabbitMQ.Client.Impl.MethodBase, ITunnelRequest {
5667     public const int ClassId = 110;
5668     public const int MethodId = 10;
5669
5670     public System.Collections.IDictionary m_metaData;
5671
5672     System.Collections.IDictionary ITunnelRequest.MetaData { get { return m_metaData; } }
5673
5674     public TunnelRequest() {}
5675     public TunnelRequest(
5676       System.Collections.IDictionary initMetaData)
5677     {
5678       m_metaData = initMetaData;
5679     }
5680
5681     public override int ProtocolClassId { get { return 110; } }
5682     public override int ProtocolMethodId { get { return 10; } }
5683     public override string ProtocolMethodName { get { return "tunnel.request"; } }
5684     public override bool HasContent { get { return true; } }
5685
5686     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5687       m_metaData = reader.ReadTable();
5688     }
5689
5690     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5691       writer.WriteTable(m_metaData);
5692     }
5693
5694     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5695       sb.Append("(");
5696       sb.Append(m_metaData);
5697       sb.Append(")");
5698     }
5699   }
5700   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5701   public class MessageTransfer: RabbitMQ.Client.Impl.MethodBase, IMessageTransfer {
5702     public const int ClassId = 120;
5703     public const int MethodId = 10;
5704
5705     public ushort m_ticket;
5706     public string m_destination;
5707     public bool m_redelivered;
5708     public bool m_immediate;
5709     public ulong m_ttl;
5710     public byte m_priority;
5711     public AmqpTimestamp m_timestamp;
5712     public byte m_deliveryMode;
5713     public AmqpTimestamp m_expiration;
5714     public string m_exchange;
5715     public string m_routingKey;
5716     public string m_messageId;
5717     public string m_correlationId;
5718     public string m_replyTo;
5719     public string m_contentType;
5720     public string m_contentEncoding;
5721     public string m_userId;
5722     public string m_appId;
5723     public string m_transactionId;
5724     public byte[] m_securityToken;
5725     public System.Collections.IDictionary m_applicationHeaders;
5726     public byte[] m_body;
5727
5728     ushort IMessageTransfer.Ticket { get { return m_ticket; } }
5729     string IMessageTransfer.Destination { get { return m_destination; } }
5730     bool IMessageTransfer.Redelivered { get { return m_redelivered; } }
5731     bool IMessageTransfer.Immediate { get { return m_immediate; } }
5732     ulong IMessageTransfer.Ttl { get { return m_ttl; } }
5733     byte IMessageTransfer.Priority { get { return m_priority; } }
5734     AmqpTimestamp IMessageTransfer.Timestamp { get { return m_timestamp; } }
5735     byte IMessageTransfer.DeliveryMode { get { return m_deliveryMode; } }
5736     AmqpTimestamp IMessageTransfer.Expiration { get { return m_expiration; } }
5737     string IMessageTransfer.Exchange { get { return m_exchange; } }
5738     string IMessageTransfer.RoutingKey { get { return m_routingKey; } }
5739     string IMessageTransfer.MessageId { get { return m_messageId; } }
5740     string IMessageTransfer.CorrelationId { get { return m_correlationId; } }
5741     string IMessageTransfer.ReplyTo { get { return m_replyTo; } }
5742     string IMessageTransfer.ContentType { get { return m_contentType; } }
5743     string IMessageTransfer.ContentEncoding { get { return m_contentEncoding; } }
5744     string IMessageTransfer.UserId { get { return m_userId; } }
5745     string IMessageTransfer.AppId { get { return m_appId; } }
5746     string IMessageTransfer.TransactionId { get { return m_transactionId; } }
5747     byte[] IMessageTransfer.SecurityToken { get { return m_securityToken; } }
5748     System.Collections.IDictionary IMessageTransfer.ApplicationHeaders { get { return m_applicationHeaders; } }
5749     byte[] IMessageTransfer.Body { get { return m_body; } }
5750
5751     public MessageTransfer() {}
5752     public MessageTransfer(
5753       ushort initTicket,
5754       string initDestination,
5755       bool initRedelivered,
5756       bool initImmediate,
5757       ulong initTtl,
5758       byte initPriority,
5759       AmqpTimestamp initTimestamp,
5760       byte initDeliveryMode,
5761       AmqpTimestamp initExpiration,
5762       string initExchange,
5763       string initRoutingKey,
5764       string initMessageId,
5765       string initCorrelationId,
5766       string initReplyTo,
5767       string initContentType,
5768       string initContentEncoding,
5769       string initUserId,
5770       string initAppId,
5771       string initTransactionId,
5772       byte[] initSecurityToken,
5773       System.Collections.IDictionary initApplicationHeaders,
5774       byte[] initBody)
5775     {
5776       m_ticket = initTicket;
5777       m_destination = initDestination;
5778       m_redelivered = initRedelivered;
5779       m_immediate = initImmediate;
5780       m_ttl = initTtl;
5781       m_priority = initPriority;
5782       m_timestamp = initTimestamp;
5783       m_deliveryMode = initDeliveryMode;
5784       m_expiration = initExpiration;
5785       m_exchange = initExchange;
5786       m_routingKey = initRoutingKey;
5787       m_messageId = initMessageId;
5788       m_correlationId = initCorrelationId;
5789       m_replyTo = initReplyTo;
5790       m_contentType = initContentType;
5791       m_contentEncoding = initContentEncoding;
5792       m_userId = initUserId;
5793       m_appId = initAppId;
5794       m_transactionId = initTransactionId;
5795       m_securityToken = initSecurityToken;
5796       m_applicationHeaders = initApplicationHeaders;
5797       m_body = initBody;
5798     }
5799
5800     public override int ProtocolClassId { get { return 120; } }
5801     public override int ProtocolMethodId { get { return 10; } }
5802     public override string ProtocolMethodName { get { return "message.transfer"; } }
5803     public override bool HasContent { get { return false; } }
5804
5805     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5806       m_ticket = reader.ReadShort();
5807       m_destination = reader.ReadShortstr();
5808       m_redelivered = reader.ReadBit();
5809       m_immediate = reader.ReadBit();
5810       m_ttl = reader.ReadLonglong();
5811       m_priority = reader.ReadOctet();
5812       m_timestamp = reader.ReadTimestamp();
5813       m_deliveryMode = reader.ReadOctet();
5814       m_expiration = reader.ReadTimestamp();
5815       m_exchange = reader.ReadShortstr();
5816       m_routingKey = reader.ReadShortstr();
5817       m_messageId = reader.ReadShortstr();
5818       m_correlationId = reader.ReadShortstr();
5819       m_replyTo = reader.ReadShortstr();
5820       m_contentType = reader.ReadShortstr();
5821       m_contentEncoding = reader.ReadShortstr();
5822       m_userId = reader.ReadShortstr();
5823       m_appId = reader.ReadShortstr();
5824       m_transactionId = reader.ReadShortstr();
5825       m_securityToken = reader.ReadLongstr();
5826       m_applicationHeaders = reader.ReadTable();
5827       m_body = reader.ReadContent();
5828     }
5829
5830     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5831       writer.WriteShort(m_ticket);
5832       writer.WriteShortstr(m_destination);
5833       writer.WriteBit(m_redelivered);
5834       writer.WriteBit(m_immediate);
5835       writer.WriteLonglong(m_ttl);
5836       writer.WriteOctet(m_priority);
5837       writer.WriteTimestamp(m_timestamp);
5838       writer.WriteOctet(m_deliveryMode);
5839       writer.WriteTimestamp(m_expiration);
5840       writer.WriteShortstr(m_exchange);
5841       writer.WriteShortstr(m_routingKey);
5842       writer.WriteShortstr(m_messageId);
5843       writer.WriteShortstr(m_correlationId);
5844       writer.WriteShortstr(m_replyTo);
5845       writer.WriteShortstr(m_contentType);
5846       writer.WriteShortstr(m_contentEncoding);
5847       writer.WriteShortstr(m_userId);
5848       writer.WriteShortstr(m_appId);
5849       writer.WriteShortstr(m_transactionId);
5850       writer.WriteLongstr(m_securityToken);
5851       writer.WriteTable(m_applicationHeaders);
5852       writer.WriteContent(m_body);
5853     }
5854
5855     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5856       sb.Append("(");
5857       sb.Append(m_ticket); sb.Append(",");
5858       sb.Append(m_destination); sb.Append(",");
5859       sb.Append(m_redelivered); sb.Append(",");
5860       sb.Append(m_immediate); sb.Append(",");
5861       sb.Append(m_ttl); sb.Append(",");
5862       sb.Append(m_priority); sb.Append(",");
5863       sb.Append(m_timestamp); sb.Append(",");
5864       sb.Append(m_deliveryMode); sb.Append(",");
5865       sb.Append(m_expiration); sb.Append(",");
5866       sb.Append(m_exchange); sb.Append(",");
5867       sb.Append(m_routingKey); sb.Append(",");
5868       sb.Append(m_messageId); sb.Append(",");
5869       sb.Append(m_correlationId); sb.Append(",");
5870       sb.Append(m_replyTo); sb.Append(",");
5871       sb.Append(m_contentType); sb.Append(",");
5872       sb.Append(m_contentEncoding); sb.Append(",");
5873       sb.Append(m_userId); sb.Append(",");
5874       sb.Append(m_appId); sb.Append(",");
5875       sb.Append(m_transactionId); sb.Append(",");
5876       sb.Append(m_securityToken); sb.Append(",");
5877       sb.Append(m_applicationHeaders); sb.Append(",");
5878       sb.Append(m_body);
5879       sb.Append(")");
5880     }
5881   }
5882   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5883   public class MessageConsume: RabbitMQ.Client.Impl.MethodBase, IMessageConsume {
5884     public const int ClassId = 120;
5885     public const int MethodId = 20;
5886
5887     public ushort m_ticket;
5888     public string m_queue;
5889     public string m_destination;
5890     public bool m_noLocal;
5891     public bool m_noAck;
5892     public bool m_exclusive;
5893     public System.Collections.IDictionary m_filter;
5894
5895     ushort IMessageConsume.Ticket { get { return m_ticket; } }
5896     string IMessageConsume.Queue { get { return m_queue; } }
5897     string IMessageConsume.Destination { get { return m_destination; } }
5898     bool IMessageConsume.NoLocal { get { return m_noLocal; } }
5899     bool IMessageConsume.NoAck { get { return m_noAck; } }
5900     bool IMessageConsume.Exclusive { get { return m_exclusive; } }
5901     System.Collections.IDictionary IMessageConsume.Filter { get { return m_filter; } }
5902
5903     public MessageConsume() {}
5904     public MessageConsume(
5905       ushort initTicket,
5906       string initQueue,
5907       string initDestination,
5908       bool initNoLocal,
5909       bool initNoAck,
5910       bool initExclusive,
5911       System.Collections.IDictionary initFilter)
5912     {
5913       m_ticket = initTicket;
5914       m_queue = initQueue;
5915       m_destination = initDestination;
5916       m_noLocal = initNoLocal;
5917       m_noAck = initNoAck;
5918       m_exclusive = initExclusive;
5919       m_filter = initFilter;
5920     }
5921
5922     public override int ProtocolClassId { get { return 120; } }
5923     public override int ProtocolMethodId { get { return 20; } }
5924     public override string ProtocolMethodName { get { return "message.consume"; } }
5925     public override bool HasContent { get { return false; } }
5926
5927     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5928       m_ticket = reader.ReadShort();
5929       m_queue = reader.ReadShortstr();
5930       m_destination = reader.ReadShortstr();
5931       m_noLocal = reader.ReadBit();
5932       m_noAck = reader.ReadBit();
5933       m_exclusive = reader.ReadBit();
5934       m_filter = reader.ReadTable();
5935     }
5936
5937     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5938       writer.WriteShort(m_ticket);
5939       writer.WriteShortstr(m_queue);
5940       writer.WriteShortstr(m_destination);
5941       writer.WriteBit(m_noLocal);
5942       writer.WriteBit(m_noAck);
5943       writer.WriteBit(m_exclusive);
5944       writer.WriteTable(m_filter);
5945     }
5946
5947     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5948       sb.Append("(");
5949       sb.Append(m_ticket); sb.Append(",");
5950       sb.Append(m_queue); sb.Append(",");
5951       sb.Append(m_destination); sb.Append(",");
5952       sb.Append(m_noLocal); sb.Append(",");
5953       sb.Append(m_noAck); sb.Append(",");
5954       sb.Append(m_exclusive); sb.Append(",");
5955       sb.Append(m_filter);
5956       sb.Append(")");
5957     }
5958   }
5959   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5960   public class MessageCancel: RabbitMQ.Client.Impl.MethodBase, IMessageCancel {
5961     public const int ClassId = 120;
5962     public const int MethodId = 30;
5963
5964     public string m_destination;
5965
5966     string IMessageCancel.Destination { get { return m_destination; } }
5967
5968     public MessageCancel() {}
5969     public MessageCancel(
5970       string initDestination)
5971     {
5972       m_destination = initDestination;
5973     }
5974
5975     public override int ProtocolClassId { get { return 120; } }
5976     public override int ProtocolMethodId { get { return 30; } }
5977     public override string ProtocolMethodName { get { return "message.cancel"; } }
5978     public override bool HasContent { get { return false; } }
5979
5980     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
5981       m_destination = reader.ReadShortstr();
5982     }
5983
5984     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
5985       writer.WriteShortstr(m_destination);
5986     }
5987
5988     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
5989       sb.Append("(");
5990       sb.Append(m_destination);
5991       sb.Append(")");
5992     }
5993   }
5994   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
5995   public class MessageGet: RabbitMQ.Client.Impl.MethodBase, IMessageGet {
5996     public const int ClassId = 120;
5997     public const int MethodId = 40;
5998
5999     public ushort m_ticket;
6000     public string m_queue;
6001     public string m_destination;
6002     public bool m_noAck;
6003
6004     ushort IMessageGet.Ticket { get { return m_ticket; } }
6005     string IMessageGet.Queue { get { return m_queue; } }
6006     string IMessageGet.Destination { get { return m_destination; } }
6007     bool IMessageGet.NoAck { get { return m_noAck; } }
6008
6009     public MessageGet() {}
6010     public MessageGet(
6011       ushort initTicket,
6012       string initQueue,
6013       string initDestination,
6014       bool initNoAck)
6015     {
6016       m_ticket = initTicket;
6017       m_queue = initQueue;
6018       m_destination = initDestination;
6019       m_noAck = initNoAck;
6020     }
6021
6022     public override int ProtocolClassId { get { return 120; } }
6023     public override int ProtocolMethodId { get { return 40; } }
6024     public override string ProtocolMethodName { get { return "message.get"; } }
6025     public override bool HasContent { get { return false; } }
6026
6027     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6028       m_ticket = reader.ReadShort();
6029       m_queue = reader.ReadShortstr();
6030       m_destination = reader.ReadShortstr();
6031       m_noAck = reader.ReadBit();
6032     }
6033
6034     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6035       writer.WriteShort(m_ticket);
6036       writer.WriteShortstr(m_queue);
6037       writer.WriteShortstr(m_destination);
6038       writer.WriteBit(m_noAck);
6039     }
6040
6041     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6042       sb.Append("(");
6043       sb.Append(m_ticket); sb.Append(",");
6044       sb.Append(m_queue); sb.Append(",");
6045       sb.Append(m_destination); sb.Append(",");
6046       sb.Append(m_noAck);
6047       sb.Append(")");
6048     }
6049   }
6050   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6051   public class MessageRecover: RabbitMQ.Client.Impl.MethodBase, IMessageRecover {
6052     public const int ClassId = 120;
6053     public const int MethodId = 50;
6054
6055     public bool m_requeue;
6056
6057     bool IMessageRecover.Requeue { get { return m_requeue; } }
6058
6059     public MessageRecover() {}
6060     public MessageRecover(
6061       bool initRequeue)
6062     {
6063       m_requeue = initRequeue;
6064     }
6065
6066     public override int ProtocolClassId { get { return 120; } }
6067     public override int ProtocolMethodId { get { return 50; } }
6068     public override string ProtocolMethodName { get { return "message.recover"; } }
6069     public override bool HasContent { get { return false; } }
6070
6071     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6072       m_requeue = reader.ReadBit();
6073     }
6074
6075     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6076       writer.WriteBit(m_requeue);
6077     }
6078
6079     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6080       sb.Append("(");
6081       sb.Append(m_requeue);
6082       sb.Append(")");
6083     }
6084   }
6085   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6086   public class MessageOpen: RabbitMQ.Client.Impl.MethodBase, IMessageOpen {
6087     public const int ClassId = 120;
6088     public const int MethodId = 60;
6089
6090     public byte[] m_reference;
6091
6092     byte[] IMessageOpen.Reference { get { return m_reference; } }
6093
6094     public MessageOpen() {}
6095     public MessageOpen(
6096       byte[] initReference)
6097     {
6098       m_reference = initReference;
6099     }
6100
6101     public override int ProtocolClassId { get { return 120; } }
6102     public override int ProtocolMethodId { get { return 60; } }
6103     public override string ProtocolMethodName { get { return "message.open"; } }
6104     public override bool HasContent { get { return false; } }
6105
6106     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6107       m_reference = reader.ReadLongstr();
6108     }
6109
6110     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6111       writer.WriteLongstr(m_reference);
6112     }
6113
6114     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6115       sb.Append("(");
6116       sb.Append(m_reference);
6117       sb.Append(")");
6118     }
6119   }
6120   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6121   public class MessageClose: RabbitMQ.Client.Impl.MethodBase, IMessageClose {
6122     public const int ClassId = 120;
6123     public const int MethodId = 70;
6124
6125     public byte[] m_reference;
6126
6127     byte[] IMessageClose.Reference { get { return m_reference; } }
6128
6129     public MessageClose() {}
6130     public MessageClose(
6131       byte[] initReference)
6132     {
6133       m_reference = initReference;
6134     }
6135
6136     public override int ProtocolClassId { get { return 120; } }
6137     public override int ProtocolMethodId { get { return 70; } }
6138     public override string ProtocolMethodName { get { return "message.close"; } }
6139     public override bool HasContent { get { return false; } }
6140
6141     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6142       m_reference = reader.ReadLongstr();
6143     }
6144
6145     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6146       writer.WriteLongstr(m_reference);
6147     }
6148
6149     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6150       sb.Append("(");
6151       sb.Append(m_reference);
6152       sb.Append(")");
6153     }
6154   }
6155   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6156   public class MessageAppend: RabbitMQ.Client.Impl.MethodBase, IMessageAppend {
6157     public const int ClassId = 120;
6158     public const int MethodId = 80;
6159
6160     public byte[] m_reference;
6161     public byte[] m_bytes;
6162
6163     byte[] IMessageAppend.Reference { get { return m_reference; } }
6164     byte[] IMessageAppend.Bytes { get { return m_bytes; } }
6165
6166     public MessageAppend() {}
6167     public MessageAppend(
6168       byte[] initReference,
6169       byte[] initBytes)
6170     {
6171       m_reference = initReference;
6172       m_bytes = initBytes;
6173     }
6174
6175     public override int ProtocolClassId { get { return 120; } }
6176     public override int ProtocolMethodId { get { return 80; } }
6177     public override string ProtocolMethodName { get { return "message.append"; } }
6178     public override bool HasContent { get { return false; } }
6179
6180     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6181       m_reference = reader.ReadLongstr();
6182       m_bytes = reader.ReadLongstr();
6183     }
6184
6185     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6186       writer.WriteLongstr(m_reference);
6187       writer.WriteLongstr(m_bytes);
6188     }
6189
6190     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6191       sb.Append("(");
6192       sb.Append(m_reference); sb.Append(",");
6193       sb.Append(m_bytes);
6194       sb.Append(")");
6195     }
6196   }
6197   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6198   public class MessageCheckpoint: RabbitMQ.Client.Impl.MethodBase, IMessageCheckpoint {
6199     public const int ClassId = 120;
6200     public const int MethodId = 90;
6201
6202     public byte[] m_reference;
6203     public string m_identifier;
6204
6205     byte[] IMessageCheckpoint.Reference { get { return m_reference; } }
6206     string IMessageCheckpoint.Identifier { get { return m_identifier; } }
6207
6208     public MessageCheckpoint() {}
6209     public MessageCheckpoint(
6210       byte[] initReference,
6211       string initIdentifier)
6212     {
6213       m_reference = initReference;
6214       m_identifier = initIdentifier;
6215     }
6216
6217     public override int ProtocolClassId { get { return 120; } }
6218     public override int ProtocolMethodId { get { return 90; } }
6219     public override string ProtocolMethodName { get { return "message.checkpoint"; } }
6220     public override bool HasContent { get { return false; } }
6221
6222     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6223       m_reference = reader.ReadLongstr();
6224       m_identifier = reader.ReadShortstr();
6225     }
6226
6227     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6228       writer.WriteLongstr(m_reference);
6229       writer.WriteShortstr(m_identifier);
6230     }
6231
6232     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6233       sb.Append("(");
6234       sb.Append(m_reference); sb.Append(",");
6235       sb.Append(m_identifier);
6236       sb.Append(")");
6237     }
6238   }
6239   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6240   public class MessageResume: RabbitMQ.Client.Impl.MethodBase, IMessageResume {
6241     public const int ClassId = 120;
6242     public const int MethodId = 100;
6243
6244     public byte[] m_reference;
6245     public string m_identifier;
6246
6247     byte[] IMessageResume.Reference { get { return m_reference; } }
6248     string IMessageResume.Identifier { get { return m_identifier; } }
6249
6250     public MessageResume() {}
6251     public MessageResume(
6252       byte[] initReference,
6253       string initIdentifier)
6254     {
6255       m_reference = initReference;
6256       m_identifier = initIdentifier;
6257     }
6258
6259     public override int ProtocolClassId { get { return 120; } }
6260     public override int ProtocolMethodId { get { return 100; } }
6261     public override string ProtocolMethodName { get { return "message.resume"; } }
6262     public override bool HasContent { get { return false; } }
6263
6264     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6265       m_reference = reader.ReadLongstr();
6266       m_identifier = reader.ReadShortstr();
6267     }
6268
6269     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6270       writer.WriteLongstr(m_reference);
6271       writer.WriteShortstr(m_identifier);
6272     }
6273
6274     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6275       sb.Append("(");
6276       sb.Append(m_reference); sb.Append(",");
6277       sb.Append(m_identifier);
6278       sb.Append(")");
6279     }
6280   }
6281   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6282   public class MessageQos: RabbitMQ.Client.Impl.MethodBase, IMessageQos {
6283     public const int ClassId = 120;
6284     public const int MethodId = 110;
6285
6286     public uint m_prefetchSize;
6287     public ushort m_prefetchCount;
6288     public bool m_global;
6289
6290     uint IMessageQos.PrefetchSize { get { return m_prefetchSize; } }
6291     ushort IMessageQos.PrefetchCount { get { return m_prefetchCount; } }
6292     bool IMessageQos.Global { get { return m_global; } }
6293
6294     public MessageQos() {}
6295     public MessageQos(
6296       uint initPrefetchSize,
6297       ushort initPrefetchCount,
6298       bool initGlobal)
6299     {
6300       m_prefetchSize = initPrefetchSize;
6301       m_prefetchCount = initPrefetchCount;
6302       m_global = initGlobal;
6303     }
6304
6305     public override int ProtocolClassId { get { return 120; } }
6306     public override int ProtocolMethodId { get { return 110; } }
6307     public override string ProtocolMethodName { get { return "message.qos"; } }
6308     public override bool HasContent { get { return false; } }
6309
6310     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6311       m_prefetchSize = reader.ReadLong();
6312       m_prefetchCount = reader.ReadShort();
6313       m_global = reader.ReadBit();
6314     }
6315
6316     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6317       writer.WriteLong(m_prefetchSize);
6318       writer.WriteShort(m_prefetchCount);
6319       writer.WriteBit(m_global);
6320     }
6321
6322     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6323       sb.Append("(");
6324       sb.Append(m_prefetchSize); sb.Append(",");
6325       sb.Append(m_prefetchCount); sb.Append(",");
6326       sb.Append(m_global);
6327       sb.Append(")");
6328     }
6329   }
6330   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6331   public class MessageOk: RabbitMQ.Client.Impl.MethodBase, IMessageOk {
6332     public const int ClassId = 120;
6333     public const int MethodId = 500;
6334
6335
6336
6337     public MessageOk(
6338 )
6339     {
6340     }
6341
6342     public override int ProtocolClassId { get { return 120; } }
6343     public override int ProtocolMethodId { get { return 500; } }
6344     public override string ProtocolMethodName { get { return "message.ok"; } }
6345     public override bool HasContent { get { return false; } }
6346
6347     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6348     }
6349
6350     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6351     }
6352
6353     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6354       sb.Append("(");
6355       sb.Append(")");
6356     }
6357   }
6358   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6359   public class MessageEmpty: RabbitMQ.Client.Impl.MethodBase, IMessageEmpty {
6360     public const int ClassId = 120;
6361     public const int MethodId = 510;
6362
6363
6364
6365     public MessageEmpty(
6366 )
6367     {
6368     }
6369
6370     public override int ProtocolClassId { get { return 120; } }
6371     public override int ProtocolMethodId { get { return 510; } }
6372     public override string ProtocolMethodName { get { return "message.empty"; } }
6373     public override bool HasContent { get { return false; } }
6374
6375     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6376     }
6377
6378     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6379     }
6380
6381     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6382       sb.Append("(");
6383       sb.Append(")");
6384     }
6385   }
6386   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6387   public class MessageReject: RabbitMQ.Client.Impl.MethodBase, IMessageReject {
6388     public const int ClassId = 120;
6389     public const int MethodId = 520;
6390
6391     public ushort m_code;
6392     public string m_text;
6393
6394     ushort IMessageReject.Code { get { return m_code; } }
6395     string IMessageReject.Text { get { return m_text; } }
6396
6397     public MessageReject() {}
6398     public MessageReject(
6399       ushort initCode,
6400       string initText)
6401     {
6402       m_code = initCode;
6403       m_text = initText;
6404     }
6405
6406     public override int ProtocolClassId { get { return 120; } }
6407     public override int ProtocolMethodId { get { return 520; } }
6408     public override string ProtocolMethodName { get { return "message.reject"; } }
6409     public override bool HasContent { get { return false; } }
6410
6411     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6412       m_code = reader.ReadShort();
6413       m_text = reader.ReadShortstr();
6414     }
6415
6416     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6417       writer.WriteShort(m_code);
6418       writer.WriteShortstr(m_text);
6419     }
6420
6421     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6422       sb.Append("(");
6423       sb.Append(m_code); sb.Append(",");
6424       sb.Append(m_text);
6425       sb.Append(")");
6426     }
6427   }
6428   /// <summary>Autogenerated type. Private implementation class - do not use directly.</summary>
6429   public class MessageOffset: RabbitMQ.Client.Impl.MethodBase, IMessageOffset {
6430     public const int ClassId = 120;
6431     public const int MethodId = 530;
6432
6433     public ulong m_value;
6434
6435     ulong IMessageOffset.Value { get { return m_value; } }
6436
6437     public MessageOffset() {}
6438     public MessageOffset(
6439       ulong initValue)
6440     {
6441       m_value = initValue;
6442     }
6443
6444     public override int ProtocolClassId { get { return 120; } }
6445     public override int ProtocolMethodId { get { return 530; } }
6446     public override string ProtocolMethodName { get { return "message.offset"; } }
6447     public override bool HasContent { get { return false; } }
6448
6449     public override void ReadArgumentsFrom(RabbitMQ.Client.Impl.MethodArgumentReader reader) {
6450       m_value = reader.ReadLonglong();
6451     }
6452
6453     public override void WriteArgumentsTo(RabbitMQ.Client.Impl.MethodArgumentWriter writer) {
6454       writer.WriteLonglong(m_value);
6455     }
6456
6457     public override void AppendArgumentDebugStringTo(System.Text.StringBuilder sb) {
6458       sb.Append("(");
6459       sb.Append(m_value);
6460       sb.Append(")");
6461     }
6462   }
6463
6464   public class Model: RabbitMQ.Client.Impl.ModelBase {
6465     public Model(RabbitMQ.Client.Impl.ISession session): base(session) {}
6466     public override void _Private_BasicPublish(
6467       System.String @exchange,
6468       System.String @routingKey,
6469       System.Boolean @mandatory,
6470       System.Boolean @immediate,
6471       RabbitMQ.Client.IBasicProperties @basicProperties,
6472       System.Byte[] @body)
6473     {
6474       BasicPublish __req = new BasicPublish();
6475       __req.m_exchange = @exchange;
6476       __req.m_routingKey = @routingKey;
6477       __req.m_mandatory = @mandatory;
6478       __req.m_immediate = @immediate;
6479       ModelSend(__req, (BasicProperties) basicProperties,body);
6480     }
6481     public override void _Private_BasicConsume(
6482       System.String @queue,
6483       System.String @consumerTag,
6484       System.Boolean @noLocal,
6485       System.Boolean @noAck,
6486       System.Boolean @exclusive,
6487       System.Boolean @nowait,
6488       System.Collections.IDictionary @filter)
6489     {
6490       BasicConsume __req = new BasicConsume();
6491       __req.m_queue = @queue;
6492       __req.m_consumerTag = @consumerTag;
6493       __req.m_noLocal = @noLocal;
6494       __req.m_noAck = @noAck;
6495       __req.m_exclusive = @exclusive;
6496       __req.m_nowait = @nowait;
6497       __req.m_filter = @filter;
6498       ModelSend(__req,null,null);
6499     }
6500     public override void _Private_BasicCancel(
6501       System.String @consumerTag,
6502       System.Boolean @nowait)
6503     {
6504       BasicCancel __req = new BasicCancel();
6505       __req.m_consumerTag = @consumerTag;
6506       __req.m_nowait = @nowait;
6507       ModelSend(__req,null,null);
6508     }
6509     public override void _Private_ChannelOpen(
6510       System.String @outOfBand)
6511     {
6512       ChannelOpen __req = new ChannelOpen();
6513       __req.m_outOfBand = @outOfBand;
6514       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6515       ChannelOpenOk __rep = __repBase as ChannelOpenOk;
6516       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6517     }
6518     public override void _Private_ChannelCloseOk()
6519     {
6520       ChannelCloseOk __req = new ChannelCloseOk();
6521       ModelSend(__req,null,null);
6522     }
6523     public override void _Private_ChannelClose(
6524       System.UInt16 @replyCode,
6525       System.String @replyText,
6526       System.UInt16 @classId,
6527       System.UInt16 @methodId)
6528     {
6529       ChannelClose __req = new ChannelClose();
6530       __req.m_replyCode = @replyCode;
6531       __req.m_replyText = @replyText;
6532       __req.m_classId = @classId;
6533       __req.m_methodId = @methodId;
6534       ModelSend(__req,null,null);
6535     }
6536     public override void _Private_BasicGet(
6537       System.String @queue,
6538       System.Boolean @noAck)
6539     {
6540       BasicGet __req = new BasicGet();
6541       __req.m_queue = @queue;
6542       __req.m_noAck = @noAck;
6543       ModelSend(__req,null,null);
6544     }
6545     public override void _Private_ChannelFlowOk()
6546     {
6547       ChannelFlowOk __req = new ChannelFlowOk();
6548       ModelSend(__req,null,null);
6549     }
6550     public override RabbitMQ.Client.Impl.ConnectionTuneDetails ConnectionStartOk(
6551       System.Collections.IDictionary @clientProperties,
6552       System.String @mechanism,
6553       System.Byte[] @response,
6554       System.String @locale)
6555     {
6556       ConnectionStartOk __req = new ConnectionStartOk();
6557       __req.m_clientProperties = @clientProperties;
6558       __req.m_mechanism = @mechanism;
6559       __req.m_response = @response;
6560       __req.m_locale = @locale;
6561       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6562       ConnectionTune __rep = __repBase as ConnectionTune;
6563       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6564       RabbitMQ.Client.Impl.ConnectionTuneDetails __result = new RabbitMQ.Client.Impl.ConnectionTuneDetails();
6565       __result.m_channelMax = __rep.m_channelMax;
6566       __result.m_frameMax = __rep.m_frameMax;
6567       __result.m_heartbeat = __rep.m_heartbeat;
6568       return __result;
6569     }
6570     public override void ConnectionTuneOk(
6571       System.UInt16 @channelMax,
6572       System.UInt32 @frameMax,
6573       System.UInt16 @heartbeat)
6574     {
6575       ConnectionTuneOk __req = new ConnectionTuneOk();
6576       __req.m_channelMax = @channelMax;
6577       __req.m_frameMax = @frameMax;
6578       __req.m_heartbeat = @heartbeat;
6579       ModelSend(__req,null,null);
6580     }
6581     public override void _Private_ConnectionOpen(
6582       System.String @virtualHost,
6583       System.String @capabilities,
6584       System.Boolean @insist)
6585     {
6586       ConnectionOpen __req = new ConnectionOpen();
6587       __req.m_virtualHost = @virtualHost;
6588       __req.m_capabilities = @capabilities;
6589       __req.m_insist = @insist;
6590       ModelSend(__req,null,null);
6591     }
6592     public override void _Private_ConnectionClose(
6593       System.UInt16 @replyCode,
6594       System.String @replyText,
6595       System.UInt16 @classId,
6596       System.UInt16 @methodId)
6597     {
6598       ConnectionClose __req = new ConnectionClose();
6599       __req.m_replyCode = @replyCode;
6600       __req.m_replyText = @replyText;
6601       __req.m_classId = @classId;
6602       __req.m_methodId = @methodId;
6603       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6604       ConnectionCloseOk __rep = __repBase as ConnectionCloseOk;
6605       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6606     }
6607     public override void _Private_ConnectionCloseOk()
6608     {
6609       ConnectionCloseOk __req = new ConnectionCloseOk();
6610       ModelSend(__req,null,null);
6611     }
6612     public override RabbitMQ.Client.IBasicProperties CreateBasicProperties()
6613     {
6614       return new BasicProperties();
6615     }
6616     public override RabbitMQ.Client.IFileProperties CreateFileProperties()
6617     {
6618       return new FileProperties();
6619     }
6620     public override RabbitMQ.Client.IStreamProperties CreateStreamProperties()
6621     {
6622       return new StreamProperties();
6623     }
6624     public override void ChannelFlow(
6625       System.Boolean @active)
6626     {
6627       ChannelFlow __req = new ChannelFlow();
6628       __req.m_active = @active;
6629       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6630       ChannelFlowOk __rep = __repBase as ChannelFlowOk;
6631       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6632     }
6633     public override void ExchangeDeclare(
6634       System.String @exchange,
6635       System.String @type,
6636       System.Boolean @passive,
6637       System.Boolean @durable,
6638       System.Boolean @autoDelete,
6639       System.Boolean @internal,
6640       System.Boolean @nowait,
6641       System.Collections.IDictionary @arguments)
6642     {
6643       ExchangeDeclare __req = new ExchangeDeclare();
6644       __req.m_exchange = @exchange;
6645       __req.m_type = @type;
6646       __req.m_passive = @passive;
6647       __req.m_durable = @durable;
6648       __req.m_autoDelete = @autoDelete;
6649       __req.m_internal = @internal;
6650       __req.m_nowait = @nowait;
6651       __req.m_arguments = @arguments;
6652       if (nowait) {
6653         ModelSend(__req,null,null);
6654       }
6655       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6656       ExchangeDeclareOk __rep = __repBase as ExchangeDeclareOk;
6657       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6658     }
6659     public override void ExchangeDelete(
6660       System.String @exchange,
6661       System.Boolean @ifUnused,
6662       System.Boolean @nowait)
6663     {
6664       ExchangeDelete __req = new ExchangeDelete();
6665       __req.m_exchange = @exchange;
6666       __req.m_ifUnused = @ifUnused;
6667       __req.m_nowait = @nowait;
6668       if (nowait) {
6669         ModelSend(__req,null,null);
6670       }
6671       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6672       ExchangeDeleteOk __rep = __repBase as ExchangeDeleteOk;
6673       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6674     }
6675     public override System.String QueueDeclare(
6676       System.String @queue,
6677       System.Boolean @passive,
6678       System.Boolean @durable,
6679       System.Boolean @exclusive,
6680       System.Boolean @autoDelete,
6681       System.Boolean @nowait,
6682       System.Collections.IDictionary @arguments)
6683     {
6684       QueueDeclare __req = new QueueDeclare();
6685       __req.m_queue = @queue;
6686       __req.m_passive = @passive;
6687       __req.m_durable = @durable;
6688       __req.m_exclusive = @exclusive;
6689       __req.m_autoDelete = @autoDelete;
6690       __req.m_nowait = @nowait;
6691       __req.m_arguments = @arguments;
6692       if (nowait) {
6693         ModelSend(__req,null,null);
6694         return null;
6695       }
6696       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6697       QueueDeclareOk __rep = __repBase as QueueDeclareOk;
6698       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6699       return __rep.m_queue;
6700     }
6701     public override void QueueBind(
6702       System.String @queue,
6703       System.String @exchange,
6704       System.String @routingKey,
6705       System.Boolean @nowait,
6706       System.Collections.IDictionary @arguments)
6707     {
6708       QueueBind __req = new QueueBind();
6709       __req.m_queue = @queue;
6710       __req.m_exchange = @exchange;
6711       __req.m_routingKey = @routingKey;
6712       __req.m_nowait = @nowait;
6713       __req.m_arguments = @arguments;
6714       if (nowait) {
6715         ModelSend(__req,null,null);
6716       }
6717       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6718       QueueBindOk __rep = __repBase as QueueBindOk;
6719       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6720     }
6721     public override void QueueUnbind(
6722       System.String @queue,
6723       System.String @exchange,
6724       System.String @routingKey,
6725       System.Collections.IDictionary @arguments)
6726     {
6727       QueueUnbind __req = new QueueUnbind();
6728       __req.m_queue = @queue;
6729       __req.m_exchange = @exchange;
6730       __req.m_routingKey = @routingKey;
6731       __req.m_arguments = @arguments;
6732       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6733       QueueUnbindOk __rep = __repBase as QueueUnbindOk;
6734       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6735     }
6736     public override System.UInt32 QueuePurge(
6737       System.String @queue,
6738       System.Boolean @nowait)
6739     {
6740       QueuePurge __req = new QueuePurge();
6741       __req.m_queue = @queue;
6742       __req.m_nowait = @nowait;
6743       if (nowait) {
6744         ModelSend(__req,null,null);
6745         return 0xFFFFFFFF;
6746       }
6747       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6748       QueuePurgeOk __rep = __repBase as QueuePurgeOk;
6749       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6750       return __rep.m_messageCount;
6751     }
6752     public override System.UInt32 QueueDelete(
6753       System.String @queue,
6754       System.Boolean @ifUnused,
6755       System.Boolean @ifEmpty,
6756       System.Boolean @nowait)
6757     {
6758       QueueDelete __req = new QueueDelete();
6759       __req.m_queue = @queue;
6760       __req.m_ifUnused = @ifUnused;
6761       __req.m_ifEmpty = @ifEmpty;
6762       __req.m_nowait = @nowait;
6763       if (nowait) {
6764         ModelSend(__req,null,null);
6765         return 0xFFFFFFFF;
6766       }
6767       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6768       QueueDeleteOk __rep = __repBase as QueueDeleteOk;
6769       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6770       return __rep.m_messageCount;
6771     }
6772     public override void BasicQos(
6773       System.UInt32 @prefetchSize,
6774       System.UInt16 @prefetchCount,
6775       System.Boolean @global)
6776     {
6777       BasicQos __req = new BasicQos();
6778       __req.m_prefetchSize = @prefetchSize;
6779       __req.m_prefetchCount = @prefetchCount;
6780       __req.m_global = @global;
6781       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6782       BasicQosOk __rep = __repBase as BasicQosOk;
6783       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6784     }
6785     public override void BasicAck(
6786       System.UInt64 @deliveryTag,
6787       System.Boolean @multiple)
6788     {
6789       BasicAck __req = new BasicAck();
6790       __req.m_deliveryTag = @deliveryTag;
6791       __req.m_multiple = @multiple;
6792       ModelSend(__req,null,null);
6793     }
6794     public override void BasicReject(
6795       System.UInt64 @deliveryTag,
6796       System.Boolean @requeue)
6797     {
6798       BasicReject __req = new BasicReject();
6799       __req.m_deliveryTag = @deliveryTag;
6800       __req.m_requeue = @requeue;
6801       ModelSend(__req,null,null);
6802     }
6803     public override void BasicRecover(
6804       System.Boolean @requeue)
6805     {
6806       BasicRecover __req = new BasicRecover();
6807       __req.m_requeue = @requeue;
6808       ModelSend(__req,null,null);
6809     }
6810     public override void TxSelect()
6811     {
6812       TxSelect __req = new TxSelect();
6813       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6814       TxSelectOk __rep = __repBase as TxSelectOk;
6815       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6816     }
6817     public override void TxCommit()
6818     {
6819       TxCommit __req = new TxCommit();
6820       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6821       TxCommitOk __rep = __repBase as TxCommitOk;
6822       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6823     }
6824     public override void TxRollback()
6825     {
6826       TxRollback __req = new TxRollback();
6827       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6828       TxRollbackOk __rep = __repBase as TxRollbackOk;
6829       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6830     }
6831     public override void DtxSelect()
6832     {
6833       DtxSelect __req = new DtxSelect();
6834       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6835       DtxSelectOk __rep = __repBase as DtxSelectOk;
6836       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6837     }
6838     public override void DtxStart(
6839       System.String @dtxIdentifier)
6840     {
6841       DtxStart __req = new DtxStart();
6842       __req.m_dtxIdentifier = @dtxIdentifier;
6843       RabbitMQ.Client.Impl.MethodBase __repBase = ModelRpc(__req,null,null);
6844       DtxStartOk __rep = __repBase as DtxStartOk;
6845       if (__rep == null) throw new UnexpectedMethodException(__repBase);
6846     }
6847     public override bool DispatchAsynchronous(RabbitMQ.Client.Impl.Command cmd) {
6848       RabbitMQ.Client.Impl.MethodBase __method = (RabbitMQ.Client.Impl.MethodBase) cmd.Method;
6849       switch ((__method.ProtocolClassId << 16) | __method.ProtocolMethodId) {
6850         case 3932181: {
6851           BasicConsumeOk __impl = (BasicConsumeOk) __method;
6852           HandleBasicConsumeOk(
6853             __impl.m_consumerTag);
6854           return true;
6855         }
6856         case 3932191: {
6857           BasicCancelOk __impl = (BasicCancelOk) __method;
6858           HandleBasicCancelOk(
6859             __impl.m_consumerTag);
6860           return true;
6861         }
6862         case 3932231: {
6863           BasicGetOk __impl = (BasicGetOk) __method;
6864           HandleBasicGetOk(
6865             __impl.m_deliveryTag,
6866             __impl.m_redelivered,
6867             __impl.m_exchange,
6868             __impl.m_routingKey,
6869             __impl.m_messageCount,
6870             (RabbitMQ.Client.IBasicProperties) cmd.Header,
6871             cmd.Body);
6872           return true;
6873         }
6874         case 3932232: {
6875           HandleBasicGetEmpty();
6876           return true;
6877         }
6878         case 3932220: {
6879           BasicDeliver __impl = (BasicDeliver) __method;
6880           HandleBasicDeliver(
6881             __impl.m_consumerTag,
6882             __impl.m_deliveryTag,
6883             __impl.m_redelivered,
6884             __impl.m_exchange,
6885             __impl.m_routingKey,
6886             (RabbitMQ.Client.IBasicProperties) cmd.Header,
6887             cmd.Body);
6888           return true;
6889         }
6890         case 3932210: {
6891           BasicReturn __impl = (BasicReturn) __method;
6892           HandleBasicReturn(
6893             __impl.m_replyCode,
6894             __impl.m_replyText,
6895             __impl.m_exchange,
6896             __impl.m_routingKey,
6897             (RabbitMQ.Client.IBasicProperties) cmd.Header,
6898             cmd.Body);
6899           return true;
6900         }
6901         case 1310740: {
6902           ChannelFlow __impl = (ChannelFlow) __method;
6903           HandleChannelFlow(
6904             __impl.m_active);
6905           return true;
6906         }
6907         case 1310760: {
6908           ChannelClose __impl = (ChannelClose) __method;
6909           HandleChannelClose(
6910             __impl.m_replyCode,
6911             __impl.m_replyText,
6912             __impl.m_classId,
6913             __impl.m_methodId);
6914           return true;
6915         }
6916         case 1310761: {
6917           HandleChannelCloseOk();
6918           return true;
6919         }
6920         case 655370: {
6921           ConnectionStart __impl = (ConnectionStart) __method;
6922           HandleConnectionStart(
6923             __impl.m_versionMajor,
6924             __impl.m_versionMinor,
6925             __impl.m_serverProperties,
6926             __impl.m_mechanisms,
6927             __impl.m_locales);
6928           return true;
6929         }
6930         case 655401: {
6931           ConnectionOpenOk __impl = (ConnectionOpenOk) __method;
6932           HandleConnectionOpenOk(
6933             __impl.m_knownHosts);
6934           return true;
6935         }
6936         case 655402: {
6937           ConnectionRedirect __impl = (ConnectionRedirect) __method;
6938           HandleConnectionRedirect(
6939             __impl.m_host,
6940             __impl.m_knownHosts);
6941           return true;
6942         }
6943         case 655410: {
6944           ConnectionClose __impl = (ConnectionClose) __method;
6945           HandleConnectionClose(
6946             __impl.m_replyCode,
6947             __impl.m_replyText,
6948             __impl.m_classId,
6949             __impl.m_methodId);
6950           return true;
6951         }
6952         default: return false;
6953       }
6954     }
6955   }
6956 }