multimedia-service/piperkt.services.multimedia.infrastructure.events.publishers/SessionEventKafkaPublisher

SessionEventKafkaPublisher

@KafkaClient

interface SessionEventKafkaPublisher

Publishes session events to Kafka.

Functions

publishAllowedUserAdded

@Topic(value = ["allowed-user-added"])

abstract fun publishAllowedUserAdded(event: AllowedUserAddedEvent)

publishAllowedUserRemoved

@Topic(value = ["allowed-user-removed"])

abstract fun publishAllowedUserRemoved(event: AllowedUserRemovedEvent)

publishParticipantJoined

@Topic(value = ["participant-joined"])

abstract fun publishParticipantJoined(event: ParticipantJoinedEvent)

publishParticipantLeft

@Topic(value = ["participant-left"])

abstract fun publishParticipantLeft(event: ParticipantLeftEvent)

publishSessionCreated

@Topic(value = ["session-created"])

abstract fun publishSessionCreated(event: SessionCreatedEvent)

publishSessionDeleted

@Topic(value = ["session-deleted"])

abstract fun publishSessionDeleted(event: SessionDeletedEvent)