@@ -41,9 +41,9 @@ namespace RabbitMQ.Client
41
41
{
42
42
public AsyncDefaultBasicConsumer() { }
43
43
public AsyncDefaultBasicConsumer(RabbitMQ.Client.IChannel channel) { }
44
+ public RabbitMQ.Client.IChannel Channel { get; set; }
44
45
public string[] ConsumerTags { get; }
45
46
public bool IsRunning { get; set; }
46
- public RabbitMQ.Client.IChannel Channel { get; set; }
47
47
public RabbitMQ.Client.ShutdownEventArgs ShutdownReason { get; set; }
48
48
public event RabbitMQ.Client.Events.AsyncEventHandler<RabbitMQ.Client.Events.ConsumerEventArgs> ConsumerCancelled;
49
49
public virtual System.Threading.Tasks.Task HandleBasicCancel(string consumerTag) { }
@@ -235,9 +235,9 @@ namespace RabbitMQ.Client
235
235
{
236
236
public DefaultBasicConsumer() { }
237
237
public DefaultBasicConsumer(RabbitMQ.Client.IChannel channel) { }
238
+ public RabbitMQ.Client.IChannel Channel { get; set; }
238
239
public string[] ConsumerTags { get; }
239
240
public bool IsRunning { get; set; }
240
- public RabbitMQ.Client.IChannel Channel { get; set; }
241
241
public RabbitMQ.Client.ShutdownEventArgs ShutdownReason { get; set; }
242
242
public event System.EventHandler<RabbitMQ.Client.Events.ConsumerEventArgs> ConsumerCancelled;
243
243
public virtual void HandleBasicCancel(string consumerTag) { }
@@ -371,70 +371,6 @@ namespace RabbitMQ.Client
371
371
void ClearType();
372
372
void ClearUserId();
373
373
}
374
- public interface IConnection : RabbitMQ.Client.INetworkConnection, System.IDisposable
375
- {
376
- ushort ChannelMax { get; }
377
- System.Collections.Generic.IDictionary<string, object> ClientProperties { get; }
378
- string ClientProvidedName { get; }
379
- RabbitMQ.Client.ShutdownEventArgs CloseReason { get; }
380
- RabbitMQ.Client.AmqpTcpEndpoint Endpoint { get; }
381
- uint FrameMax { get; }
382
- System.TimeSpan Heartbeat { get; }
383
- bool IsOpen { get; }
384
- RabbitMQ.Client.IProtocol Protocol { get; }
385
- System.Collections.Generic.IDictionary<string, object> ServerProperties { get; }
386
- System.Collections.Generic.IList<RabbitMQ.Client.ShutdownReportEntry> ShutdownReport { get; }
387
- event System.EventHandler<RabbitMQ.Client.Events.CallbackExceptionEventArgs> CallbackException;
388
- event System.EventHandler<RabbitMQ.Client.Events.ConnectionBlockedEventArgs> ConnectionBlocked;
389
- event System.EventHandler<RabbitMQ.Client.Events.ConnectionRecoveryErrorEventArgs> ConnectionRecoveryError;
390
- event System.EventHandler<RabbitMQ.Client.ShutdownEventArgs> ConnectionShutdown;
391
- event System.EventHandler<System.EventArgs> ConnectionUnblocked;
392
- event System.EventHandler<RabbitMQ.Client.Events.ConsumerTagChangedAfterRecoveryEventArgs> ConsumerTagChangeAfterRecovery;
393
- event System.EventHandler<RabbitMQ.Client.Events.QueueNameChangedAfterRecoveryEventArgs> QueueNameChangeAfterRecovery;
394
- event System.EventHandler<RabbitMQ.Client.Events.RecoveringConsumerEventArgs> RecoveringConsumer;
395
- event System.EventHandler<System.EventArgs> RecoverySucceeded;
396
- void Close(ushort reasonCode, string reasonText, System.TimeSpan timeout, bool abort);
397
- RabbitMQ.Client.IChannel CreateChannel();
398
- void UpdateSecret(string newSecret, string reason);
399
- }
400
- public static class IConnectionExtensions
401
- {
402
- public static void Abort(this RabbitMQ.Client.IConnection connection) { }
403
- public static void Abort(this RabbitMQ.Client.IConnection connection, System.TimeSpan timeout) { }
404
- public static void Abort(this RabbitMQ.Client.IConnection connection, ushort reasonCode, string reasonText) { }
405
- public static void Abort(this RabbitMQ.Client.IConnection connection, ushort reasonCode, string reasonText, System.TimeSpan timeout) { }
406
- public static void Close(this RabbitMQ.Client.IConnection connection) { }
407
- public static void Close(this RabbitMQ.Client.IConnection connection, System.TimeSpan timeout) { }
408
- public static void Close(this RabbitMQ.Client.IConnection connection, ushort reasonCode, string reasonText) { }
409
- public static void Close(this RabbitMQ.Client.IConnection connection, ushort reasonCode, string reasonText, System.TimeSpan timeout) { }
410
- }
411
- public interface IConnectionFactory
412
- {
413
- System.Collections.Generic.IDictionary<string, object> ClientProperties { get; set; }
414
- string ClientProvidedName { get; set; }
415
- int ConsumerDispatchConcurrency { get; set; }
416
- System.TimeSpan ContinuationTimeout { get; set; }
417
- bool DispatchConsumersAsync { get; set; }
418
- System.TimeSpan HandshakeContinuationTimeout { get; set; }
419
- string Password { get; set; }
420
- ushort RequestedChannelMax { get; set; }
421
- uint RequestedFrameMax { get; set; }
422
- System.TimeSpan RequestedHeartbeat { get; set; }
423
- System.Uri Uri { get; set; }
424
- string UserName { get; set; }
425
- string VirtualHost { get; set; }
426
- RabbitMQ.Client.IAuthMechanismFactory AuthMechanismFactory(System.Collections.Generic.IList<string> mechanismNames);
427
- RabbitMQ.Client.IConnection CreateConnection();
428
- RabbitMQ.Client.IConnection CreateConnection(System.Collections.Generic.IList<RabbitMQ.Client.AmqpTcpEndpoint> endpoints);
429
- RabbitMQ.Client.IConnection CreateConnection(System.Collections.Generic.IList<string> hostnames);
430
- RabbitMQ.Client.IConnection CreateConnection(string clientProvidedName);
431
- RabbitMQ.Client.IConnection CreateConnection(System.Collections.Generic.IList<RabbitMQ.Client.AmqpTcpEndpoint> endpoints, string clientProvidedName);
432
- RabbitMQ.Client.IConnection CreateConnection(System.Collections.Generic.IList<string> hostnames, string clientProvidedName);
433
- }
434
- public interface IEndpointResolver
435
- {
436
- System.Collections.Generic.IEnumerable<RabbitMQ.Client.AmqpTcpEndpoint> All();
437
- }
438
374
public interface IChannel : System.IDisposable
439
375
{
440
376
int ChannelNumber { get; }
@@ -449,8 +385,8 @@ namespace RabbitMQ.Client
449
385
event System.EventHandler<System.EventArgs> BasicRecoverOk;
450
386
event System.EventHandler<RabbitMQ.Client.Events.BasicReturnEventArgs> BasicReturn;
451
387
event System.EventHandler<RabbitMQ.Client.Events.CallbackExceptionEventArgs> CallbackException;
452
- event System.EventHandler<RabbitMQ.Client.Events.FlowControlEventArgs> FlowControl;
453
388
event System.EventHandler<RabbitMQ.Client.ShutdownEventArgs> ChannelShutdown;
389
+ event System.EventHandler<RabbitMQ.Client.Events.FlowControlEventArgs> FlowControl;
454
390
void BasicAck(ulong deliveryTag, bool multiple);
455
391
void BasicCancel(string consumerTag);
456
392
void BasicCancelNoWait(string consumerTag);
@@ -520,6 +456,70 @@ namespace RabbitMQ.Client
520
456
public static void QueueDeleteNoWait(this RabbitMQ.Client.IChannel channel, string queue, bool ifUnused = false, bool ifEmpty = false) { }
521
457
public static void QueueUnbind(this RabbitMQ.Client.IChannel channel, string queue, string exchange, string routingKey, System.Collections.Generic.IDictionary<string, object> arguments = null) { }
522
458
}
459
+ public interface IConnection : RabbitMQ.Client.INetworkConnection, System.IDisposable
460
+ {
461
+ ushort ChannelMax { get; }
462
+ System.Collections.Generic.IDictionary<string, object> ClientProperties { get; }
463
+ string ClientProvidedName { get; }
464
+ RabbitMQ.Client.ShutdownEventArgs CloseReason { get; }
465
+ RabbitMQ.Client.AmqpTcpEndpoint Endpoint { get; }
466
+ uint FrameMax { get; }
467
+ System.TimeSpan Heartbeat { get; }
468
+ bool IsOpen { get; }
469
+ RabbitMQ.Client.IProtocol Protocol { get; }
470
+ System.Collections.Generic.IDictionary<string, object> ServerProperties { get; }
471
+ System.Collections.Generic.IList<RabbitMQ.Client.ShutdownReportEntry> ShutdownReport { get; }
472
+ event System.EventHandler<RabbitMQ.Client.Events.CallbackExceptionEventArgs> CallbackException;
473
+ event System.EventHandler<RabbitMQ.Client.Events.ConnectionBlockedEventArgs> ConnectionBlocked;
474
+ event System.EventHandler<RabbitMQ.Client.Events.ConnectionRecoveryErrorEventArgs> ConnectionRecoveryError;
475
+ event System.EventHandler<RabbitMQ.Client.ShutdownEventArgs> ConnectionShutdown;
476
+ event System.EventHandler<System.EventArgs> ConnectionUnblocked;
477
+ event System.EventHandler<RabbitMQ.Client.Events.ConsumerTagChangedAfterRecoveryEventArgs> ConsumerTagChangeAfterRecovery;
478
+ event System.EventHandler<RabbitMQ.Client.Events.QueueNameChangedAfterRecoveryEventArgs> QueueNameChangeAfterRecovery;
479
+ event System.EventHandler<RabbitMQ.Client.Events.RecoveringConsumerEventArgs> RecoveringConsumer;
480
+ event System.EventHandler<System.EventArgs> RecoverySucceeded;
481
+ void Close(ushort reasonCode, string reasonText, System.TimeSpan timeout, bool abort);
482
+ RabbitMQ.Client.IChannel CreateChannel();
483
+ void UpdateSecret(string newSecret, string reason);
484
+ }
485
+ public static class IConnectionExtensions
486
+ {
487
+ public static void Abort(this RabbitMQ.Client.IConnection connection) { }
488
+ public static void Abort(this RabbitMQ.Client.IConnection connection, System.TimeSpan timeout) { }
489
+ public static void Abort(this RabbitMQ.Client.IConnection connection, ushort reasonCode, string reasonText) { }
490
+ public static void Abort(this RabbitMQ.Client.IConnection connection, ushort reasonCode, string reasonText, System.TimeSpan timeout) { }
491
+ public static void Close(this RabbitMQ.Client.IConnection connection) { }
492
+ public static void Close(this RabbitMQ.Client.IConnection connection, System.TimeSpan timeout) { }
493
+ public static void Close(this RabbitMQ.Client.IConnection connection, ushort reasonCode, string reasonText) { }
494
+ public static void Close(this RabbitMQ.Client.IConnection connection, ushort reasonCode, string reasonText, System.TimeSpan timeout) { }
495
+ }
496
+ public interface IConnectionFactory
497
+ {
498
+ System.Collections.Generic.IDictionary<string, object> ClientProperties { get; set; }
499
+ string ClientProvidedName { get; set; }
500
+ int ConsumerDispatchConcurrency { get; set; }
501
+ System.TimeSpan ContinuationTimeout { get; set; }
502
+ bool DispatchConsumersAsync { get; set; }
503
+ System.TimeSpan HandshakeContinuationTimeout { get; set; }
504
+ string Password { get; set; }
505
+ ushort RequestedChannelMax { get; set; }
506
+ uint RequestedFrameMax { get; set; }
507
+ System.TimeSpan RequestedHeartbeat { get; set; }
508
+ System.Uri Uri { get; set; }
509
+ string UserName { get; set; }
510
+ string VirtualHost { get; set; }
511
+ RabbitMQ.Client.IAuthMechanismFactory AuthMechanismFactory(System.Collections.Generic.IList<string> mechanismNames);
512
+ RabbitMQ.Client.IConnection CreateConnection();
513
+ RabbitMQ.Client.IConnection CreateConnection(System.Collections.Generic.IList<RabbitMQ.Client.AmqpTcpEndpoint> endpoints);
514
+ RabbitMQ.Client.IConnection CreateConnection(System.Collections.Generic.IList<string> hostnames);
515
+ RabbitMQ.Client.IConnection CreateConnection(string clientProvidedName);
516
+ RabbitMQ.Client.IConnection CreateConnection(System.Collections.Generic.IList<RabbitMQ.Client.AmqpTcpEndpoint> endpoints, string clientProvidedName);
517
+ RabbitMQ.Client.IConnection CreateConnection(System.Collections.Generic.IList<string> hostnames, string clientProvidedName);
518
+ }
519
+ public interface IEndpointResolver
520
+ {
521
+ System.Collections.Generic.IEnumerable<RabbitMQ.Client.AmqpTcpEndpoint> All();
522
+ }
523
523
public interface INetworkConnection
524
524
{
525
525
int LocalPort { get; }
@@ -951,4 +951,4 @@ namespace RabbitMQ.Client.Logging
951
951
public string Type { get; }
952
952
public override string ToString() { }
953
953
}
954
- }
954
+ }
0 commit comments