1 package de.juplo.kafka.chat.backend.implementation.kafka;
3 import de.juplo.kafka.chat.backend.domain.ChatRoomInfo;
4 import lombok.RequiredArgsConstructor;
6 import reactor.core.publisher.Mono;
11 @RequiredArgsConstructor
12 public class ChannelMediator
15 private InfoChannel infoChannel;
18 void shardAssigned(int shard)
20 infoChannel.sendShardAssignedEvent(shard);
23 void shardRevoked(int shard)
25 infoChannel.sendShardRevokedEvent(shard);
28 Mono<ChatRoomInfo> getChatRoomInfo(UUID id)
30 return infoChannel.getChatRoomInfo(id);