Class RabbitAdmin
Inheritance
System.Object
RabbitAdmin
Implements
IServiceNameAware
Assembly: Steeltoe.Messaging.RabbitMQ.dll
Syntax
public class RabbitAdmin : object, IRabbitAdmin, IConnectionListener
Constructors
|
Edit this page
View Source
RabbitAdmin(IApplicationContext, IConnectionFactory, ILogger)
Declaration
public RabbitAdmin(IApplicationContext applicationContext, IConnectionFactory connectionFactory, ILogger logger = null)
Parameters
Type |
Name |
Description |
IApplicationContext |
applicationContext |
|
IConnectionFactory |
connectionFactory |
|
ILogger |
logger |
|
|
Edit this page
View Source
RabbitAdmin(IConnectionFactory, ILogger)
Declaration
public RabbitAdmin(IConnectionFactory connectionFactory, ILogger logger = null)
Parameters
|
Edit this page
View Source
RabbitAdmin(RabbitTemplate, ILogger)
Declaration
public RabbitAdmin(RabbitTemplate template, ILogger logger = null)
Parameters
Fields
|
Edit this page
View Source
DEFAULT_SERVICE_NAME
Declaration
public const string DEFAULT_SERVICE_NAME = null
Field Value
Type |
Description |
System.String |
|
|
Edit this page
View Source
QUEUE_CONSUMER_COUNT
Declaration
public const string QUEUE_CONSUMER_COUNT = null
Field Value
Type |
Description |
System.String |
|
|
Edit this page
View Source
QUEUE_MESSAGE_COUNT
Declaration
public const string QUEUE_MESSAGE_COUNT = null
Field Value
Type |
Description |
System.String |
|
|
Edit this page
View Source
QUEUE_NAME
Declaration
public const string QUEUE_NAME = null
Field Value
Type |
Description |
System.String |
|
Properties
|
Edit this page
View Source
ApplicationContext
Declaration
public IApplicationContext ApplicationContext { get; set; }
Property Value
Type |
Description |
IApplicationContext |
|
|
Edit this page
View Source
AutoStartup
Declaration
public bool AutoStartup { get; set; }
Property Value
Type |
Description |
System.Boolean |
|
|
Edit this page
View Source
ConnectionFactory
Declaration
public IConnectionFactory ConnectionFactory { get; set; }
Property Value
|
Edit this page
View Source
ExplicitDeclarationsOnly
Declaration
public bool ExplicitDeclarationsOnly { get; set; }
Property Value
Type |
Description |
System.Boolean |
|
|
Edit this page
View Source
IgnoreDeclarationExceptions
Declaration
public bool IgnoreDeclarationExceptions { get; set; }
Property Value
Type |
Description |
System.Boolean |
|
|
Edit this page
View Source
IsAutoStartup
Declaration
public bool IsAutoStartup { get; set; }
Property Value
Type |
Description |
System.Boolean |
|
|
Edit this page
View Source
IsRunning
Declaration
public bool IsRunning { get; }
Property Value
Type |
Description |
System.Boolean |
|
|
Edit this page
View Source
LastDeclarationExceptionEvent
Declaration
public DeclarationExceptionEvent LastDeclarationExceptionEvent { get; }
Property Value
|
Edit this page
View Source
RabbitTemplate
Declaration
public RabbitTemplate RabbitTemplate { get; }
Property Value
|
Edit this page
View Source
RetryDisabled
Declaration
public bool RetryDisabled { get; set; }
Property Value
Type |
Description |
System.Boolean |
|
|
Edit this page
View Source
RetryTemplate
Declaration
public RetryTemplate RetryTemplate { get; set; }
Property Value
Type |
Description |
RetryTemplate |
|
|
Edit this page
View Source
ServiceName
Declaration
public string ServiceName { get; set; }
Property Value
Type |
Description |
System.String |
|
Methods
|
Edit this page
View Source
DeclareBinding(IBinding)
Declaration
public void DeclareBinding(IBinding binding)
Parameters
|
Edit this page
View Source
DeclareExchange(IExchange)
Declaration
public void DeclareExchange(IExchange exchange)
Parameters
|
Edit this page
View Source
DeclareQueue()
Declaration
public IQueue DeclareQueue()
Returns
|
Edit this page
View Source
DeclareQueue(IQueue)
Declaration
public string DeclareQueue(IQueue queue)
Parameters
Type |
Name |
Description |
IQueue |
queue |
|
Returns
Type |
Description |
System.String |
|
|
Edit this page
View Source
DeleteExchange(String)
Declaration
public bool DeleteExchange(string exchangeName)
Parameters
Type |
Name |
Description |
System.String |
exchangeName |
|
Returns
Type |
Description |
System.Boolean |
|
|
Edit this page
View Source
DeleteQueue(String)
Declaration
public bool DeleteQueue(string queueName)
Parameters
Type |
Name |
Description |
System.String |
queueName |
|
Returns
Type |
Description |
System.Boolean |
|
|
Edit this page
View Source
DeleteQueue(String, Boolean, Boolean)
Declaration
public void DeleteQueue(string queueName, bool unused, bool empty)
Parameters
Type |
Name |
Description |
System.String |
queueName |
|
System.Boolean |
unused |
|
System.Boolean |
empty |
|
|
Edit this page
View Source
GetQueueInfo(String)
Declaration
public QueueInformation GetQueueInfo(string queueName)
Parameters
Type |
Name |
Description |
System.String |
queueName |
|
Returns
|
Edit this page
View Source
GetQueueProperties(String)
Declaration
public Dictionary<string, object> GetQueueProperties(string queueName)
Parameters
Type |
Name |
Description |
System.String |
queueName |
|
Returns
Type |
Description |
Dictionary<System.String, System.Object> |
|
|
Edit this page
View Source
Initialize()
Declaration
|
Edit this page
View Source
OnClose(IConnection)
Declaration
public void OnClose(IConnection connection)
Parameters
|
Edit this page
View Source
OnCreate(IConnection)
Declaration
public void OnCreate(IConnection connection)
Parameters
|
Edit this page
View Source
OnShutDown(RabbitMQ.Client.ShutdownEventArgs)
Declaration
public void OnShutDown(RabbitMQ.Client.ShutdownEventArgs args)
Parameters
Type |
Name |
Description |
RabbitMQ.Client.ShutdownEventArgs |
args |
|
|
Edit this page
View Source
PurgeQueue(String)
Declaration
public uint PurgeQueue(string queueName)
Parameters
Type |
Name |
Description |
System.String |
queueName |
|
Returns
Type |
Description |
System.UInt32 |
|
|
Edit this page
View Source
PurgeQueue(String, Boolean)
Declaration
public void PurgeQueue(string queueName, bool noWait)
Parameters
Type |
Name |
Description |
System.String |
queueName |
|
System.Boolean |
noWait |
|
|
Edit this page
View Source
RemoveBinding(IBinding)
Declaration
public void RemoveBinding(IBinding binding)
Parameters
Implements
IServiceNameAware