+ private final int bufferSize;
+ private Sinks.Many<Message> sink;
+
+ public Chatroom(
+ UUID id,
+ String name,
+ PersistenceStrategy persistence,
+ int bufferSize)
+ {
+ this.id = id;
+ this.name = name;
+ this.persistence = persistence;
+ this.bufferSize = bufferSize;
+ this.sink = createSink();
+ }
+