How to listen to multiple databases at the same time?

[slowside45]

I created two threads and set BinaryLogClient's object as :
binaryClient.setBlocking(false); ..................... binaryClient.connect(5000);

then I start those two sub threads at the same time in the main thread, but only the first thread can listened the event

[osheroff]

I'm not totally sure what you're trying to do. Post some sample
Code?

[slowside45]

There are many databases in my product environment, I need to listen all of these databases, their host, port, databaseName are different, so I have to create some BinarylogClients, every BinaryLogClient has a BinlogListener, then to listen the databases. Now I create these BinaryLogClients in different threads, it can be started and listener can connect to those databases successfully, but after listener do onEvent() once, the keepAliveThread will be shutdown, then I can't receive any databases event message anymore. the logs is like this:

16:31:38:793 INFO com.github.shyiko.mysql.binlog.BinaryLogClient - Connected to xxxxxx at binlog.000012/955973598 (cid:9704)
.......................(something like event message)
16:31:38:826 INFO com.github.shyiko.mysql.binlog.BinaryLogClient - threadExecutor is shut down, terminating keepalive thread

My question is What should I do when I'm trying to create BinaryLogClient? Or is there any property need to be setup?(keepAlive/blocking/or any else could be useful)

[slowside45]

I found when the springboot application is running, I can create many BinaryLogClients in different thread successfully, and they will never disconnected, the keepalive thread won't be terminated and I can receive database event message. But after I restart my springboot application, console will print logs like this:

16:31:38:793 INFO com.github.shyiko.mysql.binlog.BinaryLogClient - Connected to xxxxxx at binlog.000012/955973598 (cid:9704)
........................(something like event message)
16:31:38:826 INFO com.github.shyiko.mysql.binlog.BinaryLogClient - threadExecutor is shut down, terminating keepalive thread

then the keepalive thread will be terminated, and then I can't receive any databse event message anymore.