projects
/
demos
/
kafka
/
chat
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
fix: Fixed `ConcurrentModificationException` when accessing a chat-room
[demos/kafka/chat]
/
src
/
main
/
java
/
de
/
juplo
/
kafka
/
chat
/
backend
/
implementation
/
kafka
/
KafkaServicesConfiguration.java
diff --git
a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java
b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java
index
f78beb1
..
3337127
100644
(file)
--- a/
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java
+++ b/
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java
@@
-133,7
+133,8
@@
public class KafkaServicesConfiguration
infoChannelConsumer,
properties.getKafka().getPollingInterval(),
properties.getKafka().getNumPartitions(),
infoChannelConsumer,
properties.getKafka().getPollingInterval(),
properties.getKafka().getNumPartitions(),
- properties.getKafka().getInstanceUri());
+ properties.getKafka().getInstanceUri(),
+ channelMediator);
channelMediator.setInfoChannel(infoChannel);
return infoChannel;
}
channelMediator.setInfoChannel(infoChannel);
return infoChannel;
}
@@
-148,7
+149,7
@@
public class KafkaServicesConfiguration
ChannelMediator channelMediator,
ShardingPublisherStrategy shardingPublisherStrategy)
{
ChannelMediator channelMediator,
ShardingPublisherStrategy shardingPublisherStrategy)
{
-
return
new DataChannel(
+
DataChannel dataChannel =
new DataChannel(
properties.getInstanceId(),
properties.getKafka().getDataChannelTopic(),
producer,
properties.getInstanceId(),
properties.getKafka().getDataChannelTopic(),
producer,
@@
-160,6
+161,8
@@
public class KafkaServicesConfiguration
clock,
channelMediator,
shardingPublisherStrategy);
clock,
channelMediator,
shardingPublisherStrategy);
+ channelMediator.setDataChannel(dataChannel);
+ return dataChannel;
}
@Bean
}
@Bean