Producer<String, AbstractMessageTo> producer,
Consumer<String, AbstractMessageTo> dataChannelConsumer,
ZoneId zoneId,
- Clock clock)
+ Clock clock,
+ InfoChannel infoChannel)
{
return new DataChannel(
properties.getKafka().getDataChannelTopic(),
zoneId,
properties.getKafka().getNumPartitions(),
properties.getChatroomBufferSize(),
- clock);
+ clock,
+ infoChannel);
}
@Bean