CQRS.NET  2.1
A lightweight enterprise framework to write CQRS, event-sourced and micro-service applications in hybrid multi-datacentre, on-premise and Azure environments.
Protected Member Functions | Protected Attributes | Properties | List of all members
Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > Class Template Referenceabstract
+ Inheritance diagram for Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken >:

Protected Member Functions

 AzureBus (IConfigurationManager configurationManager, IMessageSerialiser< TAuthenticationToken > messageSerialiser, IAuthenticationTokenHelper< TAuthenticationToken > authenticationTokenHelper, ICorrelationIdHelper correlationIdHelper, ILogger logger, bool isAPublisher)
 
virtual void SetConnectionStrings ()
 
virtual void SetNumberOfReceiversCount ()
 
virtual void SetMaximumConcurrentReceiverProcessesCount ()
 
abstract string GetConnectionString ()
 
virtual int GetCurrentNumberOfReceiversCount ()
 
virtual int GetCurrentMaximumConcurrentReceiverProcessesCount ()
 
abstract void InstantiatePublishing ()
 
abstract void InstantiateReceiving ()
 
virtual NamespaceManager GetNamespaceManager ()
 
virtual void StartSettingsChecking ()
 
virtual bool ValidateSettingsHaveChanged ()
 
virtual void UpdateSettings ()
 
abstract void TriggerSettingsChecking ()
 
abstract void ApplyReceiverMessageHandler ()
 

Protected Attributes

const int DefaultNumberOfReceiversCount = 1
 
const int DefaultMaximumConcurrentReceiverProcessesCount = 1
 

Properties

string ConnectionString [get, set]
 
IMessageSerialiser< TAuthenticationToken > MessageSerialiser [get]
 
IAuthenticationTokenHelper< TAuthenticationToken > AuthenticationTokenHelper [get]
 
ICorrelationIdHelper CorrelationIdHelper [get]
 
ILogger Logger [get]
 
IConfigurationManager ConfigurationManager [get]
 
IDictionary< Guid, IList< IEvent< TAuthenticationToken > > > EventWaits [get]
 
int NumberOfReceiversCount [get, set]
 
int MaximumConcurrentReceiverProcessesCount [get, set]
 
virtual RetryPolicy AzureServiceBusRetryPolicy [get]
 Gets the default retry policy dedicated to handling transient conditions with Windows Azure Service Bus. More...