singleThreadExecutor.execute (() -> this.closeConsumer(consumer));
private void closeConsumer(MessageConsumer consumer) {
try {
consumer.close();
}
catch (Exception e) {
logger.warn(e.getMessage, e);
}
}
A good thing of using the listener still is that you save some thre
Hi Rafael,
I’m just an ActiveMQ classic user.
I will report the behavior of ActiveMQ I experienced.
As far as I know the ActiveMQ classic journal is composed of append only
files.
Each file should be by default 32MB in size (this can be changed, I think
is controlled by journalLogFileSize)
A jour
