< Summary

Class:Microsoft.Azure.ServiceBus.MessagingEventSource
Assembly:Microsoft.Azure.ServiceBus
File(s):C:\Git\azure-sdk-for-net\sdk\servicebus\Microsoft.Azure.ServiceBus\src\MessagingEventSource.cs
Covered lines:9
Uncovered lines:447
Coverable lines:456
Total lines:1392
Line coverage:1.9% (9 of 456)
Covered branches:4
Total branches:276
Branch coverage:1.4% (4 of 276)

Metrics

MethodCyclomatic complexity Line coverage Branch coverage
get_Log()-100%100%
QueueClientCreateStart(...)-0%0%
QueueClientCreateStop(...)-0%0%
TopicClientCreateStart(...)-0%0%
TopicClientCreateStop(...)-0%0%
SubscriptionClientCreateStart(...)-0%0%
SubscriptionClientCreateStop(...)-0%0%
MessageSendStart(...)-0%0%
MessageSendStop(...)-0%0%
MessageSendException(...)-0%0%
MessageSendException(...)-0%100%
MessageReceiveStart(...)-0%0%
MessageReceiveStop(...)-0%0%
MessageReceiveException(...)-0%0%
MessageReceiveException(...)-0%100%
MessageCompleteStart(...)-0%0%
MessageCompleteStart(...)-0%100%
MessageCompleteStop(...)-0%0%
MessageCompleteException(...)-0%0%
MessageCompleteException(...)-0%100%
MessageAbandonStart(...)-0%0%
MessageAbandonStop(...)-0%0%
MessageAbandonException(...)-0%0%
MessageAbandonException(...)-0%100%
MessageDeferStart(...)-0%0%
MessageDeferStop(...)-0%0%
MessageDeferException(...)-0%0%
MessageDeferException(...)-0%100%
MessageDeadLetterStart(...)-0%0%
MessageDeadLetterStop(...)-0%0%
MessageDeadLetterException(...)-0%0%
MessageDeadLetterException(...)-0%100%
MessageRenewLockStart(...)-0%0%
MessageRenewLockStop(...)-0%0%
MessageRenewLockException(...)-0%0%
MessageRenewLockException(...)-0%100%
MessageReceiveDeferredMessageStart(...)-0%0%
MessageReceiveDeferredMessageStart(...)-0%100%
MessageReceiveDeferredMessageStop(...)-0%0%
MessageReceiveDeferredMessageException(...)-0%0%
MessageReceiveDeferredMessageException(...)-0%100%
AmqpSendLinkCreateStart(...)-0%0%
AmqpSendLinkCreateStart(...)-0%100%
AmqpSendLinkCreateStop(...)-0%0%
AmqpReceiveLinkCreateStart(...)-0%0%
AmqpReceiveLinkCreateStart(...)-0%100%
AmqpReceiveLinkCreateStop(...)-0%0%
AmqpGetOrCreateConnectionStart()-0%0%
AmqpGetOrCreateConnectionStop(...)-0%0%
AmqpSendAuthenticationTokenStart(...)-0%0%
AmqpSendAuthenticationTokenStart(...)-0%100%
AmqpSendAuthenticationTokenStop()-0%0%
MessagePeekStart(...)-0%0%
MessagePeekStop(...)-0%0%
MessagePeekException(...)-0%0%
MessagePeekException(...)-0%100%
MessageSenderCreateStart(...)-66.67%50%
MessageSenderCreateStop(...)-66.67%50%
MessageReceiverCreateStart(...)-0%0%
MessageReceiverCreateStop(...)-0%0%
ScheduleMessageStart(...)-0%0%
ScheduleMessageStart(...)-0%0%
ScheduleMessageStop(...)-0%0%
ScheduleMessageException(...)-0%0%
ScheduleMessageException(...)-0%100%
CancelScheduledMessageStart(...)-0%0%
CancelScheduledMessageStop(...)-0%0%
CancelScheduledMessageException(...)-0%0%
CancelScheduledMessageException(...)-0%100%
AddRuleStart(...)-0%0%
AddRuleStop(...)-0%0%
AddRuleException(...)-0%0%
AddRuleException(...)-0%100%
RemoveRuleStart(...)-0%0%
RemoveRuleStop(...)-0%0%
RemoveRuleException(...)-0%0%
RemoveRuleException(...)-0%100%
RegisterOnMessageHandlerStart(...)-0%0%
RegisterOnMessageHandlerStart(...)-0%100%
RegisterOnMessageHandlerStop(...)-0%0%
RegisterOnMessageHandlerException(...)-0%0%
RegisterOnMessageHandlerException(...)-0%100%
MessageReceiverPumpTaskStart(...)-0%0%
MessageReceiverPumpTaskStart(...)-0%100%
MessageReceiverPumpTaskStop(...)-0%0%
MessageReceivePumpTaskException(...)-0%0%
MessageReceivePumpTaskException(...)-0%100%
MessageReceiverPumpDispatchTaskStart(...)-0%0%
MessageReceiverPumpDispatchTaskStart(...)-0%100%
MessageReceiverPumpDispatchTaskStop(...)-0%0%
MessageReceiverPumpDispatchTaskStop(...)-0%100%
MessageReceiverPumpUserCallbackStart(...)-0%0%
MessageReceiverPumpUserCallbackStart(...)-0%100%
MessageReceiverPumpUserCallbackStop(...)-0%0%
MessageReceiverPumpUserCallbackStop(...)-0%100%
MessageReceiverPumpUserCallbackException(...)-0%0%
MessageReceiverPumpUserCallbackException(...)-0%100%
MessageReceiverPumpRenewMessageStart(...)-0%0%
MessageReceiverPumpRenewMessageStart(...)-0%100%
MessageReceiverPumpRenewMessageStop(...)-0%0%
MessageReceiverPumpRenewMessageStop(...)-0%100%
MessageReceiverPumpRenewMessageException(...)-0%0%
MessageReceiverPumpRenewMessageException(...)-0%100%
RunOperationExceptionEncountered(...)-66.67%50%
RunOperationExceptionEncountered(...)-0%100%
RegisterOnSessionHandlerStart(...)-0%0%
RegisterOnSessionHandlerStart(...)-0%100%
RegisterOnSessionHandlerStop(...)-0%0%
RegisterOnSessionHandlerException(...)-0%0%
RegisterOnSessionHandlerException(...)-0%100%
SessionReceivePumpSessionReceiveException(...)-0%0%
SessionReceivePumpSessionReceiveException(...)-0%100%
SessionReceivePumpSessionEmpty(...)-0%0%
SessionReceivePumpSessionClosed(...)-0%0%
SessionReceivePumpSessionCloseException(...)-0%0%
SessionReceivePumpSessionCloseException(...)-0%100%
SessionReceivePumpSessionRenewLockStart(...)-0%0%
SessionReceivePumpSessionRenewLockStart(...)-0%100%
SessionReceivePumpSessionRenewLockStop(...)-0%0%
SessionReceivePumpSessionRenewLockException(...)-0%0%
SessionReceivePumpSessionRenewLockException(...)-0%100%
AmqpSessionClientAcceptMessageSessionStart(...)-0%0%
AmqpSessionClientAcceptMessageSessionStart(...)-0%100%
AmqpSessionClientAcceptMessageSessionStop(...)-0%0%
AmqpSessionClientAcceptMessageSessionException(...)-0%0%
AmqpSessionClientAcceptMessageSessionException(...)-0%100%
AmqpLinkCreationException(...)-0%0%
AmqpLinkCreationException(...)-0%100%
AmqpConnectionCreated(...)-0%0%
AmqpConnectionCreated(...)-0%100%
AmqpConnectionClosed(...)-0%0%
AmqpConnectionClosed(...)-0%100%
AmqpSessionCreationException(...)-0%0%
AmqpSessionCreationException(...)-0%100%
PluginCallStarted(...)-0%0%
PluginCallCompleted(...)-0%0%
PluginCallFailed(...)-0%0%
PluginCallFailed(...)-0%100%
ScheduleTaskFailed(...)-0%0%
ScheduleTaskFailed(...)-0%100%
ExceptionReceivedHandlerThrewException(...)-0%0%
ExceptionReceivedHandlerThrewException(...)-0%100%
LinkStateLost(...)-0%0%
LinkStateLost(...)-0%100%
UpdateClientId(...)-0%0%
GetRulesStart(...)-0%0%
GetRulesStop(...)-0%0%
GetRulesException(...)-0%0%
GetRulesException(...)-0%100%
CreatingNewLink(...)-0%0%
CreatingNewLink(...)-0%100%
SessionReceiverLinkClosed(...)-0%0%
SessionReceiverLinkClosed(...)-0%100%
AmqpSendAuthenticationTokenException(...)-0%0%
AmqpSendAuthenticationTokenException(...)-0%100%
AmqpTransactionInitializeException(...)-0%0%
AmqpTransactionInitializeException(...)-0%100%
AmqpTransactionDeclared(...)-0%0%
AmqpTransactionDeclared(...)-0%100%
AmqpTransactionDischarged(...)-0%0%
AmqpTransactionDischarged(...)-0%100%
AmqpTransactionDischargeException(...)-0%0%
AmqpTransactionDischargeException(...)-0%100%
AmqpCreateControllerException(...)-0%0%
AmqpCreateControllerException(...)-0%100%
ManagementOperationStart(...)-0%0%
ManagementOperationEnd(...)-0%0%
ManagementOperationException(...)-0%0%
ManagementOperationException(...)-0%100%
ManagementClientCreated(...)-66.67%50%
ManagementSerializationException(...)-0%0%

