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

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

Protected Member Functions
	AzureEventHub (IConfigurationManager configurationManager, IMessageSerialiser< TAuthenticationToken > messageSerialiser, IAuthenticationTokenHelper< TAuthenticationToken > authenticationTokenHelper, ICorrelationIdHelper correlationIdHelper, ILogger logger, bool isAPublisher)
override string	GetConnectionString ()
override void	SetConnectionStrings ()
override void	InstantiatePublishing ()
override void	InstantiateReceiving ()
virtual void	CheckPrivateEventHubExists (NamespaceManager namespaceManager)
virtual void	CheckPublicHubExists (NamespaceManager namespaceManager)
virtual void	CheckHubExists (NamespaceManager namespaceManager, string eventHubName, string eventSubscriptionNames)
override bool	ValidateSettingsHaveChanged ()
override void	TriggerSettingsChecking ()
virtual void	RegisterReceiverMessageHandler (Action< PartitionContext, EventData > receiverMessageHandler, EventProcessorOptions receiverMessageHandlerOptions=null)
virtual void	StoreReceiverMessageHandler (Action< PartitionContext, EventData > receiverMessageHandler, EventProcessorOptions receiverMessageHandlerOptions=null)
override void	ApplyReceiverMessageHandler ()
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	SetNumberOfReceiversCount ()
virtual void	SetMaximumConcurrentReceiverProcessesCount ()
virtual int	GetCurrentNumberOfReceiversCount ()
virtual int	GetCurrentMaximumConcurrentReceiverProcessesCount ()
virtual NamespaceManager	GetNamespaceManager ()
virtual void	StartSettingsChecking ()
virtual void	UpdateSettings ()

Protected Attributes
const string	DefaultPrivateEventHubConsumerGroupName = "$Default"
const string	DefaultPublicEventHubConsumerGroupName = "$Default"
Protected Attributes inherited from Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken >
const int	DefaultNumberOfReceiversCount = 1
const int	DefaultMaximumConcurrentReceiverProcessesCount = 1

Properties
EventHubClient	EventHubPublisher [get]
EventProcessorHost	EventHubReceiver [get]
string	PrivateEventHubName [get, set]
string	PublicEventHubName [get]
string	PrivateEventHubConsumerGroupName [get]
string	PublicEventHubConsumerGroupName [get]
abstract string	EventHubConnectionStringNameConfigurationKey [get]
abstract string	EventHubStorageConnectionStringNameConfigurationKey [get]
abstract string	PrivateEventHubNameConfigurationKey [get]
abstract string	PublicEventHubNameConfigurationKey [get]
abstract string	DefaultPrivateEventHubName [get]
abstract string	DefaultPublicEventHubName [get]
abstract string	PrivateEventHubConsumerGroupNameConfigurationKey [get]
abstract string	PublicEventHubConsumerGroupNameConfigurationKey [get]
string	StorageConnectionString [get]
Action< PartitionContext, EventData >	ReceiverMessageHandler [get]
EventProcessorOptions	ReceiverMessageHandlerOptions [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...