Skip to content

castlecraft_engineer.abstractions.event_publisher

castlecraft_engineer.abstractions.event_publisher

ExternalEventPublisher

Bases: ABC

Abstract base class for publishing domain events to external messaging systems (e.g., Kafka, RabbitMQ, Redis Streams).

Source code in src/castlecraft_engineer/abstractions/event_publisher.py 
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
class ExternalEventPublisher(abc.ABC):
    """
    Abstract base class for publishing domain events to external
    messaging systems (e.g., Kafka, RabbitMQ, Redis Streams).
    """

    @abc.abstractmethod
    async def publish(self, events: List[Event]) -> None:
        """
        Publishes a list of domain events to the external broker.

        Implementations should handle serialization,connection management,
        and the specifics of the chosen message broker protocol.

        Args:
            events: A list of domain event instances to publish.

        Raises:
            NotImplementedError: This method must be implemented by
                                 concrete subclasses.
            Exception: Implementation-specific exceptions related to
                       publishing failures (e.g., connection errors,
                       serialization issues).
        """
        raise NotImplementedError

    @abc.abstractmethod
    async def close(self) -> None:
        """Clean up resources, like network connections."""
        raise NotImplementedError

close() abstractmethod async

Clean up resources, like network connections.

Source code in src/castlecraft_engineer/abstractions/event_publisher.py 
33
34
35
36
@abc.abstractmethod
async def close(self) -> None:
    """Clean up resources, like network connections."""
    raise NotImplementedError

publish(events) abstractmethod async

Publishes a list of domain events to the external broker.

Implementations should handle serialization,connection management, and the specifics of the chosen message broker protocol.

Parameters:

Name Type Description Default
events List[Event]

A list of domain event instances to publish.

 required

Raises:

Type Description
NotImplementedError

This method must be implemented by concrete subclasses.
Exception

Implementation-specific exceptions related to publishing failures (e.g., connection errors, serialization issues).
Source code in src/castlecraft_engineer/abstractions/event_publisher.py 
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
@abc.abstractmethod
async def publish(self, events: List[Event]) -> None:
    """
    Publishes a list of domain events to the external broker.

    Implementations should handle serialization,connection management,
    and the specifics of the chosen message broker protocol.

    Args:
        events: A list of domain event instances to publish.

    Raises:
        NotImplementedError: This method must be implemented by
                             concrete subclasses.
        Exception: Implementation-specific exceptions related to
                   publishing failures (e.g., connection errors,
                   serialization issues).
    """
    raise NotImplementedError