- public ChatRoomChannel(
- String topic,
- Consumer<Integer, ChatRoomTo> consumer,
- Producer<Integer, ChatRoomTo> producer,
- int numShards,
- ChatMessageChannel chatMessageChannel)
- {
- log.debug(
- "Creating ChatRoomChannel for topic {} with sharding for {} partitions",
- topic,
- numShards);
- this.topic = topic;
- this.consumer = consumer;
- this.producer = producer;
- this.shardingStrategy = new KafkaLikeShardingStrategy(numShards);
- this.chatMessageChannel = chatMessageChannel;
- }
-
-