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

A event bus based on AzureServiceBus<TAuthenticationToken>. More...

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, IHashAlgorithmFactory hashAlgorithmFactory, bool isAPublisher)
	Instantiate a new instance of AzureEventBus<TAuthenticationToken>. More...
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, IHashAlgorithmFactory hashAlgorithmFactory, bool isAPublisher)
	Instantiates a new instance of AzureServiceBus<TAuthenticationToken> More...
override string	GetConnectionString ()
	Gets the connection string for the bus from AzureBus<TAuthenticationToken>.ConfigurationManager More...
override void	InstantiatePublishing ()
	Instantiate publishing on this bus by calling CheckPrivateTopicExists and CheckPublicTopicExists then calling AzureBus<TAuthenticationToken>.StartSettingsChecking More...
override void	InstantiateReceiving ()
	Instantiate receiving on this bus by calling CheckPrivateTopicExists and CheckPublicTopicExists then InstantiateReceiving for private and public topics, calls CleanUpDeadLetters for the private and public topics, then calling AzureBus<TAuthenticationToken>.StartSettingsChecking More...
virtual void	InstantiateReceiving (Manager manager, IDictionary< int, IMessageReceiver > serviceBusReceivers, string topicName, string topicSubscriptionName)
virtual void	CheckPrivateTopicExists (Manager manager)
	Checks if the private topic and subscription name exists as per PrivateTopicName and PrivateTopicSubscriptionName. More...
virtual void	CheckPublicTopicExists (Manager manager)
	Checks if the public topic and subscription name exists as per PublicTopicName and PublicTopicSubscriptionName. More...
virtual void	CheckTopicExists (Manager manager, string topicName, string subscriptionName)
	Checks if a topic by the provided topicName exists and Checks if a subscription name by the provided subscriptionName exists. More...
override void	TriggerSettingsChecking ()
	Triggers settings checking on both public and private publishers and receivers, then calls InstantiatePublishing if PublicServiceBusPublisher is not null. More...
virtual void	TriggerSettingsChecking (TopicClient serviceBusPublisher, IDictionary< int, IMessageReceiver > serviceBusReceivers)
	Triggers settings checking on the provided serviceBusPublisher and serviceBusReceivers , then calls InstantiateReceiving(). More...
override void	ApplyReceiverMessageHandler ()
	Applies the stored ReceiverMessageHandler and ReceiverMessageHandlerOptions to all receivers in PrivateServiceBusReceivers and PublicServiceBusReceivers. More...
virtual CancellationTokenSource	CleanUpDeadLetters (string topicName, string topicSubscriptionName)
	Using a Task, clears all dead letters from the topic and subscription of the provided topicName and topicSubscriptionName . More...
virtual BrokeredMessage	CreateBrokeredMessage< TMessage > (Func< TMessage, string > serialiserFunction, Type messageType, TMessage message)
	Create a BrokeredMessage with additional properties to aid routing and tracing More...
virtual IDictionary< string, string >	ExtractTelemetryProperties (BrokeredMessage message, string baseCommunicationType)
	Extract any telemetry properties from the provided message . More...
virtual string	ExtractSignature (BrokeredMessage message)
	Extract the signature from the provided message . More...
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)
	Instantiates a new instance of AzureBus<TAuthenticationToken> More...
virtual void	SetConnectionStrings ()
	Sets ConnectionString from GetConnectionString. More...
virtual void	SetNumberOfReceiversCount ()
	Sets NumberOfReceiversCount from GetCurrentNumberOfReceiversCount. More...
virtual void	SetMaximumConcurrentReceiverProcessesCount ()
	Sets MaximumConcurrentReceiverProcessesCount from GetCurrentMaximumConcurrentReceiverProcessesCount. More...
virtual int	GetCurrentNumberOfReceiversCount ()
	Returns DefaultNumberOfReceiversCount. More...
virtual int	GetCurrentMaximumConcurrentReceiverProcessesCount ()
	Returns DefaultMaximumConcurrentReceiverProcessesCount. More...

Properties
override string	MessageBusConnectionStringConfigurationKey [get]
	The configuration key for the message bus connection string as used by IConfigurationManager. More...
override string	SigningTokenConfigurationKey [get]
	The configuration key for the signing token as used by IConfigurationManager. More...
override string	PrivateTopicNameConfigurationKey [get]
	The configuration key for the name of the private topic as used by IConfigurationManager. More...
override string	PublicTopicNameConfigurationKey [get]
	The configuration key for the name of the public topic as used by IConfigurationManager. More...
override string	PrivateTopicSubscriptionNameConfigurationKey [get]
	The configuration key for the name of the subscription in the private topic as used by IConfigurationManager. More...
override string	PublicTopicSubscriptionNameConfigurationKey [get]
	The configuration key for the name of the subscription in the public topic as used by IConfigurationManager. More...
override string	DefaultPrivateTopicName [get]
	The default name of the private topic if no IConfigurationManager value is set. More...
override string	DefaultPublicTopicName [get]
	The default name of the public topic if no IConfigurationManager value is set. More...
override string	ThrowExceptionOnReceiverMessageLockLostExceptionDuringCompleteConfigurationKey [get]
	The configuration key that specifies if an Exception is thrown if the network lock is lost as used by IConfigurationManager. More...
