ramonsmits

using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Threading.Tasks;
using NServiceBus.Features;
using NServiceBus.Logging;
using NServiceBus.Pipeline;

class LogIncomingMessageId : Feature
{

ramonsmits

using System;
using System.Threading.Tasks;
using NServiceBus.Features;
using NServiceBus.Logging;
using NServiceBus.Pipeline;

class LogIncomingServiceControlRetry : Feature
{
    static readonly ILog Log = LogManager.GetLogger<LogIncomingServiceControlRetry>();

ramonsmits

// 
//  endpointConfiguration.Pipeline.Register(new LogDuplicateMessageId(),nameof(LogDuplicateMessageId));
//
// NOTE: DOES NOT RELEASE MEMORY. Dictionary will grow indefinitely. ONLY FOR TESTING!
//
class LogDuplicateMessageId : IBehavior<IIncomingPhysicalMessageContext, IIncomingPhysicalMessageContext>
{
    static readonly BlockingCollection<string> Logs = new BlockingCollection<string>();

    static LogMessageId()

ramonsmits

// MIT , Inspired by https://softwareengineering.stackexchange.com/questions/149346/logging-asynchronously-how-should-it-be-done
using System;
using System.Collections.Concurrent;
using System.Threading.Tasks;

class AsyncConsoleLogger
{
    static readonly BlockingCollection<string> Logs = new BlockingCollection<string>();

    static AsyncConsoleLogger()

ramonsmits

//
// endpointConfiguration.RegisterComponents(c=>c.ConfigureComponent<ExtendLoggerScopeWithMessageData>(DependencyLifecycle.SingleInstance));
// endpointConfiguration.Pipeline.Register(b=>b.Build<ExtendLoggerScopeWithMessageData>(),nameof(ExtendLoggerScopeWithMessageData));
//
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using NServiceBus;
using NServiceBus.Pipeline;
using Microsoft.Extensions.Logging;

ramonsmits

// Source: https://stackoverflow.com/a/24031467/199551
public static string CreateMD5(string input)
{
    // Use input string to calculate MD5 hash
    using (var md5 = System.Security.Cryptography.MD5.Create())
    {
        var inputBytes = System.Text.Encoding.ASCII.GetBytes(input);
        var hashBytes = md5.ComputeHash(inputBytes);

        // Convert the byte array to hexadecimal string

ramonsmits

static class StringExt
{
    public static string? Truncate(this string? value, int maxLength)
    {
        if (value == null) return value;
        return value.Length <= maxLength ? value : string.Concat(value.AsSpan(0, maxLength - 1), "…");
    }
}

ramonsmits

public static class ObjectExtension
{
    public static T Do<T>(this T instance, Action<T> x)
    {
        x?.Invoke(instance);
        return instance;
    }
}

ramonsmits

using NServiceBus;
using NServiceBus.Logging;
using NServiceBus.Raw;
using NServiceBus.Routing;
using NServiceBus.Transport;

CancellationTokenSource cts = new();
Console.CancelKeyPress += (s, ea) =>
{
    ea.Cancel = true;

ramonsmits

//
// NServiceBus v8 will have improved support for cooperative cancellation.
//
// Register behavior:
//
//     endpointConfiguration.Pipeline.Register(new CancellationTimeoutBehavior(TimeSpan.FromSeconds(5)), nameof(CancellationTimeoutBehavior));
//
using System;
using System.Threading;
using System.Threading.Tasks;