File(s)

C:\Git\azure-sdk-for-net\sdk\servicebus\Microsoft.Azure.ServiceBus\src\MessagingEventSource.cs

#LineLine coverage
 1// Copyright (c) Microsoft. All rights reserved.
 2// Licensed under the MIT license. See LICENSE file in the project root for full license information.
 3
 4namespace Microsoft.Azure.ServiceBus
 5{
 6    using System;
 7    using System.Collections.Generic;
 8    using System.Diagnostics.Tracing;
 9    using System.Reflection;
 10    using System.Text;
 11    using System.Threading.Tasks;
 12    using Microsoft.Azure.Amqp;
 13    using Microsoft.Azure.ServiceBus.Amqp;
 14    using Microsoft.Azure.ServiceBus.Primitives;
 15
 16    [EventSource(Name = "Microsoft-Azure-ServiceBus")]
 17    internal sealed class MessagingEventSource : EventSource
 18    {
 3619        public static MessagingEventSource Log { get; } = new MessagingEventSource();
 20
 21        [Event(1, Level = EventLevel.Informational, Message = "Creating QueueClient (Namespace '{0}'; Queue '{1}'; Recei
 22        public void QueueClientCreateStart(string namespaceName, string queueName, string receiveMode)
 23        {
 024            if (this.IsEnabled())
 25            {
 026                this.WriteEvent(1, namespaceName ?? string.Empty, queueName, receiveMode);
 27            }
 028        }
 29
 30        [Event(2, Level = EventLevel.Informational, Message = "QueueClient (Namespace '{0}'; Queue '{1}'; ClientId: '{2}
 31        public void QueueClientCreateStop(string namespaceName, string queueName, string clientId)
 32        {
 033            if (this.IsEnabled())
 34            {
 035                this.WriteEvent(2, namespaceName, queueName, clientId);
 36            }
 037        }
 38
 39        [Event(3, Level = EventLevel.Informational, Message = "Creating TopicClient (Namespace '{0}'; Topic '{1}').")]
 40        public void TopicClientCreateStart(string namespaceName, string topicName)
 41        {
 042            if (this.IsEnabled())
 43            {
 044                this.WriteEvent(3, namespaceName ?? string.Empty, topicName);
 45            }
 046        }
 47
 48        [Event(4, Level = EventLevel.Informational, Message = "TopicClient (Namespace '{0}'; Topic '{1}'; ClientId: '{2}
 49        public void TopicClientCreateStop(string namespaceName, string topicName, string clientId)
 50        {
 051            if (this.IsEnabled())
 52            {
 053                this.WriteEvent(4, namespaceName, topicName, clientId);
 54            }
 055        }
 56
 57        [Event(5, Level = EventLevel.Informational, Message = "Creating SubscriptionClient (Namespace '{0}'; Topic '{1}'
 58        public void SubscriptionClientCreateStart(string namespaceName, string topicName, string subscriptionName, strin
 59        {
 060            if (this.IsEnabled())
 61            {
 062                this.WriteEvent(5, namespaceName, topicName ?? string.Empty, subscriptionName, receiveMode);
 63            }
 064        }
 65
 66        [Event(6, Level = EventLevel.Informational, Message = "SubscriptionClient (Namespace '{0}'; Topic '{1}'; Subscri
 67        public void SubscriptionClientCreateStop(string namespaceName, string topicName, string subscriptionName, string
 68        {
 069            if (this.IsEnabled())
 70            {
 071                this.WriteEvent(6, namespaceName, topicName, subscriptionName, clientId);
 72            }
 073        }
 74
 75        [Event(7, Level = EventLevel.Informational, Message = "{0}: SendAsync start. MessageCount = {1}")]
 76        public void MessageSendStart(string clientId, int messageCount)
 77        {
 078            if (this.IsEnabled())
 79            {
 080                this.WriteEvent(7, clientId, messageCount);
 81            }
 082        }
 83
 84        [Event(8, Level = EventLevel.Informational, Message = "{0}: SendAsync done.")]
 85        public void MessageSendStop(string clientId)
 86        {
 087            if (this.IsEnabled())
 88            {
 089                this.WriteEvent(8, clientId);
 90            }
 091        }
 92
 93        [NonEvent]
 94        public void MessageSendException(string clientId, Exception exception)
 95        {
 096            if (this.IsEnabled())
 97            {
 098                this.MessageSendException(clientId, exception.ToString());
 99            }
 0100        }
 101
 102        [Event(9, Level = EventLevel.Error, Message = "{0}: SendAsync Exception: {1}.")]
 103        void MessageSendException(string clientId, string exception)
 104        {
 0105            this.WriteEvent(9, clientId, exception);
 0106        }
 107
 108        [Event(10, Level = EventLevel.Informational, Message = "{0}: ReceiveAsync start. MessageCount = {1}")]
 109        public void MessageReceiveStart(string clientId, int messageCount)
 110        {
 0111            if (this.IsEnabled())
 112            {
 0113                this.WriteEvent(10, clientId, messageCount);
 114            }
 0115        }
 116
 117        [Event(11, Level = EventLevel.Informational, Message = "{0}: ReceiveAsync done. Received '{1}' messages")]
 118        public void MessageReceiveStop(string clientId, int messageCount)
 119        {
 0120            if (this.IsEnabled())
 121            {
 0122                this.WriteEvent(11, clientId, messageCount);
 123            }
 0124        }
 125
 126        [NonEvent]
 127        public void MessageReceiveException(string clientId, Exception exception)
 128        {
 0129            if (this.IsEnabled())
 130            {
 0131                this.MessageReceiveException(clientId, exception.ToString());
 132            }
 0133        }
 134
 135        [Event(12, Level = EventLevel.Error, Message = "{0}: ReceiveAsync Exception: {1}.")]
 136        void MessageReceiveException(string clientId, string exception)
 137        {
 0138            this.WriteEvent(12, clientId, exception);
 0139        }
 140
 141        [NonEvent]
 142        public void MessageCompleteStart(string clientId, int messageCount, IEnumerable<string> lockTokens)
 143        {
 0144            if (this.IsEnabled())
 145            {
 0146                var formattedLockTokens = StringUtility.GetFormattedLockTokens(lockTokens);
 0147                this.MessageCompleteStart(clientId, messageCount, formattedLockTokens);
 148            }
 0149        }
 150
 151        [Event(13, Level = EventLevel.Informational, Message = "{0}: CompleteAsync start. MessageCount = {1}, LockTokens
 152        void MessageCompleteStart(string clientId, int messageCount, string lockTokens)
 153        {
 0154            this.WriteEvent(13, clientId, messageCount, lockTokens);
 0155        }
 156
 157        [Event(14, Level = EventLevel.Informational, Message = "{0}: CompleteAsync done.")]
 158        public void MessageCompleteStop(string clientId)
 159        {
 0160            if (this.IsEnabled())
 161            {
 0162                this.WriteEvent(14, clientId);
 163            }
 0164        }
 165
 166        [NonEvent]
 167        public void MessageCompleteException(string clientId, Exception exception)
 168        {
 0169            if (this.IsEnabled())
 170            {
 0171                this.MessageCompleteException(clientId, exception.ToString());
 172            }
 0173        }
 174
 175        [Event(15, Level = EventLevel.Error, Message = "{0}: CompleteAsync Exception: {1}.")]
 176        void MessageCompleteException(string clientId, string exception)
 177        {
 0178            this.WriteEvent(15, clientId, exception);
 0179        }
 180
 181        [Event(16, Level = EventLevel.Informational, Message = "{0}: AbandonAsync start. MessageCount = {1}, LockToken =
 182        public void MessageAbandonStart(string clientId, int messageCount, string lockToken)
 183        {
 0184            if (this.IsEnabled())
 185            {
 0186                this.WriteEvent(16, clientId, messageCount, lockToken);
 187            }
 0188        }
 189
 190        [Event(17, Level = EventLevel.Informational, Message = "{0}: AbandonAsync done.")]
 191        public void MessageAbandonStop(string clientId)
 192        {
 0193            if (this.IsEnabled())
 194            {
 0195                this.WriteEvent(17, clientId);
 196            }
 0197        }
 198
 199        [NonEvent]
 200        public void MessageAbandonException(string clientId, Exception exception)
 201        {
 0202            if (this.IsEnabled())
 203            {
 0204                this.MessageAbandonException(clientId, exception.ToString());
 205            }
 0206        }
 207
 208        [Event(18, Level = EventLevel.Error, Message = "{0}: AbandonAsync Exception: {1}.")]
 209        void MessageAbandonException(string clientId, string exception)
 210        {
 0211            this.WriteEvent(18, clientId, exception);
 0212        }
 213
 214        [Event(19, Level = EventLevel.Informational, Message = "{0}: DeferAsync start. MessageCount = {1}, LockToken = {
 215        public void MessageDeferStart(string clientId, int messageCount, string lockToken)
 216        {
 0217            if (this.IsEnabled())
 218            {
 0219                this.WriteEvent(19, clientId, messageCount, lockToken);
 220            }
 0221        }
 222
 223        [Event(20, Level = EventLevel.Informational, Message = "{0}: DeferAsync done.")]
 224        public void MessageDeferStop(string clientId)
 225        {
 0226            if (this.IsEnabled())
 227            {
 0228                this.WriteEvent(20, clientId);
 229            }
 0230        }
 231
 232        [NonEvent]
 233        public void MessageDeferException(string clientId, Exception exception)
 234        {
 0235            if (this.IsEnabled())
 236            {
 0237                this.MessageDeferException(clientId, exception.ToString());
 238            }
 0239        }
 240
 241        [Event(21, Level = EventLevel.Error, Message = "{0}: DeferAsync Exception: {1}.")]
 242        void MessageDeferException(string clientId, string exception)
 243        {
 0244                this.WriteEvent(21, clientId, exception);
 0245        }
 246
 247        [Event(22, Level = EventLevel.Informational, Message = "{0}: DeadLetterAsync start. MessageCount = {1}, LockToke
 248        public void MessageDeadLetterStart(string clientId, int messageCount, string lockToken)
 249        {
 0250            if (this.IsEnabled())
 251            {
 0252                this.WriteEvent(22, clientId, messageCount, lockToken);
 253            }
 0254        }
 255
 256        [Event(23, Level = EventLevel.Informational, Message = "{0}: DeadLetterAsync done.")]
 257        public void MessageDeadLetterStop(string clientId)
 258        {
 0259            if (this.IsEnabled())
 260            {
 0261                this.WriteEvent(23, clientId);
 262            }
 0263        }
 264
 265        [NonEvent]
 266        public void MessageDeadLetterException(string clientId, Exception exception)
 267        {
 0268            if (this.IsEnabled())
 269            {
 0270                this.MessageDeadLetterException(clientId, exception.ToString());
 271            }
 0272        }
 273
 274        [Event(24, Level = EventLevel.Error, Message = "{0}: DeadLetterAsync Exception: {1}.")]
 275        void MessageDeadLetterException(string clientId, string exception)
 276        {
 0277            this.WriteEvent(24, clientId, exception);
 0278        }
 279
 280        [Event(25, Level = EventLevel.Informational, Message = "{0}: RenewLockAsync start. MessageCount = {1}, LockToken
 281        public void MessageRenewLockStart(string clientId, int messageCount, string lockToken)
 282        {
 0283            if (this.IsEnabled())
 284            {
 0285                this.WriteEvent(25, clientId, messageCount, lockToken);
 286            }
 0287        }
 288
 289        [Event(26, Level = EventLevel.Informational, Message = "{0}: RenewLockAsync done.")]
 290        public void MessageRenewLockStop(string clientId)
 291        {
 0292            if (this.IsEnabled())
 293            {
 0294                this.WriteEvent(26, clientId);
 295            }
 0296        }
 297
 298        [NonEvent]
 299        public void MessageRenewLockException(string clientId, Exception exception)
 300        {
 0301            if (this.IsEnabled())
 302            {
 0303                this.MessageRenewLockException(clientId, exception.ToString());
 304            }
 0305        }
 306
 307        [Event(27, Level = EventLevel.Error, Message = "{0}: RenewLockAsync Exception: {1}.")]
 308        void MessageRenewLockException(string clientId, string exception)
 309        {
 0310            this.WriteEvent(27, clientId, exception);
 0311        }
 312
 313        [NonEvent]
 314        public void MessageReceiveDeferredMessageStart(string clientId, int messageCount, IEnumerable<long> sequenceNumb
 315        {
 0316            if (this.IsEnabled())
 317            {
 0318                var formattedSequenceNumbers = StringUtility.GetFormattedSequenceNumbers(sequenceNumbers);
 0319                this.MessageReceiveDeferredMessageStart(clientId, messageCount, formattedSequenceNumbers);
 320            }
 0321        }
 322
 323        [Event(28, Level = EventLevel.Informational, Message = "{0}: ReceiveDeferredMessageAsync start. MessageCount = {
 324        void MessageReceiveDeferredMessageStart(string clientId, int messageCount, string sequenceNumbers)
 325        {
 0326            this.WriteEvent(28, clientId, messageCount, sequenceNumbers);
 0327        }
 328
 329        [Event(29, Level = EventLevel.Informational, Message = "{0}: ReceiveDeferredMessageAsync done. Received '{1}' me
 330        public void MessageReceiveDeferredMessageStop(string clientId, int messageCount)
 331        {
 0332            if (this.IsEnabled())
 333            {
 0334                this.WriteEvent(29, clientId, messageCount);
 335            }
 0336        }
 337
 338        [NonEvent]
 339        public void MessageReceiveDeferredMessageException(string clientId, Exception exception)
 340        {
 0341            if (this.IsEnabled())
 342            {
 0343                this.MessageReceiveDeferredMessageException(clientId, exception.ToString());
 344            }
 0345        }
 346
 347        [Event(30, Level = EventLevel.Error, Message = "{0}: ReceiveDeferredMessageAsync Exception: {1}.")]
 348        void MessageReceiveDeferredMessageException(string clientId, string exception)
 349        {
 0350            this.WriteEvent(30, clientId, exception);
 0351        }
 352
 353        // Unused - 31;32;33
 354
 355        [NonEvent]
 356        public void AmqpSendLinkCreateStart(string clientId, MessagingEntityType? entityType, string entityPath)
 357        {
 0358            if (this.IsEnabled())
 359            {
 0360                this.AmqpSendLinkCreateStart(clientId, entityType?.ToString() ?? string.Empty, entityPath);
 361            }
 0362        }
 363
 364        [Event(34, Level = EventLevel.Informational, Message = "{0}: AmqpSendLinkCreate started. EntityType: {1}, Entity
 365        void AmqpSendLinkCreateStart(string clientId, string entityType, string entityPath)
 366        {
 0367            this.WriteEvent(34, clientId, entityType, entityPath);
 0368        }
 369
 370        [Event(35, Level = EventLevel.Informational, Message = "{0}: AmqpSendLinkCreate done.")]
 371        public void AmqpSendLinkCreateStop(string clientId)
 372        {
 0373            if (this.IsEnabled())
 374            {
 0375                this.WriteEvent(35, clientId);
 376            }
 0377        }
 378
 379        [NonEvent]
 380        public void AmqpReceiveLinkCreateStart(string clientId, bool isRequestResponseLink, MessagingEntityType? entityT
 381        {
 0382            if (this.IsEnabled())
 383            {
 0384                this.AmqpReceiveLinkCreateStart(clientId, isRequestResponseLink.ToString(), entityType?.ToString() ?? st
 385            }
 0386        }
 387
 388        [Event(36, Level = EventLevel.Informational, Message = "{0}: AmqpReceiveLinkCreate started. IsRequestResponseLin
 389        void AmqpReceiveLinkCreateStart(string clientId, string isRequestResponseLink, string entityType, string entityP
 390        {
 0391            this.WriteEvent(36, clientId, isRequestResponseLink, entityType, entityPath);
 0392        }
 393
 394        [Event(37, Level = EventLevel.Informational, Message = "{0}: AmqpReceiveLinkCreate done.")]
 395        public void AmqpReceiveLinkCreateStop(string clientId)
 396        {
 0397            if (this.IsEnabled())
 398            {
 0399                this.WriteEvent(37, clientId);
 400            }
 0401        }
 402
 403        [Event(38, Level = EventLevel.Verbose, Message = "AmqpGetOrCreateConnection started.")]
 404        public void AmqpGetOrCreateConnectionStart()
 405        {
 0406            if (this.IsEnabled())
 407            {
 0408                this.WriteEvent(38);
 409            }
 0410        }
 411
 412        [Event(39, Level = EventLevel.Verbose, Message = "AmqpGetOrCreateConnection done. EntityPath: {0}, ConnectionInf
 413        public void AmqpGetOrCreateConnectionStop(string entityPath, string connectionInfo, string connectionState)
 414        {
 0415            if (this.IsEnabled())
 416            {
 0417                this.WriteEvent(39, entityPath, connectionInfo, connectionState);
 418            }
 0419        }
 420
 421        [NonEvent]
 422        public void AmqpSendAuthenticationTokenStart(Uri address, string audience, string resource, string[] claims)
 423        {
 0424            if (this.IsEnabled())
 425            {
 0426                this.AmqpSendAuthenticationTokenStart(address.ToString(), audience, resource, claims.ToString());
 427            }
 0428        }
 429
 430        [Event(40, Level = EventLevel.Verbose, Message = "AmqpSendAuthenticanToken started. Address: {0}, Audience: {1},
 431        void AmqpSendAuthenticationTokenStart(string address, string audience, string resource, string claims)
 432        {
 0433            this.WriteEvent(40, address, audience, resource, claims);
 0434        }
 435
 436        [Event(41, Level = EventLevel.Verbose, Message = "AmqpSendAuthenticanToken done.")]
 437        public void AmqpSendAuthenticationTokenStop()
 438        {
 0439            if (this.IsEnabled())
 440            {
 0441                this.WriteEvent(41);
 442            }
 0443        }
 444
 445        [Event(42, Level = EventLevel.Informational, Message = "{0}: MessagePeekAsync start. SequenceNumber = {1}, Messa
 446        public void MessagePeekStart(string clientId, long sequenceNumber, int messageCount)
 447        {
 0448            if (this.IsEnabled())
 449            {
 0450                this.WriteEvent(42, clientId, sequenceNumber, messageCount);
 451            }
 0452        }
 453
 454        [Event(43, Level = EventLevel.Informational, Message = "{0}: MessagePeekAsync done. Peeked '{1}' messages")]
 455        public void MessagePeekStop(string clientId, int messageCount)
 456        {
 0457            if (this.IsEnabled())
 458            {
 0459                this.WriteEvent(43, clientId, messageCount);
 460            }
 0461        }
 462
 463        [NonEvent]
 464        public void MessagePeekException(string clientId, Exception exception)
 465        {
 0466            if (this.IsEnabled())
 467            {
 0468                this.MessagePeekException(clientId, exception.ToString());
 469            }
 0470        }
 471
 472        [Event(44, Level = EventLevel.Error, Message = "{0}: MessagePeekAsync Exception: {1}.")]
 473        void MessagePeekException(string clientId, string exception)
 474        {
 0475            this.WriteEvent(44, clientId, exception);
 0476        }
 477
 478        [Event(45, Level = EventLevel.Informational, Message = "Creating MessageSender (Namespace '{0}'; Entity '{1}')."
 479        public void MessageSenderCreateStart(string namespaceName, string entityName)
 480        {
 12481            if (this.IsEnabled())
 482            {
 0483                this.WriteEvent(45, namespaceName, entityName);
 484            }
 12485        }
 486
 487        [Event(46, Level = EventLevel.Informational, Message = "MessageSender (Namespace '{0}'; Entity '{1}'; ClientId '
 488        public void MessageSenderCreateStop(string namespaceName, string entityName, string clientId)
 489        {
 12490            if (this.IsEnabled())
 491            {
 0492                this.WriteEvent(46, namespaceName, entityName, clientId);
 493            }
 12494        }
 495
 496        [Event(47, Level = EventLevel.Informational, Message = "Creating MessageReceiver (Namespace '{0}'; Entity '{1}';
 497        public void MessageReceiverCreateStart(string namespaceName, string entityName, string receiveMode)
 498        {
 0499            if (this.IsEnabled())
 500            {
 0501                this.WriteEvent(47, namespaceName, entityName, receiveMode);
 502            }
 0503        }
 504
 505        [Event(48, Level = EventLevel.Informational, Message = "MessageReceiver (Namespace '{0}'; Entity '{1}'; ClientId
 506        public void MessageReceiverCreateStop(string namespaceName, string entityName, string clientId)
 507        {
 0508            if (this.IsEnabled())
 509            {
 0510                this.WriteEvent(48, namespaceName, entityName, clientId);
 511            }
 0512        }
 513
 514        [NonEvent]
 515        public void ScheduleMessageStart(string clientId, DateTimeOffset scheduleEnqueueTimeUtc)
 516        {
 0517            if (this.IsEnabled())
 518            {
 0519                this.ScheduleMessageStart(clientId, scheduleEnqueueTimeUtc.ToString());
 520            }
 0521        }
 522
 523        [Event(49, Level = EventLevel.Informational, Message = "{0}: ScheduleMessageAsync start. ScheduleTimeUtc = {1}")
 524        void ScheduleMessageStart(string clientId, string scheduleEnqueueTimeUtc)
 525        {
 0526            if (this.IsEnabled())
 527            {
 0528                this.WriteEvent(49, clientId, scheduleEnqueueTimeUtc);
 529            }
 0530        }
 531
 532        [Event(50, Level = EventLevel.Informational, Message = "{0}: ScheduleMessageAsync done.")]
 533        public void ScheduleMessageStop(string clientId)
 534        {
 0535            if (this.IsEnabled())
 536            {
 0537                this.WriteEvent(50, clientId);
 538            }
 0539        }
 540
 541        [NonEvent]
 542        public void ScheduleMessageException(string clientId, Exception exception)
 543        {
 0544            if (this.IsEnabled())
 545            {
 0546                this.ScheduleMessageException(clientId, exception.ToString());
 547            }
 0548        }
 549
 550        [Event(51, Level = EventLevel.Error, Message = "{0}: ScheduleMessageAsync Exception: {1}.")]
 551        void ScheduleMessageException(string clientId, string exception)
 552        {
 0553            this.WriteEvent(51, clientId, exception);
 0554        }
 555
 556        [Event(52, Level = EventLevel.Informational, Message = "{0}: CancelScheduledMessageAsync start. SequenceNumber =
 557        public void CancelScheduledMessageStart(string clientId, long sequenceNumber)
 558        {
 0559            if (this.IsEnabled())
 560            {
 0561                this.WriteEvent(52, clientId, sequenceNumber);
 562            }
 0563        }
 564
 565        [Event(53, Level = EventLevel.Informational, Message = "{0}: CancelScheduledMessageAsync done.")]
 566        public void CancelScheduledMessageStop(string clientId)
 567        {
 0568            if (this.IsEnabled())
 569            {
 0570                this.WriteEvent(53, clientId);
 571            }
 0572        }
 573
 574        [NonEvent]
 575        public void CancelScheduledMessageException(string clientId, Exception exception)
 576        {
 0577            if (this.IsEnabled())
 578            {
 0579                this.CancelScheduledMessageException(clientId, exception.ToString());
 580            }
 0581        }
 582
 583        [Event(54, Level = EventLevel.Error, Message = "{0}: CancelScheduledMessageAsync Exception: {1}.")]
 584        void CancelScheduledMessageException(string clientId, string exception)
 585        {
 0586            this.WriteEvent(54, clientId, exception);
 0587        }
 588
 589        [Event(55, Level = EventLevel.Informational, Message = "{0}: AddRuleAsync start. RuleName = {1}")]
 590        public void AddRuleStart(string clientId, string ruleName)
 591        {
 0592            if (this.IsEnabled())
 593            {
 0594                this.WriteEvent(55, clientId, ruleName);
 595            }
 0596        }
 597
 598        [Event(56, Level = EventLevel.Informational, Message = "{0}: AddRuleAsync done.")]
 599        public void AddRuleStop(string clientId)
 600        {
 0601            if (this.IsEnabled())
 602            {
 0603                this.WriteEvent(56, clientId);
 604            }
 0605        }
 606
 607        [NonEvent]
 608        public void AddRuleException(string clientId, Exception exception)
 609        {
 0610            if (this.IsEnabled())
 611            {
 0612                this.AddRuleException(clientId, exception.ToString());
 613            }
 0614        }
 615
 616        [Event(57, Level = EventLevel.Error, Message = "{0}: AddRuleAsync Exception: {1}.")]
 617        void AddRuleException(string clientId, string exception)
 618        {
 0619            this.WriteEvent(57, clientId, exception);
 0620        }
 621
 622        [Event(58, Level = EventLevel.Informational, Message = "{0}: RemoveRuleAsync start. RuleName = {1}")]
 623        public void RemoveRuleStart(string clientId, string ruleName)
 624        {
 0625            if (this.IsEnabled())
 626            {
 0627                this.WriteEvent(58, clientId, ruleName);
 628            }
 0629        }
 630
 631        [Event(59, Level = EventLevel.Informational, Message = "{0}: RemoveRuleAsync done.")]
 632        public void RemoveRuleStop(string clientId)
 633        {
 0634            if (this.IsEnabled())
 635            {
 0636                this.WriteEvent(59, clientId);
 637            }
 0638        }
 639
 640        [NonEvent]
 641        public void RemoveRuleException(string clientId, Exception exception)
 642        {
 0643            if (this.IsEnabled())
 644            {
 0645                this.RemoveRuleException(clientId, exception.ToString());
 646            }
 0647        }
 648
 649        [Event(60, Level = EventLevel.Error, Message = "{0}: RemoveRuleAsync Exception: {1}.")]
 650        void RemoveRuleException(string clientId, string exception)
 651        {
 0652            this.WriteEvent(60, clientId, exception);
 0653        }
 654
 655        [NonEvent]
 656        public void RegisterOnMessageHandlerStart(string clientId, MessageHandlerOptions registerHandlerOptions)
 657        {
 0658            if (this.IsEnabled())
 659            {
 0660                this.RegisterOnMessageHandlerStart(clientId, registerHandlerOptions.AutoComplete, registerHandlerOptions
 661            }
 0662        }
 663
 664        [Event(61, Level = EventLevel.Informational, Message = "{0}: Register OnMessageHandler start: OnMessage Options:
 665        void RegisterOnMessageHandlerStart(string clientId, bool autoComplete, bool autorenewLock, int maxConcurrentCall
 666        {
 0667            this.WriteEvent(61, clientId, autoComplete, autorenewLock, maxConcurrentCalls, autorenewTimeoutInSeconds);
 0668        }
 669
 670        [Event(62, Level = EventLevel.Informational, Message = "{0}: Register OnMessageHandler done.")]
 671        public void RegisterOnMessageHandlerStop(string clientId)
 672        {
 0673            if (this.IsEnabled())
 674            {
 0675                this.WriteEvent(62, clientId);
 676            }
 0677        }
 678
 679        [NonEvent]
 680        public void RegisterOnMessageHandlerException(string clientId, Exception exception)
 681        {
 0682            if (this.IsEnabled())
 683            {
 0684                this.RegisterOnMessageHandlerException(clientId, exception.ToString());
 685            }
 0686        }
 687
 688        [Event(63, Level = EventLevel.Error, Message = "{0}: Register OnMessageHandler Exception: {1}")]
 689        void RegisterOnMessageHandlerException(string clientId, string exception)
 690        {
 0691            this.WriteEvent(63, clientId, exception);
 0692        }
 693
 694        [NonEvent]
 695        public void MessageReceiverPumpTaskStart(string clientId, Message message, int currentSemaphoreCount)
 696        {
 0697            if (this.IsEnabled())
 698            {
 0699                this.MessageReceiverPumpTaskStart(clientId, message?.SystemProperties.SequenceNumber ?? -1, currentSemap
 700            }
 0701        }
 702
 703        [Event(66, Level = EventLevel.Informational, Message = "{0}: MessageReceiverPump PumpTask Started: Message: Sequ
 704        void MessageReceiverPumpTaskStart(string clientId, long sequenceNumber, int currentSemaphoreCount)
 705        {
 0706            this.WriteEvent(66, clientId, sequenceNumber, currentSemaphoreCount);
 0707        }
 708
 709        [Event(67, Level = EventLevel.Informational, Message = "{0}: MessageReceiverPump PumpTask done: Available Semaph
 710        public void MessageReceiverPumpTaskStop(string clientId, int currentSemaphoreCount)
 711        {
 0712            if (this.IsEnabled())
 713            {
 0714                this.WriteEvent(67, clientId, currentSemaphoreCount);
 715            }
 0716        }
 717
 718        [NonEvent]
 719        public void MessageReceivePumpTaskException(string clientId, string sessionId, Exception exception)
 720        {
 0721            if (this.IsEnabled())
 722            {
 0723                this.MessageReceivePumpTaskException(clientId, sessionId, exception.ToString());
 724            }
 0725        }
 726
 727        [Event(68, Level = EventLevel.Error, Message = "{0}: MessageReceiverPump PumpTask Exception: SessionId: {1}, Exc
 728        void MessageReceivePumpTaskException(string clientId, string sessionId, string exception)
 729        {
 0730            this.WriteEvent(68, clientId, sessionId, exception);
 0731        }
 732
 733        [NonEvent]
 734        public void MessageReceiverPumpDispatchTaskStart(string clientId, Message message)
 735        {
 0736            if (this.IsEnabled())
 737            {
 0738                this.MessageReceiverPumpDispatchTaskStart(clientId, message?.SystemProperties.SequenceNumber ?? -1);
 739            }
 0740        }
 741
 742        [Event(69, Level = EventLevel.Informational, Message = "{0}: MessageReceiverPump DispatchTask start: Message: Se
 743        void MessageReceiverPumpDispatchTaskStart(string clientId, long sequenceNumber)
 744        {
 0745            this.WriteEvent(69, clientId, sequenceNumber);
 0746        }
 747
 748        [NonEvent]
 749        public void MessageReceiverPumpDispatchTaskStop(string clientId, Message message, int currentSemaphoreCount)
 750        {
 0751            if (this.IsEnabled())
 752            {
 0753                this.MessageReceiverPumpDispatchTaskStop(clientId, message?.SystemProperties.SequenceNumber ?? -1, curre
 754            }
 0755        }
 756
 757        [Event(70, Level = EventLevel.Informational, Message = "{0}: MessageReceiverPump DispatchTask done: Message: Seq
 758        void MessageReceiverPumpDispatchTaskStop(string clientId, long sequenceNumber, int currentSemaphoreCount)
 759        {
 0760            this.WriteEvent(70, clientId, sequenceNumber, currentSemaphoreCount);
 0761        }
 762
 763        [NonEvent]
 764        public void MessageReceiverPumpUserCallbackStart(string clientId, Message message)
 765        {
 0766            if (this.IsEnabled())
 767            {
 0768                this.MessageReceiverPumpUserCallbackStart(clientId, message?.SystemProperties.SequenceNumber ?? -1);
 769            }
 0770        }
 771
 772        [Event(71, Level = EventLevel.Informational, Message = "{0}: MessageReceiverPump UserCallback start: Message: Se
 773        void MessageReceiverPumpUserCallbackStart(string clientId, long sequenceNumber)
 774        {
 0775            this.WriteEvent(71, clientId, sequenceNumber);
 0776        }
 777
 778        [NonEvent]
 779        public void MessageReceiverPumpUserCallbackStop(string clientId, Message message)
 780        {
 0781            if (this.IsEnabled())
 782            {
 0783                this.MessageReceiverPumpUserCallbackStop(clientId, message?.SystemProperties.SequenceNumber ?? -1);
 784            }
 0785        }
 786
 787        [Event(72, Level = EventLevel.Informational, Message = "{0}: MessageReceiverPump UserCallback done: Message: Seq
 788        void MessageReceiverPumpUserCallbackStop(string clientId, long sequenceNumber)
 789        {
 0790            this.WriteEvent(72, clientId, sequenceNumber);
 0791        }
 792
 793        [NonEvent]
 794        public void MessageReceiverPumpUserCallbackException(string clientId, Message message, Exception exception)
 795        {
 0796            if (this.IsEnabled())
 797            {
 0798                this.MessageReceiverPumpUserCallbackException(clientId, message?.SystemProperties.SequenceNumber ?? -1, 
 799            }
 0800        }
 801
 802        [Event(73, Level = EventLevel.Error, Message = "{0}: MessageReceiverPump UserCallback Exception: Message: Sequen
 803        void MessageReceiverPumpUserCallbackException(string clientId, long sequenceNumber, string exception)
 804        {
 0805            this.WriteEvent(73, clientId, sequenceNumber, exception);
 0806        }
 807
 808        [NonEvent]
 809        public void MessageReceiverPumpRenewMessageStart(string clientId, Message message, TimeSpan renewAfterTimeSpan)
 810        {
 0811            if (this.IsEnabled())
 812            {
 0813                this.MessageReceiverPumpRenewMessageStart(clientId, message?.SystemProperties.SequenceNumber ?? -1, (lon
 814            }
 0815        }
 816
 817        [Event(74, Level = EventLevel.Informational, Message = "{0}: MessageReceiverPump RenewMessage start: Message: Se
 818        void MessageReceiverPumpRenewMessageStart(string clientId, long sequenceNumber, long renewAfterTimeSpanInSeconds
 819        {
 0820            this.WriteEvent(74, clientId, sequenceNumber, renewAfterTimeSpanInSeconds);
 0821        }
 822
 823        [NonEvent]
 824        public void MessageReceiverPumpRenewMessageStop(string clientId, Message message)
 825        {
 0826            if (this.IsEnabled())
 827            {
 0828                this.MessageReceiverPumpRenewMessageStop(clientId, message?.SystemProperties.SequenceNumber ?? -1);
 829            }
 0830        }
 831
 832        [Event(75, Level = EventLevel.Informational, Message = "{0}: MessageReceiverPump RenewMessage done: Message: Seq
 833        void MessageReceiverPumpRenewMessageStop(string clientId, long sequenceNumber)
 834        {
 0835            this.WriteEvent(75, clientId, sequenceNumber);
 0836        }
 837
 838        [NonEvent]
 839        public void MessageReceiverPumpRenewMessageException(string clientId, Message message, Exception exception)
 840        {
 0841            if (this.IsEnabled())
 842            {
 0843                this.MessageReceiverPumpRenewMessageException(clientId, message?.SystemProperties.SequenceNumber ?? -1, 
 844            }
 0845        }
 846
 847        [Event(76, Level = EventLevel.Error, Message = "{0}: MessageReceiverPump RenewMessage Exception: Message: Sequen
 848        void MessageReceiverPumpRenewMessageException(string clientId, long sequenceNumber, string exception)
 849        {
 0850            this.WriteEvent(76, clientId, sequenceNumber, exception);
 0851        }
 852
 853        [NonEvent]
 854        public void RunOperationExceptionEncountered(Exception exception)
 855        {
 4856            if (this.IsEnabled())
 857            {
 0858                this.RunOperationExceptionEncountered(exception.ToString());
 859            }
 4860        }
 861
 862        [Event(77, Level = EventLevel.Warning, Message = "RunOperation encountered an exception and will retry. Exceptio
 863        void RunOperationExceptionEncountered(string exception)
 864        {
 0865            this.WriteEvent(77, exception);
 0866        }
 867
 868        [NonEvent]
 869        public void RegisterOnSessionHandlerStart(string clientId, SessionHandlerOptions sessionHandlerOptions)
 870        {
 0871            if (this.IsEnabled())
 872            {
 0873                this.RegisterOnSessionHandlerStart(clientId, sessionHandlerOptions.AutoComplete, sessionHandlerOptions.M
 874            }
 0875        }
 876
 877        [Event(78, Level = EventLevel.Informational, Message = "{0}: Register OnSessionHandler start: RegisterSessionHan
 878        void RegisterOnSessionHandlerStart(string clientId, bool autoComplete, int maxConcurrentSessions, long messageWa
 879        {
 0880            this.WriteEvent(78, clientId, autoComplete, maxConcurrentSessions, messageWaitTimeoutInSeconds, autorenewTim
 0881        }
 882
 883        [Event(79, Level = EventLevel.Informational, Message = "{0}: Register OnSessionHandler done.")]
 884        public void RegisterOnSessionHandlerStop(string clientId)
 885        {
 0886            if (this.IsEnabled())
 887            {
 0888                this.WriteEvent(79, clientId);
 889            }
 0890        }
 891
 892        [NonEvent]
 893        public void RegisterOnSessionHandlerException(string clientId, Exception exception)
 894        {
 0895            if (this.IsEnabled())
 896            {
 0897                this.RegisterOnSessionHandlerException(clientId, exception.ToString());
 898            }
 0899        }
 900
 901        [Event(80, Level = EventLevel.Error, Message = "{0}: Register OnSessionHandler Exception: {1}")]
 902        void RegisterOnSessionHandlerException(string clientId, string exception)
 903        {
 0904            this.WriteEvent(80, clientId, exception);
 0905        }
 906
 907        [NonEvent]
 908        public void SessionReceivePumpSessionReceiveException(string clientId, Exception exception)
 909        {
 0910            if (this.IsEnabled())
 911            {
 0912                this.SessionReceivePumpSessionReceiveException(clientId, exception.ToString());
 913            }
 0914        }
 915
 916        [Event(81, Level = EventLevel.Error, Message = "{0}: Exception while Receving a session: SessionId: {1}")]
 917        void SessionReceivePumpSessionReceiveException(string clientId, string exception)
 918        {
 0919            this.WriteEvent(81, clientId, exception);
 0920        }
 921
 922        [Event(82, Level = EventLevel.Informational, Message = "{0}: Session has no more messages: SessionId: {1}")]
 923        public void SessionReceivePumpSessionEmpty(string clientId, string sessionId)
 924        {
 0925            if (this.IsEnabled())
 926            {
 0927                this.WriteEvent(82, clientId, sessionId);
 928            }
 0929        }
 930
 931        [Event(83, Level = EventLevel.Informational, Message = "{0}: Session closed: SessionId: {1}")]
 932        public void SessionReceivePumpSessionClosed(string clientId, string sessionId)
 933        {
 0934            if (this.IsEnabled())
 935            {
 0936                this.WriteEvent(83, clientId, sessionId);
 937            }
 0938        }
 939
 940        [NonEvent]
 941        public void SessionReceivePumpSessionCloseException(string clientId, string sessionId, Exception exception)
 942        {
 0943            if (this.IsEnabled())
 944            {
 0945                this.SessionReceivePumpSessionCloseException(clientId, sessionId, exception.ToString());
 946            }
 0947        }
 948
 949        [Event(84, Level = EventLevel.Error, Message = "{0}: Exception while closing session: SessionId: {1}, Exception:
 950        void SessionReceivePumpSessionCloseException(string clientId, string sessionId, string exception)
 951        {
 0952            this.WriteEvent(84, clientId, sessionId, exception);
 0953        }
 954
 955        [NonEvent]
 956        public void SessionReceivePumpSessionRenewLockStart(string clientId, string sessionId, TimeSpan renewAfterTimeSp
 957        {
 0958            if (this.IsEnabled())
 959            {
 0960                this.SessionReceivePumpSessionRenewLockStart(clientId, sessionId, (long)renewAfterTimeSpan.TotalSeconds)
 961            }
 0962        }
 963
 964        [Event(85, Level = EventLevel.Informational, Message = "{0}: SessionRenewLock start. SessionId: {1}, RenewAfterT
 965        void SessionReceivePumpSessionRenewLockStart(string clientId, string sessionId, long totalSeconds)
 966        {
 0967            this.WriteEvent(85, clientId, sessionId, totalSeconds);
 0968        }
 969
 970        [Event(86, Level = EventLevel.Informational, Message = "{0}: RenewSession done: SessionId: {1}")]
 971        public void SessionReceivePumpSessionRenewLockStop(string clientId, string sessionId)
 972        {
 0973            if (this.IsEnabled())
 974            {
 0975                this.WriteEvent(86, clientId, sessionId);
 976            }
 0977        }
 978
 979        [NonEvent]
 980        public void SessionReceivePumpSessionRenewLockException(string clientId, string sessionId, Exception exception)
 981        {
 0982            if (this.IsEnabled())
 983            {
 0984                this.SessionReceivePumpSessionRenewLockException(clientId, sessionId, exception.ToString());
 985            }
 0986        }
 987
 988        [Event(87, Level = EventLevel.Error, Message = "{0}: Exception while renewing session lock: SessionId: {1}, Exce
 989        void SessionReceivePumpSessionRenewLockException(string clientId, string sessionId, string exception)
 990        {
 0991            this.WriteEvent(87, clientId, sessionId, exception);
 0992        }
 993
 994        [NonEvent]
 995        public void AmqpSessionClientAcceptMessageSessionStart(string clientId, string entityPath, ReceiveMode receiveMo
 996        {
 0997            if (this.IsEnabled())
 998            {
 0999                this.AmqpSessionClientAcceptMessageSessionStart(clientId, entityPath, receiveMode.ToString(), prefetchCo
 1000            }
 01001        }
 1002
 1003        [Event(88, Level = EventLevel.Informational, Message = "{0}: AcceptMessageSession start: EntityPath: {1}, Receiv
 1004        void AmqpSessionClientAcceptMessageSessionStart(string clientId, string entityPath, string receiveMode, int pref
 1005        {
 01006            this.WriteEvent(88, clientId, entityPath, receiveMode, prefetchCount, sessionId);
 01007        }
 1008
 1009        [Event(89, Level = EventLevel.Informational, Message = "{0}: AcceptMessageSession done: EntityPath: {1}, Session
 1010        public void AmqpSessionClientAcceptMessageSessionStop(string clientId, string entityPath, string sessionId)
 1011        {
 01012            if (this.IsEnabled())
 1013            {
 01014                this.WriteEvent(89, clientId, entityPath, sessionId);
 1015            }
 01016        }
 1017
 1018        [NonEvent]
 1019        public void AmqpSessionClientAcceptMessageSessionException(string clientId, string entityPath, Exception excepti
 1020        {
 01021            if (this.IsEnabled())
 1022            {
 01023                this.AmqpSessionClientAcceptMessageSessionException(clientId, entityPath, exception.ToString());
 1024            }
 01025        }
 1026
 1027        [Event(90, Level = EventLevel.Error, Message = "{0}: AcceptMessageSession Exception: EntityPath: {1}, Exception:
 1028        void AmqpSessionClientAcceptMessageSessionException(string clientId, string entityPath, string exception)
 1029        {
 01030            this.WriteEvent(90, clientId, entityPath, exception);
 01031        }
 1032
 1033        [NonEvent]
 1034        public void AmqpLinkCreationException(string entityPath, AmqpSession session, AmqpConnection connection, Excepti
 1035        {
 01036            if (this.IsEnabled())
 1037            {
 01038                this.AmqpLinkCreationException(entityPath, session.ToString(), session.State.ToString(), session.GetInne
 1039            }
 01040        }
 1041
 1042        [Event(91, Level = EventLevel.Error, Message = "AmqpLinkCreatorException Exception: EntityPath: {0}, SessionStri
 1043        void AmqpLinkCreationException(string entityPath, string session, string sessionState, string terminalException,
 1044        {
 01045            this.WriteEvent(91, entityPath, session, sessionState, terminalException, connectionInfo, connectionState, e
 01046        }
 1047
 1048        [NonEvent]
 1049        public void AmqpConnectionCreated(string hostName, AmqpConnection connection)
 1050        {
 01051            if (this.IsEnabled())
 1052            {
 01053                this.AmqpConnectionCreated(hostName, connection.ToString(), connection.State.ToString());
 1054            }
 01055        }
 1056
 1057        [Event(92, Level = EventLevel.Verbose, Message = "AmqpConnectionCreated: HostName: {0}, ConnectionInfo: {1}, Con
 1058        void AmqpConnectionCreated(string hostName, string connectionInfo, string connectionState)
 1059        {
 01060            this.WriteEvent(92, hostName, connectionInfo, connectionState);
 01061        }
 1062
 1063        [NonEvent]
 1064        public void AmqpConnectionClosed(AmqpConnection connection)
 1065        {
 01066            if (this.IsEnabled())
 1067            {
 01068                this.AmqpConnectionClosed(connection.RemoteEndpoint, connection.ToString(), connection.State.ToString())
 1069            }
 01070        }
 1071
 1072        [Event(93, Level = EventLevel.Verbose, Message = "AmqpConnectionClosed: HostName: {0}, ConnectionInfo: {1}, Conn
 1073        public void AmqpConnectionClosed(string hostName, string connectionInfo, string connectionState)
 1074        {
 01075            this.WriteEvent(93, hostName, connectionInfo, connectionState);
 01076        }
 1077
 1078        [NonEvent]
 1079        public void AmqpSessionCreationException(string entityPath, AmqpConnection connection, Exception exception)
 1080        {
 01081            if (this.IsEnabled())
 1082            {
 01083                this.AmqpSessionCreationException(entityPath, connection.ToString(), connection.State.ToString(), except
 1084            }
 01085        }
 1086
 1087        [Event(94, Level = EventLevel.Error, Message = "AmqpSessionCreationException Exception: EntityPath: {0}, Connect
 1088        void AmqpSessionCreationException(string entityPath, string connectionInfo, string connectionState, string excep
 1089        {
 01090            this.WriteEvent(94, entityPath, connectionInfo, connectionState, exception);
 01091        }
 1092
 1093        [Event(95, Level = EventLevel.Verbose, Message = "User plugin {0} called on message {1}")]
 1094        public void PluginCallStarted(string pluginName, string messageId)
 1095        {
 01096            if (this.IsEnabled())
 1097            {
 01098                this.WriteEvent(95, pluginName, messageId);
 1099            }
 01100        }
 1101
 1102        [Event(96, Level = EventLevel.Verbose, Message = "User plugin {0} completed on message {1}")]
 1103        public void PluginCallCompleted(string pluginName, string messageId)
 1104        {
 01105            if (this.IsEnabled())
 1106            {
 01107                this.WriteEvent(96, pluginName, messageId);
 1108            }
 01109        }
 1110
 1111        [NonEvent]
 1112        public void PluginCallFailed(string pluginName, string messageId, Exception exception)
 1113        {
 01114            if (this.IsEnabled())
 1115            {
 01116                this.PluginCallFailed(pluginName, messageId, exception.ToString());
 1117            }
 01118        }
 1119
 1120        [Event(97, Level = EventLevel.Error, Message = "Exception during {0} plugin execution. MessageId: {1}, Exception
 1121        void PluginCallFailed(string pluginName, string messageId, string exception)
 1122        {
 01123            this.WriteEvent(97, pluginName, messageId, exception);
 01124        }
 1125
 1126        [NonEvent]
 1127        public void ScheduleTaskFailed(Func<Task> task, Exception exception)
 1128        {
 01129            if (this.IsEnabled())
 1130            {
 01131                this.ScheduleTaskFailed(task.Target.GetType().FullName, task.GetMethodInfo().Name, exception.ToString())
 1132            }
 01133        }
 1134
 1135        [Event(98, Level = EventLevel.Error, Message = "Exception during Schedule Task. FunctionTargetName: {0}, MethodI
 1136        void ScheduleTaskFailed(string funcTargetName, string methodInfoName, string exception)
 1137        {
 01138            WriteEvent(98, funcTargetName, methodInfoName, exception);
 01139        }
 1140
 1141        [NonEvent]
 1142        public void ExceptionReceivedHandlerThrewException(Exception exception)
 1143        {
 01144            if (this.IsEnabled())
 1145            {
 01146                this.ExceptionReceivedHandlerThrewException(exception.ToString());
 1147            }
 01148        }
 1149
 1150        [Event(99, Level = EventLevel.Error, Message = "ExceptionReceivedHandler threw exception. Exception:{0}")]
 1151        void ExceptionReceivedHandlerThrewException(string exception)
 1152        {
 01153            WriteEvent(99, exception);
 01154        }
 1155
 1156        [NonEvent]
 1157        public void LinkStateLost(string clientId, string receiveLinkName, AmqpObjectState receiveLinkState, bool isSess
 1158        {
 01159            if (this.IsEnabled())
 1160            {
 01161                this.LinkStateLost(clientId, receiveLinkName, receiveLinkState.ToString(), isSessionReceiver, exception.
 1162            }
 01163        }
 1164
 1165        [Event(100, Level = EventLevel.Error, Message = "Link state lost. Throwing LockLostException for clientId: {0}, 
 1166        void LinkStateLost(string clientId, string receiveLinkName, string receiveLinkState, bool isSessionReceiver, str
 1167        {
 01168            WriteEvent(100, clientId, receiveLinkName, receiveLinkState, isSessionReceiver, exception);
 01169        }
 1170
 1171        [Event(101, Level = EventLevel.Informational, Message = "Updating client id. OldClientId: {0}, NewClientId: {1}"
 1172        public void UpdateClientId(string oldClientId, string newClientId)
 1173        {
 01174            if (this.IsEnabled())
 1175            {
 01176                WriteEvent(101, oldClientId, newClientId);
 1177            }
 01178        }
 1179
 1180        [Event(102, Level = EventLevel.Informational, Message = "{0}: GetRulesException start.")]
 1181        public void GetRulesStart(string clientId)
 1182        {
 01183            if (this.IsEnabled())
 1184            {
 01185                this.WriteEvent(102, clientId);
 1186            }
 01187        }
 1188
 1189        [Event(103, Level = EventLevel.Informational, Message = "{0}: GetRulesException done.")]
 1190        public void GetRulesStop(string clientId)
 1191        {
 01192            if (this.IsEnabled())
 1193            {
 01194                this.WriteEvent(103, clientId);
 1195            }
 01196        }
 1197
 1198        [NonEvent]
 1199        public void GetRulesException(string clientId, Exception exception)
 1200        {
 01201            if (this.IsEnabled())
 1202            {
 01203                this.GetRulesException(clientId, exception.ToString());
 1204            }
 01205        }
 1206
 1207        [Event(104, Level = EventLevel.Error, Message = "{0}: GetRulesException Exception: {1}.")]
 1208        void GetRulesException(string clientId, string exception)
 1209        {
 01210            this.WriteEvent(104, clientId, exception);
 01211        }
 1212
 1213        [NonEvent]
 1214        public void CreatingNewLink(string clientId, bool isSessionReceiver, string sessionId, bool isRequestResponseLin
 1215        {
 01216            if (this.IsEnabled())
 1217            {
 01218                this.CreatingNewLink(clientId, isSessionReceiver, sessionId ?? string.Empty, isRequestResponseLink, link
 1219            }
 01220        }
 1221
 1222        [Event(105, Level = EventLevel.Informational, Message = "Creating/Recreating New Link. ClientId: {0}, IsSessionR
 1223        void CreatingNewLink(string clientId, bool isSessionReceiver, string sessionId, bool isRequestResponseLink, stri
 1224        {
 01225            WriteEvent(105, clientId, isSessionReceiver, sessionId, isRequestResponseLink, linkError);
 01226        }
 1227
 1228        [NonEvent]
 1229        public void SessionReceiverLinkClosed(string clientId, string sessionId, Exception linkException)
 1230        {
 01231            if (this.IsEnabled())
 1232            {
 01233                this.SessionReceiverLinkClosed(clientId, sessionId ?? string.Empty, linkException?.ToString() ?? string.
 1234            }
 01235        }
 1236
 1237        [Event(106, Level = EventLevel.Error, Message = "SessionReceiver Link Closed. ClientId: {0}, SessionId: {1}, lin
 1238        void SessionReceiverLinkClosed(string clientId, string sessionId, string linkException)
 1239        {
 01240            WriteEvent(106, clientId, sessionId, linkException);
 01241        }
 1242
 1243        [NonEvent]
 1244        public void AmqpSendAuthenticationTokenException(string clientId, Exception exception)
 1245        {
 01246            if (this.IsEnabled())
 1247            {
 01248                this.AmqpSendAuthenticationTokenException(clientId, exception.ToString());
 1249            }
 01250        }
 1251
 1252        [Event(107, Level = EventLevel.Error, Message = "{0}: AmqpSendAuthenticationTokenException Exception: {1}.")]
 1253        void AmqpSendAuthenticationTokenException(string clientId, string exception)
 1254        {
 01255            this.WriteEvent(107, clientId, exception);
 01256        }
 1257
 1258        [NonEvent]
 1259        public void AmqpTransactionInitializeException(string transactionId, Exception exception)
 1260        {
 01261            if (this.IsEnabled())
 1262            {
 01263                this.AmqpTransactionInitializeException(transactionId, exception.ToString());
 1264            }
 01265        }
 1266
 1267        [Event(108, Level = EventLevel.Error, Message = "AmqpTransactionInitializeException for TransactionId: {0} Excep
 1268        void AmqpTransactionInitializeException(string transactionId, string exception)
 1269        {
 01270            this.WriteEvent(108, transactionId, exception);
 01271        }
 1272
 1273        [NonEvent]
 1274        public void AmqpTransactionDeclared(string localTransactionId, ArraySegment<byte> amqpTransactionId)
 1275        {
 01276            if (this.IsEnabled())
 1277            {
 01278                this.AmqpTransactionDeclared(localTransactionId, amqpTransactionId.GetAsciiString());
 1279            }
 01280        }
 1281
 1282        [Event(109, Level = EventLevel.Informational, Message = "AmqpTransactionDeclared for LocalTransactionId: {0} Amq
 1283        void AmqpTransactionDeclared(string transactionId, string amqpTransactionId)
 1284        {
 01285            this.WriteEvent(109, transactionId, amqpTransactionId);
 01286        }
 1287
 1288        [NonEvent]
 1289        public void AmqpTransactionDischarged(string localTransactionId, ArraySegment<byte> amqpTransactionId, bool roll
 1290        {
 01291            if (this.IsEnabled())
 1292            {
 01293                this.AmqpTransactionDischarged(localTransactionId, amqpTransactionId.GetAsciiString(), rollback);
 1294            }
 01295        }
 1296
 1297        [Event(110, Level = EventLevel.Informational, Message = "AmqpTransactionDischarged for LocalTransactionId: {0} A
 1298        void AmqpTransactionDischarged(string transactionId, string amqpTransactionId, bool rollback)
 1299        {
 01300            this.WriteEvent(110, transactionId, amqpTransactionId, rollback);
 01301        }
 1302
 1303        [NonEvent]
 1304        public void AmqpTransactionDischargeException(string transactionId, ArraySegment<byte> amqpTransactionId, Except
 1305        {
 01306            if (this.IsEnabled())
 1307            {
 01308                this.AmqpTransactionDischargeException(transactionId, amqpTransactionId.GetAsciiString(), exception.ToSt
 1309            }
 01310        }
 1311
 1312        [Event(111, Level = EventLevel.Error, Message = "AmqpTransactionDischargeException for TransactionId: {0} AmqpTr
 1313        void AmqpTransactionDischargeException(string transactionId, string amqpTransactionId, string exception)
 1314        {
 01315            this.WriteEvent(111, transactionId, amqpTransactionId, exception);
 01316        }
 1317
 1318        [NonEvent]
 1319        public void AmqpCreateControllerException(string connectionManager, Exception exception)
 1320        {
 01321            if (this.IsEnabled())
 1322            {
 01323                this.AmqpCreateControllerException(connectionManager, exception.ToString());
 1324            }
 01325        }
 1326
 1327        [Event(112, Level = EventLevel.Error, Message = "AmqpCreateControllerException for ConnectionManager: {0} Except
 1328        void AmqpCreateControllerException(string connectionManager, string exception)
 1329        {
 01330            this.WriteEvent(112, connectionManager, exception);
 01331        }
 1332
 1333        [Event(113, Level = EventLevel.Informational, Message = "{0}: Management operation '{1}' for '{2}' started.")]
 1334        public void ManagementOperationStart(string clientId, string operationName, string details = "")
 1335        {
 01336            if (this.IsEnabled())
 1337            {
 01338                this.WriteEvent(113, clientId, operationName, details);
 1339            }
 01340        }
 1341
 1342        [Event(114, Level = EventLevel.Informational, Message = "{0}: Management operation '{1}' for '{2}' finished.")]
 1343        public void ManagementOperationEnd(string clientId, string operationName, string details = "")
 1344        {
 01345            if (this.IsEnabled())
 1346            {
 01347                this.WriteEvent(114, clientId, operationName, details);
 1348            }
 01349        }
 1350
 1351        [NonEvent]
 1352        public void ManagementOperationException(string clientId, string operationName, Exception exception)
 1353        {
 01354            if (this.IsEnabled())
 1355            {
 01356                this.ManagementOperationException(clientId, operationName, exception.ToString());
 1357            }
 01358        }
 1359
 1360        [Event(115, Level = EventLevel.Error, Message = "{0}: Management operation '{1}' encountered exception: '{2}'.")
 1361        void ManagementOperationException(string clientId, string operationName, string exception)
 1362        {
 01363            this.WriteEvent(115, clientId, operationName, exception);
 01364        }
 1365
 1366        [Event(116, Level = EventLevel.Informational, Message = "{0}: Management client created with operationTimeout:{1
 1367        public void ManagementClientCreated(string clientId, double operationTimeout, string tokenProvider)
 1368        {
 61369            if (this.IsEnabled())
 1370            {
 01371                this.WriteEvent(116, clientId, operationTimeout, tokenProvider);
 1372            }
 61373        }
 1374
 1375        [Event(117, Level = EventLevel.Warning, Message = "[De]Serialization failed for object:{0}; Details:{1}")]
 1376        public void ManagementSerializationException(string objectName, string details = "")
 1377        {
 01378            if (this.IsEnabled())
 1379            {
 01380                this.WriteEvent(117, objectName, details);
 1381            }
 01382        }
 1383    }
 1384
 1385    internal static class TraceHelper
 1386    {
 1387        public static string GetAsciiString(this ArraySegment<byte> arraySegment)
 1388        {
 1389            return arraySegment.Array == null ? string.Empty : Encoding.ASCII.GetString(arraySegment.Array, arraySegment
 1390        }
 1391    }
 1392}

Methods/Properties

get_Log()
QueueClientCreateStart(...)
QueueClientCreateStop(...)
TopicClientCreateStart(...)
TopicClientCreateStop(...)
SubscriptionClientCreateStart(...)
SubscriptionClientCreateStop(...)
MessageSendStart(...)
MessageSendStop(...)
MessageSendException(...)
MessageSendException(...)
MessageReceiveStart(...)
MessageReceiveStop(...)
MessageReceiveException(...)
MessageReceiveException(...)
MessageCompleteStart(...)
MessageCompleteStart(...)
MessageCompleteStop(...)
MessageCompleteException(...)
MessageCompleteException(...)
MessageAbandonStart(...)
MessageAbandonStop(...)
MessageAbandonException(...)
MessageAbandonException(...)
MessageDeferStart(...)
MessageDeferStop(...)
MessageDeferException(...)
MessageDeferException(...)
MessageDeadLetterStart(...)
MessageDeadLetterStop(...)
MessageDeadLetterException(...)
MessageDeadLetterException(...)
MessageRenewLockStart(...)
MessageRenewLockStop(...)
MessageRenewLockException(...)
MessageRenewLockException(...)
MessageReceiveDeferredMessageStart(...)
MessageReceiveDeferredMessageStart(...)
MessageReceiveDeferredMessageStop(...)
MessageReceiveDeferredMessageException(...)
MessageReceiveDeferredMessageException(...)
AmqpSendLinkCreateStart(...)
AmqpSendLinkCreateStart(...)
AmqpSendLinkCreateStop(...)
AmqpReceiveLinkCreateStart(...)
AmqpReceiveLinkCreateStart(...)
AmqpReceiveLinkCreateStop(...)
AmqpGetOrCreateConnectionStart()
AmqpGetOrCreateConnectionStop(...)
AmqpSendAuthenticationTokenStart(...)
AmqpSendAuthenticationTokenStart(...)
AmqpSendAuthenticationTokenStop()
MessagePeekStart(...)
MessagePeekStop(...)
MessagePeekException(...)
MessagePeekException(...)
MessageSenderCreateStart(...)
MessageSenderCreateStop(...)
MessageReceiverCreateStart(...)
MessageReceiverCreateStop(...)
ScheduleMessageStart(...)
ScheduleMessageStart(...)
ScheduleMessageStop(...)
ScheduleMessageException(...)
ScheduleMessageException(...)
CancelScheduledMessageStart(...)
CancelScheduledMessageStop(...)
CancelScheduledMessageException(...)
CancelScheduledMessageException(...)
AddRuleStart(...)
AddRuleStop(...)
AddRuleException(...)
AddRuleException(...)
RemoveRuleStart(...)
RemoveRuleStop(...)
RemoveRuleException(...)
RemoveRuleException(...)
RegisterOnMessageHandlerStart(...)
RegisterOnMessageHandlerStart(...)
RegisterOnMessageHandlerStop(...)
RegisterOnMessageHandlerException(...)
RegisterOnMessageHandlerException(...)
MessageReceiverPumpTaskStart(...)
MessageReceiverPumpTaskStart(...)
MessageReceiverPumpTaskStop(...)
MessageReceivePumpTaskException(...)
MessageReceivePumpTaskException(...)
MessageReceiverPumpDispatchTaskStart(...)
MessageReceiverPumpDispatchTaskStart(...)
MessageReceiverPumpDispatchTaskStop(...)
MessageReceiverPumpDispatchTaskStop(...)
MessageReceiverPumpUserCallbackStart(...)
MessageReceiverPumpUserCallbackStart(...)
MessageReceiverPumpUserCallbackStop(...)
MessageReceiverPumpUserCallbackStop(...)
MessageReceiverPumpUserCallbackException(...)
MessageReceiverPumpUserCallbackException(...)
MessageReceiverPumpRenewMessageStart(...)
MessageReceiverPumpRenewMessageStart(...)
MessageReceiverPumpRenewMessageStop(...)
MessageReceiverPumpRenewMessageStop(...)
MessageReceiverPumpRenewMessageException(...)
MessageReceiverPumpRenewMessageException(...)
RunOperationExceptionEncountered(...)
RunOperationExceptionEncountered(...)
RegisterOnSessionHandlerStart(...)
RegisterOnSessionHandlerStart(...)
RegisterOnSessionHandlerStop(...)
RegisterOnSessionHandlerException(...)
RegisterOnSessionHandlerException(...)
SessionReceivePumpSessionReceiveException(...)
SessionReceivePumpSessionReceiveException(...)
SessionReceivePumpSessionEmpty(...)
SessionReceivePumpSessionClosed(...)
SessionReceivePumpSessionCloseException(...)
SessionReceivePumpSessionCloseException(...)
SessionReceivePumpSessionRenewLockStart(...)
SessionReceivePumpSessionRenewLockStart(...)
SessionReceivePumpSessionRenewLockStop(...)
SessionReceivePumpSessionRenewLockException(...)
SessionReceivePumpSessionRenewLockException(...)
AmqpSessionClientAcceptMessageSessionStart(...)
AmqpSessionClientAcceptMessageSessionStart(...)
AmqpSessionClientAcceptMessageSessionStop(...)
AmqpSessionClientAcceptMessageSessionException(...)
AmqpSessionClientAcceptMessageSessionException(...)
AmqpLinkCreationException(...)
AmqpLinkCreationException(...)
AmqpConnectionCreated(...)
AmqpConnectionCreated(...)
AmqpConnectionClosed(...)
AmqpConnectionClosed(...)
AmqpSessionCreationException(...)
AmqpSessionCreationException(...)
PluginCallStarted(...)
PluginCallCompleted(...)
PluginCallFailed(...)
PluginCallFailed(...)
ScheduleTaskFailed(...)
ScheduleTaskFailed(...)
ExceptionReceivedHandlerThrewException(...)
ExceptionReceivedHandlerThrewException(...)
LinkStateLost(...)
LinkStateLost(...)
UpdateClientId(...)
GetRulesStart(...)
GetRulesStop(...)
GetRulesException(...)
GetRulesException(...)
CreatingNewLink(...)
CreatingNewLink(...)
SessionReceiverLinkClosed(...)
SessionReceiverLinkClosed(...)
AmqpSendAuthenticationTokenException(...)
AmqpSendAuthenticationTokenException(...)
AmqpTransactionInitializeException(...)
AmqpTransactionInitializeException(...)
AmqpTransactionDeclared(...)
AmqpTransactionDeclared(...)
AmqpTransactionDischarged(...)
AmqpTransactionDischarged(...)
AmqpTransactionDischargeException(...)
AmqpTransactionDischargeException(...)
AmqpCreateControllerException(...)
AmqpCreateControllerException(...)
ManagementOperationStart(...)
ManagementOperationEnd(...)
ManagementOperationException(...)
ManagementOperationException(...)
ManagementClientCreated(...)
ManagementSerializationException(...)