return new InfoChannel(
properties.getKafka().getInfoChannelTopic(),
producer,
- infoChannelConsumer);
+ infoChannelConsumer,
+ properties.getKafka().getInstanceUri());
}
@Bean
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