CasCap.Api.Azure.EventHub 1.4.3

CasCap.Api.Azure.EventHub

Helper library for Azure Event Hub. Provides generic publisher and subscriber base services for streaming events via Event Hubs, with MessagePack serialization.

Services / Extensions

Key Methods — PublisherService<T>

• Push(T obj) — Serializes and pushes a single event.
• Push(List<T> objs) — Serializes and pushes a list of events.
• Push(byte[] bytes) — Pushes a raw byte array as a single event.
• SendTestMessages(int numMessagesToSend) — Sends test messages to the Event Hub.

Key Methods — SubscriberService<T>

• InitiateReceive(CancellationToken) — Begins processing events until cancellation.

Class Hierarchy

Publisher/Subscriber pattern for Event Hub streaming:

classDiagram
    direction TB

    IPublisherService~T~ <|.. PublisherService~T~
    ISubscriberService~T~ <|.. SubscriberService~T~

    PublisherService~T~ <|-- YourPublisher
    SubscriberService~T~ <|-- YourSubscriber

    class IEvent {
        <<interface>>
    }

    class IPublisherService~T~ {
        <<interface>>
        +Push(obj) Task
        +Push(objs) Task
        +Push(bytes) Task
    }

    class PublisherService~T~ {
        <<abstract>>
        #EventHubProducerClient Client
        #ILogger Logger
        +Push(obj) Task
        +Push(objs) Task
        +Push(bytes) Task
        +SendTestMessages(count) Task
    }

    class ISubscriberService~T~ {
        <<interface>>
        +InitiateReceive(token) Task
    }

    class SubscriberService~T~ {
        <<abstract>>
        #EventProcessorClient Client
        #ILogger Logger
        +InitiateReceive(token) Task
        #ProcessEventHandler(args) Task
        #ProcessErrorHandler(args) Task
    }

    class YourPublisher {
        +PublishDomainEvent(event) Task
    }

    class YourSubscriber {
        +ProcessDomainEvent(event) Task
    }

    T --|> IEvent : implements
    PublisherService~T~ ..> EventHubProducerClient : uses
    SubscriberService~T~ ..> EventProcessorClient : uses
    PublisherService~T~ ..> MessagePack : serializes
    SubscriberService~T~ ..> MessagePack : deserializes

Usage Pattern:

1. Define event types implementing IEvent
2. Inherit from PublisherService<T> for sending
3. Inherit from SubscriberService<T> for receiving
4. Override ProcessEventHandler for custom event processing
5. MessagePack handles serialization automatically

Configuration

No configuration model. Services are constructed directly with connection strings or TokenCredential.

Dependencies

NuGet Packages

Project References

None.