NewEventBus creates a new instance of an eventBus with a specified buffer size for the event queue and attaches a logger.

NewOutboxRepository creates a new OutboxRepository.

message acknowledged, no need to retry.

message not acknowledged, need to retry.

Event represents a message or event that can be published to a topic within the EventBus.

OutboxEvent represents an event stored in the outbox table.

OutboxRepository provides methods to interact with the outbox table.

EventBus defines an interface for subscribing to topics, publishing events, and managing event processing.

EventHandler is a function type that processes an Event and returns an error if the processing fails.