@@ -185,7 +185,7 @@ public interface IModel : IDisposable
185
185
void Abort ( ushort replyCode , string replyText ) ;
186
186
187
187
/// <summary>
188
- /// (Spec method) Acknowledge one or more delivered message(s).
188
+ /// Acknowledge one or more delivered message(s).
189
189
/// </summary>
190
190
void BasicAck ( ulong deliveryTag , bool multiple ) ;
191
191
@@ -235,7 +235,7 @@ string BasicConsume(string queue,
235
235
IBasicConsumer consumer ) ;
236
236
237
237
/// <summary>
238
- /// (Spec method) Retrieve an individual message, if
238
+ /// Retrieve an individual message, if
239
239
/// one is available; returns null if the server answers that
240
240
/// no messages are currently available. See also <see cref="IModel.BasicAck"/>.
241
241
/// </summary>
@@ -246,7 +246,7 @@ string BasicConsume(string queue,
246
246
void BasicNack ( ulong deliveryTag , bool multiple , bool requeue ) ;
247
247
248
248
/// <summary>
249
- /// (Spec method) Convenience overload of BasicPublish.
249
+ /// Convenience overload of BasicPublish.
250
250
/// </summary>
251
251
/// <remarks>
252
252
/// The publication occurs with mandatory=false and immediate=false.
@@ -255,7 +255,7 @@ string BasicConsume(string queue,
255
255
void BasicPublish ( PublicationAddress addr , IBasicProperties basicProperties , byte [ ] body ) ;
256
256
257
257
/// <summary>
258
- /// (Spec method) Convenience overload of BasicPublish.
258
+ /// Convenience overload of BasicPublish.
259
259
/// </summary>
260
260
/// <remarks>
261
261
/// The publication occurs with mandatory=false
@@ -264,14 +264,14 @@ string BasicConsume(string queue,
264
264
void BasicPublish ( string exchange , string routingKey , IBasicProperties basicProperties , byte [ ] body ) ;
265
265
266
266
/// <summary>
267
- /// (Spec method) Convenience overload of BasicPublish.
267
+ /// Convenience overload of BasicPublish.
268
268
/// </summary>
269
269
[ AmqpMethodDoNotImplement ( null ) ]
270
270
void BasicPublish ( string exchange , string routingKey , bool mandatory ,
271
271
IBasicProperties basicProperties , byte [ ] body ) ;
272
272
273
273
/// <summary>
274
- /// (Spec method) Configures QoS parameters of the Basic content-class.
274
+ /// Configures QoS parameters of the Basic content-class.
275
275
/// </summary>
276
276
void BasicQos ( uint prefetchSize , ushort prefetchCount , bool global ) ;
277
277
@@ -286,7 +286,7 @@ void BasicPublish(string exchange, string routingKey, bool mandatory,
286
286
/// </summary>
287
287
void BasicRecoverAsync ( bool requeue ) ;
288
288
289
- /// <summary>(Spec method) Reject a delivered message.</summary>
289
+ /// <summary>Reject a delivered message.</summary>
290
290
void BasicReject ( ulong deliveryTag , bool requeue ) ;
291
291
292
292
/// <summary>Close this session.</summary>
@@ -327,24 +327,39 @@ void BasicPublish(string exchange, string routingKey, bool mandatory,
327
327
IBasicProperties CreateBasicProperties ( ) ;
328
328
329
329
/// <summary>
330
- /// (Extension method) Bind an exchange to an exchange.
330
+ /// Bind an exchange to an exchange.
331
331
/// </summary>
332
+ /// <remarks>
333
+ /// <para>
334
+ /// Routing key must be shorter than 255 bytes.
335
+ /// </para>
336
+ /// </remarks>
332
337
[ AmqpMethodDoNotImplement ( null ) ]
333
338
void ExchangeBind ( string destination , string source , string routingKey , IDictionary < string , object > arguments ) ;
334
339
335
340
/// <summary>
336
- /// (Extension method) Bind an exchange to an exchange.
341
+ /// Bind an exchange to an exchange.
337
342
/// </summary>
343
+ /// <remarks>
344
+ /// <para>
345
+ /// Routing key must be shorter than 255 bytes.
346
+ /// </para>
347
+ /// </remarks>
338
348
[ AmqpMethodDoNotImplement ( null ) ]
339
349
void ExchangeBind ( string destination , string source , string routingKey ) ;
340
350
341
351
/// <summary>
342
- ///Like ExchangeBind but sets nowait to true.
352
+ /// Like ExchangeBind but sets nowait to true.
343
353
/// </summary>
354
+ /// <remarks>
355
+ /// <para>
356
+ /// Routing key must be shorter than 255 bytes.
357
+ /// </para>
358
+ /// </remarks>
344
359
void ExchangeBindNoWait ( string destination , string source , string routingKey ,
345
360
IDictionary < string , object > arguments ) ;
346
361
347
- /// <summary>(Spec method) Declare an exchange.</summary>
362
+ /// <summary>Declare an exchange.</summary>
348
363
/// <remarks>
349
364
/// The exchange is declared non-passive and non-internal.
350
365
/// The "nowait" option is not exercised.
@@ -354,7 +369,7 @@ void ExchangeDeclare(string exchange, string type, bool durable, bool autoDelete
354
369
IDictionary < string , object > arguments ) ;
355
370
356
371
/// <summary>
357
- /// (Spec method) Declare an exchange.
372
+ /// Declare an exchange.
358
373
/// </summary>
359
374
/// <remarks>
360
375
/// The exchange is declared non-passive, non-autodelete, and
@@ -364,7 +379,7 @@ void ExchangeDeclare(string exchange, string type, bool durable, bool autoDelete
364
379
void ExchangeDeclare ( string exchange , string type , bool durable ) ;
365
380
366
381
/// <summary>
367
- /// (Spec method) Declare an exchange.
382
+ /// Declare an exchange.
368
383
/// </summary>
369
384
/// <remarks>
370
385
/// The exchange is declared non-passive, non-durable, non-autodelete, and
@@ -381,7 +396,7 @@ void ExchangeDeclareNoWait(string exchange, string type, bool durable, bool auto
381
396
IDictionary < string , object > arguments ) ;
382
397
383
398
/// <summary>
384
- /// (Spec method) Declare an exchange.
399
+ /// Declare an exchange.
385
400
/// </summary>
386
401
/// <remarks>
387
402
/// The exchange is declared passive.
@@ -390,12 +405,12 @@ void ExchangeDeclareNoWait(string exchange, string type, bool durable, bool auto
390
405
void ExchangeDeclarePassive ( string exchange ) ;
391
406
392
407
/// <summary>
393
- /// (Spec method) Delete an exchange.
408
+ /// Delete an exchange.
394
409
/// </summary>
395
410
[ AmqpMethodDoNotImplement ( null ) ]
396
411
void ExchangeDelete ( string exchange , bool ifUnused ) ;
397
412
398
- /// <summary>(Spec method) Delete an exchange.</summary>
413
+ /// <summary>Delete an exchange.</summary>
399
414
/// <remarks>
400
415
/// The exchange is deleted regardless of any queue bindings.
401
416
/// </remarks>
@@ -408,17 +423,27 @@ void ExchangeDeclareNoWait(string exchange, string type, bool durable, bool auto
408
423
void ExchangeDeleteNoWait ( string exchange , bool ifUnused ) ;
409
424
410
425
/// <summary>
411
- /// (Extension method) Unbind an exchange from an exchange.
426
+ /// Unbind an exchange from an exchange.
412
427
/// </summary>
428
+ /// <remarks>
429
+ /// <para>
430
+ /// Routing key must be shorter than 255 bytes.
431
+ /// </para>
432
+ /// </remarks>
413
433
[ AmqpMethodDoNotImplement ( null ) ]
414
434
void ExchangeUnbind ( string destination ,
415
435
string source ,
416
436
string routingKey ,
417
437
IDictionary < string , object > arguments ) ;
418
438
419
439
/// <summary>
420
- /// (Extension method) Unbind an exchange from an exchange.
440
+ /// Unbind an exchange from an exchange.
421
441
/// </summary>
442
+ /// <remarks>
443
+ /// <para>
444
+ /// Routing key must be shorter than 255 bytes.
445
+ /// </para>
446
+ /// </remarks>
422
447
[ AmqpMethodDoNotImplement ( null ) ]
423
448
void ExchangeUnbind ( string destination , string source , string routingKey ) ;
424
449
@@ -430,19 +455,34 @@ void ExchangeUnbindNoWait(string destination, string source, string routingKey,
430
455
IDictionary < string , object > arguments ) ;
431
456
432
457
/// <summary>
433
- /// (Spec method) Bind a queue to an exchange.
458
+ /// Bind a queue to an exchange.
434
459
/// </summary>
460
+ /// <remarks>
461
+ /// <para>
462
+ /// Routing key must be shorter than 255 bytes.
463
+ /// </para>
464
+ /// </remarks>
435
465
[ AmqpMethodDoNotImplement ( null ) ]
436
466
void QueueBind ( string queue , string exchange , string routingKey , IDictionary < string , object > arguments ) ;
437
467
438
- /// <summary>(Spec method) Bind a queue to an exchange.</summary>
468
+ /// <summary>Bind a queue to an exchange.</summary>
469
+ /// <remarks>
470
+ /// <para>
471
+ /// Routing key must be shorter than 255 bytes.
472
+ /// </para>
473
+ /// </remarks>
439
474
[ AmqpMethodDoNotImplement ( null ) ]
440
475
void QueueBind ( string queue , string exchange , string routingKey ) ;
441
476
442
477
/// <summary>Same as QueueBind but sets nowait parameter to true.</summary>
478
+ /// <remarks>
479
+ /// <para>
480
+ /// Routing key must be shorter than 255 bytes.
481
+ /// </para>
482
+ /// </remarks>
443
483
void QueueBindNoWait ( string queue , string exchange , string routingKey , IDictionary < string , object > arguments ) ;
444
484
445
- /// <summary>(Spec method) Declare a queue.</summary>
485
+ /// <summary>Declare a queue.</summary>
446
486
/// <remarks>
447
487
/// The queue is declared non-passive, non-durable,
448
488
/// but exclusive and autodelete, with no arguments. The
@@ -451,7 +491,7 @@ void ExchangeUnbindNoWait(string destination, string source, string routingKey,
451
491
[ AmqpMethodDoNotImplement ( null ) ]
452
492
QueueDeclareOk QueueDeclare ( ) ;
453
493
454
- /// <summary>(Spec method) Declare a queue.</summary>
494
+ /// <summary>Declare a queue.</summary>
455
495
[ AmqpMethodDoNotImplement ( null ) ]
456
496
QueueDeclareOk QueueDeclare ( string queue , bool durable , bool exclusive ,
457
497
bool autoDelete , IDictionary < string , object > arguments ) ;
@@ -491,7 +531,7 @@ void QueueDeclareNoWait(string queue, bool durable, bool exclusive,
491
531
uint ConsumerCount ( string queue ) ;
492
532
493
533
/// <summary>
494
- /// (Spec method) Delete a queue.
534
+ /// Delete a queue.
495
535
/// </summary>
496
536
/// <remarks>
497
537
///Returns the number of messages purged during queue deletion.
@@ -501,7 +541,7 @@ void QueueDeclareNoWait(string queue, bool durable, bool exclusive,
501
541
uint QueueDelete ( string queue , bool ifUnused , bool ifEmpty ) ;
502
542
503
543
/// <summary>
504
- /// (Spec method) Delete a queue.
544
+ /// Delete a queue.
505
545
/// </summary>
506
546
/// <remarks>
507
547
///Returns the number of messages purged during queue deletion.
@@ -516,7 +556,7 @@ void QueueDeclareNoWait(string queue, bool durable, bool exclusive,
516
556
void QueueDeleteNoWait ( string queue , bool ifUnused , bool ifEmpty ) ;
517
557
518
558
/// <summary>
519
- /// (Spec method) Purge a queue of messages.
559
+ /// Purge a queue of messages.
520
560
/// </summary>
521
561
/// <remarks>
522
562
/// Returns the number of messages purged.
@@ -525,22 +565,22 @@ void QueueDeclareNoWait(string queue, bool durable, bool exclusive,
525
565
uint QueuePurge ( string queue ) ;
526
566
527
567
/// <summary>
528
- /// (Spec method) Unbind a queue from an exchange.
568
+ /// Unbind a queue from an exchange.
529
569
/// </summary>
530
570
void QueueUnbind ( string queue , string exchange , string routingKey , IDictionary < string , object > arguments ) ;
531
571
532
572
/// <summary>
533
- /// (Spec method) Commit this session's active TX transaction.
573
+ /// Commit this session's active TX transaction.
534
574
/// </summary>
535
575
void TxCommit ( ) ;
536
576
537
577
/// <summary>
538
- /// (Spec method) Roll back this session's active TX transaction.
578
+ /// Roll back this session's active TX transaction.
539
579
/// </summary>
540
580
void TxRollback ( ) ;
541
581
542
582
/// <summary>
543
- /// (Spec method) Enable TX mode for this session.
583
+ /// Enable TX mode for this session.
544
584
/// </summary>
545
585
void TxSelect ( ) ;
546
586
0 commit comments