Getting Started
Architecture
NServiceBus
Transports
Persistence
ServiceInsight
ServicePulse
ServiceControl
Monitoring
Samples

Metrics Upgrade Version 1.0 to 1.1

Component: Metrics

RegisterObservers replaces basic methods

The EnableMetricTracing, EnableCustomReport and EnableLogTracing methods have been deprecated and replaced with the more extensible RegisterObservers.

Also note that the older methods supported an interval TimeSpan. It is now the responsibility of the implementing code to batch metrics and flush them as needed.

EnableMetricTracing

Replace with explicit calls to Trace.WriteLine.

// For Metrics version 1.x
var metrics = endpointConfiguration.EnableMetrics();
metrics.RegisterObservers(
    register: context =>
    {
        foreach (var duration in context.Durations)
        {
            duration.Register(
                observer: length =>
                {
                    Trace.WriteLine($"Duration '{duration.Name}'. Value: '{length}'");
                });
        }
        foreach (var signal in context.Signals)
        {
            signal.Register(
                observer: () =>
                {
                    Trace.WriteLine($"Signal: '{signal.Name}'");
                });
        }
    });

// For Metrics version 1.x
var metrics = endpointConfiguration.EnableMetrics();
metrics.EnableMetricTracing(TimeSpan.FromSeconds(5));

EnableLogTracing

Replace with explicit calls to an NServiceBus logger.

// For Metrics version 1.x
//TODO: the logger instance should be a static field
var log = LogManager.GetLogger("LoggerName");

var metrics = endpointConfiguration.EnableMetrics();
metrics.RegisterObservers(
    register: context =>
    {
        foreach (var duration in context.Durations)
        {
            duration.Register(
                observer: length =>
                {
                    log.Info($"Duration: '{duration.Name}'. Value: '{length}'");
                });
        }
        foreach (var signal in context.Signals)
        {
            signal.Register(
                observer: () =>
                {
                    log.Info($"Signal: '{signal.Name}'");
                });
        }
    });

// For Metrics version 1.x
var metrics = endpointConfiguration.EnableMetrics();
metrics.EnableLogTracing(TimeSpan.FromSeconds(5), LogLevel.Info);

EnableCustomReport

Replace with explicit calls to the custom method.

// For Metrics version 1.x
var metrics = endpointConfiguration.EnableMetrics();
metrics.RegisterObservers(
    register: context =>
    {
        foreach (var duration in context.Durations)
        {
            duration.Register(
                observer: length =>
                {
                    ProcessMetric(duration, length);
                });
        }
        foreach (var signal in context.Signals)
        {
            signal.Register(
                observer: () =>
                {
                    ProcessMetric(signal);
                });
        }
    });

// For Metrics version 1.x
var metrics = endpointConfiguration.EnableMetrics();
metrics.EnableCustomReport(
    func: data => ProcessMetric(data),
    interval: TimeSpan.FromSeconds(5));