ApplyReceiverMessageHandler() | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
AuthenticationTokenHelper | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
AzureBus(IConfigurationManager configurationManager, IMessageSerialiser< TAuthenticationToken > messageSerialiser, IAuthenticationTokenHelper< TAuthenticationToken > authenticationTokenHelper, ICorrelationIdHelper correlationIdHelper, ILogger logger, bool isAPublisher) | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
AzureBusHelper | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
AzureEventBus(IConfigurationManager configurationManager, IMessageSerialiser< TAuthenticationToken > messageSerialiser, IAuthenticationTokenHelper< TAuthenticationToken > authenticationTokenHelper, ICorrelationIdHelper correlationIdHelper, ILogger logger, IAzureBusHelper< TAuthenticationToken > azureBusHelper, IBusHelper busHelper, bool isAPublisher) | Cqrs.Azure.ServiceBus.AzureEventBus< TAuthenticationToken > | protected |
AzureServiceBus(IConfigurationManager configurationManager, IMessageSerialiser< TAuthenticationToken > messageSerialiser, IAuthenticationTokenHelper< TAuthenticationToken > authenticationTokenHelper, ICorrelationIdHelper correlationIdHelper, ILogger logger, IAzureBusHelper< TAuthenticationToken > azureBusHelper, IBusHelper busHelper, bool isAPublisher) | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
AzureServiceBusRetryPolicy | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
BusHelper | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
CheckPrivateEventTopicExists(NamespaceManager namespaceManager) | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
CheckPublicTopicExists(NamespaceManager namespaceManager) | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
CheckTopicExists(NamespaceManager namespaceManager, string eventTopicName, string eventSubscriptionNames) | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
CleanUpDeadLetters(string topicName, string topicSubscriptionName) | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
ConfigurationManager | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
ConnectionString | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
CorrelationIdHelper | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
DefaultMaximumConcurrentReceiverProcessesCount | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
DefaultNumberOfReceiversCount | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
DefaultPrivateTopicName | Cqrs.Azure.ServiceBus.AzureEventBus< TAuthenticationToken > | protected |
DefaultPrivateTopicSubscriptionName | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
DefaultPublicTopicName | Cqrs.Azure.ServiceBus.AzureEventBus< TAuthenticationToken > | protected |
DefaultPublicTopicSubscriptionName | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
EventWaits | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
GetConnectionString() | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
GetCurrentMaximumConcurrentReceiverProcessesCount() | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protectedvirtual |
GetCurrentNumberOfReceiversCount() | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protectedvirtual |
GetNamespaceManager() | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protectedvirtual |
InstantiatePublishing() | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
InstantiateReceiving() | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
InstantiateReceiving(NamespaceManager namespaceManager, IDictionary< int, SubscriptionClient > serviceBusReceivers, string topicName, string topicSubscriptionName) | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
Logger | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
MaximumConcurrentReceiverProcessesCount | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
MessageBusConnectionStringConfigurationKey | Cqrs.Azure.ServiceBus.AzureEventBus< TAuthenticationToken > | protected |
MessageSerialiser | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
NumberOfReceiversCount | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
PrivateServiceBusPublisher | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
PrivateServiceBusReceivers | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
PrivateTopicName | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
PrivateTopicNameConfigurationKey | Cqrs.Azure.ServiceBus.AzureEventBus< TAuthenticationToken > | protected |
PrivateTopicSubscriptionName | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
PrivateTopicSubscriptionNameConfigurationKey | Cqrs.Azure.ServiceBus.AzureEventBus< TAuthenticationToken > | protected |
PublicServiceBusPublisher | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
PublicServiceBusReceivers | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
PublicTopicName | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
PublicTopicNameConfigurationKey | Cqrs.Azure.ServiceBus.AzureEventBus< TAuthenticationToken > | protected |
PublicTopicSubscriptionName | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
PublicTopicSubscriptionNameConfigurationKey | Cqrs.Azure.ServiceBus.AzureEventBus< TAuthenticationToken > | protected |
ReceiverMessageHandler | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
ReceiverMessageHandlerOptions | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
RegisterReceiverMessageHandler(Action< BrokeredMessage > receiverMessageHandler, OnMessageOptions receiverMessageHandlerOptions) | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
SetConnectionStrings() | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protectedvirtual |
SetMaximumConcurrentReceiverProcessesCount() | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protectedvirtual |
SetNumberOfReceiversCount() | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protectedvirtual |
StartSettingsChecking() | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protectedvirtual |
StoreReceiverMessageHandler(Action< BrokeredMessage > receiverMessageHandler, OnMessageOptions receiverMessageHandlerOptions) | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
TelemetryHelper | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
ThrowExceptionOnReceiverMessageLockLostExceptionDuringComplete | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
ThrowExceptionOnReceiverMessageLockLostExceptionDuringCompleteConfigurationKey | Cqrs.Azure.ServiceBus.AzureEventBus< TAuthenticationToken > | protected |
TriggerSettingsChecking() | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
TriggerSettingsChecking(TopicClient serviceBusPublisher, IDictionary< int, SubscriptionClient > serviceBusReceivers) | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
UpdateSettings() | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protectedvirtual |
ValidateSettingsHaveChanged() | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protectedvirtual |