@Autowired
ChatRoomChannel chatRoomChannel;
@Autowired
- Consumer<Integer, ChatRoomTo> chatRoomChannelConsumer;
+ Consumer<Integer, CreateChatRoomRequestTo> chatRoomChannelConsumer;
@Autowired
ChatMessageChannel chatMessageChannel;
@Autowired
- Consumer<String, MessageTo> chatMessageChannelConsumer;
+ Consumer<String, ChatMessageTo> chatMessageChannelConsumer;
CompletableFuture<Void> chatRoomChannelConsumerJob;
CompletableFuture<Void> chatMessageChannelConsumerJob;