ApplyReceiverMessageHandler() | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
AuthenticationTokenHelper | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
AuthenticationTokenIsGuid | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
AuthenticationTokenIsInt | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
AuthenticationTokenIsString | 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, IHashAlgorithmFactory hashAlgorithmFactory, 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, IHashAlgorithmFactory hashAlgorithmFactory, bool isAPublisher) | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
BusHelper | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
CheckPrivateTopicExists(Manager manager) | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
CheckPublicTopicExists(Manager manager) | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
CheckTopicExists(Manager manager, string topicName, string subscriptionName) | 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 |
CreateBrokeredMessage< TMessage >(Func< TMessage, string > serialiserFunction, Type messageType, TMessage message) | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
DefaultMaximumConcurrentReceiverProcessesCount | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protectedstatic |
DefaultNumberOfReceiversCount | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protectedstatic |
DefaultPrivateTopicName | Cqrs.Azure.ServiceBus.AzureEventBus< TAuthenticationToken > | protected |
DefaultPrivateTopicSubscriptionName | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedstatic |
DefaultPublicTopicName | Cqrs.Azure.ServiceBus.AzureEventBus< TAuthenticationToken > | protected |
DefaultPublicTopicSubscriptionName | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedstatic |
EventWaits | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protected |
ExclusionNamespaces | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
ExtractSignature(BrokeredMessage message) | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
ExtractTelemetryProperties(BrokeredMessage message, string baseCommunicationType) | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
GetConnectionString() | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
GetCurrentMaximumConcurrentReceiverProcessesCount() | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protectedvirtual |
GetCurrentNumberOfReceiversCount() | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protectedvirtual |
InstantiatePublishing() | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
InstantiateReceiving() | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |
InstantiateReceiving(Manager manager, IDictionary< int, IMessageReceiver > 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 |
SetConnectionStrings() | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protectedvirtual |
SetMaximumConcurrentReceiverProcessesCount() | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protectedvirtual |
SetNumberOfReceiversCount() | Cqrs.Azure.ServiceBus.AzureBus< TAuthenticationToken > | protectedvirtual |
Signer | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
SigningTokenConfigurationKey | Cqrs.Azure.ServiceBus.AzureEventBus< TAuthenticationToken > | protected |
TelemetryHelper | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
ThrowExceptionOnReceiverMessageLockLostExceptionDuringComplete | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
ThrowExceptionOnReceiverMessageLockLostExceptionDuringCompleteConfigurationKey | Cqrs.Azure.ServiceBus.AzureEventBus< TAuthenticationToken > | protected |
TimeoutOnSendRetryMaximumCount | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
TriggerSettingsChecking() | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protected |
TriggerSettingsChecking(TopicClient serviceBusPublisher, IDictionary< int, IMessageReceiver > serviceBusReceivers) | Cqrs.Azure.ServiceBus.AzureServiceBus< TAuthenticationToken > | protectedvirtual |