Inheritance diagram for Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken >:

Protected Member Functions
	AzureServiceBus (IConfigurationManager configurationManager, IMessageSerialiser< TAuthenticationToken > messageSerialiser, IAuthenticationTokenHelper< TAuthenticationToken > authenticationTokenHelper, ICorrelationIdHelper correlationIdHelper, ILogger logger, IAzureBusHelper< TAuthenticationToken > azureBusHelper, IBusHelper busHelper, bool isAPublisher)

override string	GetConnectionString ()

override void	InstantiatePublishing ()

override void	InstantiateReceiving ()

virtual void	InstantiateReceiving (NamespaceManager namespaceManager, IDictionary< int, SubscriptionClient > serviceBusReceivers, string topicName, string topicSubscriptionName)

virtual void	CheckPrivateEventTopicExists (NamespaceManager namespaceManager)

virtual void	CheckPublicTopicExists (NamespaceManager namespaceManager)

virtual void	CheckTopicExists (NamespaceManager namespaceManager, string eventTopicName, string eventSubscriptionNames)

override void	TriggerSettingsChecking ()

virtual void	TriggerSettingsChecking (TopicClient serviceBusPublisher, IDictionary< int, SubscriptionClient > serviceBusReceivers)

virtual void	RegisterReceiverMessageHandler (Action< BrokeredMessage > receiverMessageHandler, OnMessageOptions receiverMessageHandlerOptions)

virtual void	StoreReceiverMessageHandler (Action< BrokeredMessage > receiverMessageHandler, OnMessageOptions receiverMessageHandlerOptions)

override void	ApplyReceiverMessageHandler ()

virtual CancellationTokenSource	CleanUpDeadLetters (string topicName, string topicSubscriptionName)

Protected Member Functions inherited from Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken >
	AzureBus (IConfigurationManager configurationManager, IMessageSerialiser< TAuthenticationToken > messageSerialiser, IAuthenticationTokenHelper< TAuthenticationToken > authenticationTokenHelper, ICorrelationIdHelper correlationIdHelper, ILogger logger, bool isAPublisher)

virtual void	SetConnectionStrings ()

virtual void	SetNumberOfReceiversCount ()

virtual void	SetMaximumConcurrentReceiverProcessesCount ()

virtual int	GetCurrentNumberOfReceiversCount ()

virtual int	GetCurrentMaximumConcurrentReceiverProcessesCount ()

virtual NamespaceManager	GetNamespaceManager ()

virtual void	StartSettingsChecking ()

virtual bool	ValidateSettingsHaveChanged ()

virtual void	UpdateSettings ()

Protected Attributes
const string	DefaultPrivateTopicSubscriptionName = "Root"

const string	DefaultPublicTopicSubscriptionName = "Root"

Protected Attributes inherited from Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken >
const int	DefaultNumberOfReceiversCount = 1

const int	DefaultMaximumConcurrentReceiverProcessesCount = 1

Properties
TopicClient	PrivateServiceBusPublisher `[get]`

TopicClient	PublicServiceBusPublisher `[get]`

IDictionary< int, SubscriptionClient >	PrivateServiceBusReceivers `[get]`

IDictionary< int, SubscriptionClient >	PublicServiceBusReceivers `[get]`

string	PrivateTopicName `[get]`

string	PublicTopicName `[get]`

string	PrivateTopicSubscriptionName `[get]`

string	PublicTopicSubscriptionName `[get]`

abstract string	MessageBusConnectionStringConfigurationKey `[get]`

abstract string	PrivateTopicNameConfigurationKey `[get]`

abstract string	PublicTopicNameConfigurationKey `[get]`

abstract string	DefaultPrivateTopicName `[get]`

abstract string	DefaultPublicTopicName `[get]`

abstract string	PrivateTopicSubscriptionNameConfigurationKey `[get]`

abstract string	PublicTopicSubscriptionNameConfigurationKey `[get]`

abstract string	ThrowExceptionOnReceiverMessageLockLostExceptionDuringCompleteConfigurationKey `[get]`

bool	ThrowExceptionOnReceiverMessageLockLostExceptionDuringComplete `[get]`

Action< BrokeredMessage >	ReceiverMessageHandler `[get, set]`

OnMessageOptions	ReceiverMessageHandlerOptions `[get, set]`

IBusHelper	BusHelper `[get]`

IAzureBusHelper< TAuthenticationToken >	AzureBusHelper `[get]`

ITelemetryHelper	TelemetryHelper `[get, set]`

Properties inherited from Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken >
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...

Protected Member Functions

Protected Attributes

Properties