@@ -41,9 +41,9 @@ namespace RabbitMQ.Client
4141 {
4242 public AsyncDefaultBasicConsumer() { }
4343 public AsyncDefaultBasicConsumer(RabbitMQ.Client.IChannel channel) { }
44+ public RabbitMQ.Client.IChannel Channel { get; set; }
4445 public string[] ConsumerTags { get; }
4546 public bool IsRunning { get; set; }
46- public RabbitMQ.Client.IChannel Channel { get; set; }
4747 public RabbitMQ.Client.ShutdownEventArgs ShutdownReason { get; set; }
4848 public event RabbitMQ.Client.Events.AsyncEventHandler<RabbitMQ.Client.Events.ConsumerEventArgs> ConsumerCancelled;
4949 public virtual System.Threading.Tasks.Task HandleBasicCancel(string consumerTag) { }
@@ -235,9 +235,9 @@ namespace RabbitMQ.Client
235235 {
236236 public DefaultBasicConsumer() { }
237237 public DefaultBasicConsumer(RabbitMQ.Client.IChannel channel) { }
238+ public RabbitMQ.Client.IChannel Channel { get; set; }
238239 public string[] ConsumerTags { get; }
239240 public bool IsRunning { get; set; }
240- public RabbitMQ.Client.IChannel Channel { get; set; }
241241 public RabbitMQ.Client.ShutdownEventArgs ShutdownReason { get; set; }
242242 public event System.EventHandler<RabbitMQ.Client.Events.ConsumerEventArgs> ConsumerCancelled;
243243 public virtual void HandleBasicCancel(string consumerTag) { }
@@ -371,70 +371,6 @@ namespace RabbitMQ.Client
371371 void ClearType();
372372 void ClearUserId();
373373 }
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- }
438374 public interface IChannel : System.IDisposable
439375 {
440376 int ChannelNumber { get; }
@@ -449,8 +385,8 @@ namespace RabbitMQ.Client
449385 event System.EventHandler<System.EventArgs> BasicRecoverOk;
450386 event System.EventHandler<RabbitMQ.Client.Events.BasicReturnEventArgs> BasicReturn;
451387 event System.EventHandler<RabbitMQ.Client.Events.CallbackExceptionEventArgs> CallbackException;
452- event System.EventHandler<RabbitMQ.Client.Events.FlowControlEventArgs> FlowControl;
453388 event System.EventHandler<RabbitMQ.Client.ShutdownEventArgs> ChannelShutdown;
389+ event System.EventHandler<RabbitMQ.Client.Events.FlowControlEventArgs> FlowControl;
454390 void BasicAck(ulong deliveryTag, bool multiple);
455391 void BasicCancel(string consumerTag);
456392 void BasicCancelNoWait(string consumerTag);
@@ -520,6 +456,70 @@ namespace RabbitMQ.Client
520456 public static void QueueDeleteNoWait(this RabbitMQ.Client.IChannel channel, string queue, bool ifUnused = false, bool ifEmpty = false) { }
521457 public static void QueueUnbind(this RabbitMQ.Client.IChannel channel, string queue, string exchange, string routingKey, System.Collections.Generic.IDictionary<string, object> arguments = null) { }
522458 }
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+ }
523523 public interface INetworkConnection
524524 {
525525 int LocalPort { get; }
@@ -951,4 +951,4 @@ namespace RabbitMQ.Client.Logging
951951 public string Type { get; }
952952 public override string ToString() { }
953953 }
954- }
954+ }
0 commit comments