Properties inherited from Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken >
TopicClient	PrivateServiceBusPublisher [get]
	Gets the private TopicClient publisher. More...
TopicClient	PublicServiceBusPublisher [get]
	Gets the public TopicClient publisher. More...
IDictionary< int, IMessageReceiver >	PrivateServiceBusReceivers [get]
	Gets the private IMessageReceiver receivers. More...
IDictionary< int, IMessageReceiver >	PublicServiceBusReceivers [get]
	Gets the public IMessageReceiver receivers. More...
string	PrivateTopicName [get]
	The name of the private topic. More...
string	PublicTopicName [get]
	The name of the public topic. More...
string	PrivateTopicSubscriptionName [get]
	The name of the subscription in the private topic. More...
string	PublicTopicSubscriptionName [get]
	The name of the subscription in the public topic. More...
abstract string	MessageBusConnectionStringConfigurationKey [get]
	The configuration key for the message bus connection string as used by IConfigurationManager. More...
abstract string	SigningTokenConfigurationKey [get]
	The configuration key for the signing token as used by IConfigurationManager. More...
abstract string	PrivateTopicNameConfigurationKey [get]
	The configuration key for the name of the private topic as used by IConfigurationManager. More...
abstract string	PublicTopicNameConfigurationKey [get]
	The configuration key for the name of the public topic as used by IConfigurationManager. More...
abstract string	DefaultPrivateTopicName [get]
	The default name of the private topic if no IConfigurationManager value is set. More...
abstract string	DefaultPublicTopicName [get]
	The default name of the public topic if no IConfigurationManager value is set. More...
abstract string	PrivateTopicSubscriptionNameConfigurationKey [get]
	The configuration key for the name of the subscription in the private topic as used by IConfigurationManager. More...
abstract string	PublicTopicSubscriptionNameConfigurationKey [get]
	The configuration key for the name of the subscription in the public topic as used by IConfigurationManager. More...
abstract string	ThrowExceptionOnReceiverMessageLockLostExceptionDuringCompleteConfigurationKey [get]
	The configuration key that specifies if an Exception is thrown if the network lock is lost as used by IConfigurationManager. More...
bool	ThrowExceptionOnReceiverMessageLockLostExceptionDuringComplete [get]
	Specifies if an Exception is thrown if the network lock is lost. More...
IBusHelper	BusHelper [get]
	Gets the IBusHelper. More...
IAzureBusHelper< TAuthenticationToken >	AzureBusHelper [get]
	Gets the IAzureBusHelper<TAuthenticationToken>. More...
ITelemetryHelper	TelemetryHelper [get, set]
	Gets the ITelemetryHelper. More...
short	TimeoutOnSendRetryMaximumCount [get]
	The maximum number of time a retry is tried if a System.TimeoutException is thrown while sending messages. More...
IHashAlgorithmFactory	Signer [get]
	The IHashAlgorithmFactory to use to sign messages. More...
IList< string >	ExclusionNamespaces [get]
	A list of namespaces to exclude when trying to automatically determine the container. More...
Properties inherited from Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken >
string	ConnectionString [get, set]
	Gets or sets the connection string to the bus. More...
IMessageSerialiser< TAuthenticationToken >	MessageSerialiser [get]
	Gets or sets the IMessageSerialiser<TAuthenticationToken>. More...
IAuthenticationTokenHelper< TAuthenticationToken >	AuthenticationTokenHelper [get]
	Gets or sets the IAuthenticationTokenHelper<TAuthenticationToken>. More...
ICorrelationIdHelper	CorrelationIdHelper [get]
	Gets or sets the ICorrelationIdHelper. More...
ILogger	Logger [get]
	Gets or sets the ILogger. More...
IConfigurationManager	ConfigurationManager [get]
	Gets or sets the IConfigurationManager. More...
IDictionary< Guid, IList< IEvent< TAuthenticationToken > > >	EventWaits [get]
	Gets or sets the events to wait for before responding to the caller keyed by the ICommand<TAuthenticationToken>.Id More...
int	NumberOfReceiversCount [get, set]
	The number of receivers to start and run. More...
int	MaximumConcurrentReceiverProcessesCount [get, set]
bool	AuthenticationTokenIsGuid [get]
	Indicates if the TAuthenticationToken is a Guid. More...
bool	AuthenticationTokenIsInt [get]
	Indicates if the TAuthenticationToken is an int. More...
bool	AuthenticationTokenIsString [get]
	Indicates if the TAuthenticationToken is a string. More...

Additional Inherited Members
Static Protected Attributes inherited from Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken >
const string	DefaultPrivateTopicSubscriptionName = "Root"
	The default name of the subscription in the private topic if no IConfigurationManager value is set. More...
const string	DefaultPublicTopicSubscriptionName = "Root"
	The default name of the subscription in the public topic if no IConfigurationManager value is set. More...
Static Protected Attributes inherited from Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken >
const int	DefaultNumberOfReceiversCount = 1
	The default number of receivers to start and run. More...
const int	DefaultMaximumConcurrentReceiverProcessesCount = 1
	The default number for MaximumConcurrentReceiverProcessesCount. More...

Detailed Description

A event bus based on AzureServiceBus<TAuthenticationToken>.

Template Parameters

TAuthenticationToken

The Type of the authentication token.