MultiSender only removes senders, never adds them back when available about fluency HOT 2 CLOSED

    public static void main(String[] args)
            throws InterruptedException, IOException
    {
        Fluency fluency = new FluencyBuilderForFluentd().build(
                Arrays.asList(new InetSocketAddress(24224), new InetSocketAddress(24225)));
        Map<String, Object> event = new HashMap<>();
        event.put("name", "aaaa");
        event.put("age", 42);
        for (int i = 0; i < 100; i++) {
            event.put("i", i);
            fluency.emit("foo.bar", event);
            TimeUnit.SECONDS.sleep(2);
        }
        fluency.close();
    }

<source>
  @type forward
  port 24224
  bind 0.0.0.0
</source>

<match foo.bar>
  @type stdout
</match>

<source>
  @type forward
  port 24225
  bind 0.0.0.0
</source>

<match foo.bar>
  @type stdout
</match>

$ fluentd -c fluentd.conf
    :
2019-11-29 00:21:44.000000000 +0900 foo.bar: {"name":"aaaa","i":0,"age":42}
2019-11-29 00:21:46.000000000 +0900 foo.bar: {"name":"aaaa","i":1,"age":42}
2019-11-29 00:21:48.000000000 +0900 foo.bar: {"name":"aaaa","i":2,"age":42}
2019-11-29 00:21:50.000000000 +0900 foo.bar: {"name":"aaaa","i":3,"age":42}
2019-11-29 00:21:52.000000000 +0900 foo.bar: {"name":"aaaa","i":4,"age":42}
^C2019-11-29 00:21:55 +0900 [info]: Received graceful stop
2019-11-29 00:21:54.000000000 +0900 foo.bar: {"name":"aaaa","i":5,"age":42}
2019-11-29 00:21:55 +0900 [info]: #0 fluentd worker is now stopping worker=0
2019-11-29 00:21:55 +0900 [info]: #0 shutting down fluentd worker worker=0
2019-11-29 00:21:55 +0900 [info]: #0 shutting down input plugin type=:forward plugin_id="object:3fe0728d2ccc"
2019-11-29 00:21:55 +0900 [info]: #0 shutting down output plugin type=:stdout plugin_id="object:3fe0718aa188"
2019-11-29 00:21:56 +0900 [info]: Worker 0 finished with status 0
$ fluentd -c fluentd.conf
    :
2019-11-29 00:22:26 +0900 [info]: #0 starting fluentd worker pid=5603 ppid=5578 worker=0
2019-11-29 00:22:26 +0900 [info]: #0 listening port port=24224 bind="0.0.0.0"
2019-11-29 00:22:26 +0900 [info]: #0 fluentd worker is now running worker=0
2019-11-29 00:22:28.000000000 +0900 foo.bar: {"name":"aaaa","i":22,"age":42}
2019-11-29 00:22:30.000000000 +0900 foo.bar: {"name":"aaaa","i":23,"age":42}
2019-11-29 00:22:32.000000000 +0900 foo.bar: {"name":"aaaa","i":24,"age":42}
2019-11-29 00:22:34.000000000 +0900 foo.bar: {"name":"aaaa","i":25,"age":42}
2019-11-29 00:22:36.000000000 +0900 foo.bar: {"name":"aaaa","i":26,"age":42}
2019-11-29 00:22:38.000000000 +0900 foo.bar: {"name":"aaaa","i":27,"age":42}
2019-11-29 00:22:40.000000000 +0900 foo.bar: {"name":"aaaa","i":28,"age":42}
2019-11-29 00:22:42.000000000 +0900 foo.bar: {"name":"aaaa","i":29,"age":42}
2019-11-29 00:22:44.000000000 +0900 foo.bar: {"name":"aaaa","i":30,"age":42}
    :

$ fluentd -c fluentd2.conf
    :
2019-11-29 00:21:19 +0900 [info]: #0 starting fluentd worker pid=5571 ppid=5545 worker=0
2019-11-29 00:21:19 +0900 [info]: #0 listening port port=24225 bind="0.0.0.0"
2019-11-29 00:21:19 +0900 [info]: #0 fluentd worker is now running worker=0
2019-11-29 00:21:56.000000000 +0900 foo.bar: {"name":"aaaa","i":6,"age":42}
2019-11-29 00:21:58.000000000 +0900 foo.bar: {"name":"aaaa","i":7,"age":42}
2019-11-29 00:22:00.000000000 +0900 foo.bar: {"name":"aaaa","i":8,"age":42}
2019-11-29 00:22:02.000000000 +0900 foo.bar: {"name":"aaaa","i":9,"age":42}
2019-11-29 00:22:04.000000000 +0900 foo.bar: {"name":"aaaa","i":10,"age":42}
2019-11-29 00:22:06.000000000 +0900 foo.bar: {"name":"aaaa","i":11,"age":42}
2019-11-29 00:22:08.000000000 +0900 foo.bar: {"name":"aaaa","i":12,"age":42}
2019-11-29 00:22:10.000000000 +0900 foo.bar: {"name":"aaaa","i":13,"age":42}
2019-11-29 00:22:12.000000000 +0900 foo.bar: {"name":"aaaa","i":14,"age":42}
2019-11-29 00:22:14.000000000 +0900 foo.bar: {"name":"aaaa","i":15,"age":42}
2019-11-29 00:22:16.000000000 +0900 foo.bar: {"name":"aaaa","i":16,"age":42}
2019-11-29 00:22:18.000000000 +0900 foo.bar: {"name":"aaaa","i":17,"age":42}
2019-11-29 00:22:20.000000000 +0900 foo.bar: {"name":"aaaa","i":18,"age":42}
2019-11-29 00:22:22.000000000 +0900 foo.bar: {"name":"aaaa","i":19,"age":42}
2019-11-29 00:22:24.000000000 +0900 foo.bar: {"name":"aaaa","i":20,"age":42}
2019-11-29 00:22:26.000000000 +0900 foo.bar: {"name":"aaaa","i":21,"age":42}