Cqrs.Azure.ServiceBus.AzureEventBus< TAuthenticationToken > Class Template Reference

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

Protected Member Functions
	AzureEventBus (IConfigurationManager configurationManager, IMessageSerialiser< TAuthenticationToken > messageSerialiser, IAuthenticationTokenHelper< TAuthenticationToken > authenticationTokenHelper, ICorrelationIdHelper correlationIdHelper, ILogger logger, IAzureBusHelper< TAuthenticationToken > azureBusHelper, IBusHelper busHelper, bool isAPublisher)
Protected Member Functions inherited from Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken >
	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 ()

Properties
override string	MessageBusConnectionStringConfigurationKey [get]
override string	PrivateTopicNameConfigurationKey [get]
override string	PublicTopicNameConfigurationKey [get]
override string	PrivateTopicSubscriptionNameConfigurationKey [get]
override string	PublicTopicSubscriptionNameConfigurationKey [get]
override string	DefaultPrivateTopicName [get]
override string	DefaultPublicTopicName [get]
override string	ThrowExceptionOnReceiverMessageLockLostExceptionDuringCompleteConfigurationKey [get]
Properties inherited from Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken >
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...

Additional Inherited Members
Protected Attributes inherited from Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken >
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