MessageEnvelope

CloudNimble.SimpleMessageBus.Core.MessageEnvelope

// Creating an envelope (typically done automatically by publishers)
var message = new OrderCreatedMessage { OrderNumber = "ORD-001" };
var envelope = new MessageEnvelope(message);

// Processing an envelope in a handler
public async Task OnNextAsync(MessageEnvelope envelope)
{
    // Access metadata
    var attempts = envelope.AttemptsCount;
    var published = envelope.DatePublished;

    // Extract the message
    var orderMessage = envelope.GetMessage<OrderCreatedMessage>();

    // Use the logger for this specific message
    envelope.ProcessLog?.LogInformation("Processing order {OrderNumber}", orderMessage.OrderNumber);

    // Process the message...
}

public MessageEnvelope()

public MessageEnvelope(CloudNimble.SimpleMessageBus.Core.IMessage message)

var message = new OrderCreatedMessage
{
    OrderNumber = "ORD-001",
    CustomerId = customerId,
    TotalAmount = 99.99m
};

var envelope = new MessageEnvelope(message);
// envelope.Id is automatically generated
// envelope.DatePublished is set to now
// envelope.MessageType contains the full type name
// envelope.MessageContent contains the JSON serialized message

public Object()

public long AttemptsCount { get; set; }

public System.DateTimeOffset DatePublished { get; set; }

public System.Guid Id { get; set; }

public CloudNimble.SimpleMessageBus.Core.IMessage Message { get; }

public async Task OnNextAsync(MessageEnvelope envelope)
{
    // Type-safe access without specifying the type
    switch (envelope.Message)
    {
        case OrderCreatedMessage order:
            await ProcessOrderAsync(order);
            break;
        case PaymentProcessedMessage payment:
            await ProcessPaymentAsync(payment);
            break;
        default:
            throw new NotSupportedException($"Unknown message type: {envelope.MessageType}");
    }
}

public string MessageContent { get; set; }

public dynamic MessageState { get; private set; }

public string MessageType { get; set; }

public Microsoft.Extensions.Logging.ILogger ProcessLog { get; set; }

public Microsoft.Extensions.DependencyInjection.IServiceScope ServiceScope { get; set; }

public virtual bool Equals(object obj)

public static bool Equals(object objA, object objB)

public virtual int GetHashCode()

public T GetMessage<T>() where T : CloudNimble.SimpleMessageBus.Core.IMessage

public async Task OnNextAsync(MessageEnvelope envelope)
{
    // Type-safe deserialization when you know the expected type
    var orderMessage = envelope.GetMessage<OrderCreatedMessage>();

    // Process the strongly-typed message
    await ProcessOrderAsync(orderMessage.OrderNumber, orderMessage.TotalAmount);
}

public System.Type GetType()

protected internal object MemberwiseClone()

public static bool ReferenceEquals(object objA, object objB)

public override string ToString()

public virtual string ToString()