Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added additional logging on BrokerService startup 

(cherry picked from commit dc55028c00)
This commit is contained in:
Dmytro Chebotarskyi 2022-11-14 15:58:30 -08:00 committed by Jean-Baptiste Onofré
parent 3f6ffd30d2
commit c35687052a
3 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
View File

@ -668,10 +668,13 @@ public class BrokerService implements Service {
persistenceAdapterToStart.setBrokerName(getBrokerName()); persistenceAdapterToStart.setBrokerName(getBrokerName());
LOG.info("Using Persistence Adapter: {}", persistenceAdapterToStart); LOG.info("Using Persistence Adapter: {}", persistenceAdapterToStart);
if (deleteAllMessagesOnStartup) { if (deleteAllMessagesOnStartup) {
LOG.info("Deleting all messages on startup because deleteAllMessagesOnStartup configuration has been provided");
deleteAllMessages(); deleteAllMessages();
} }
LOG.info("Starting Persistence Adapter: {}", persistenceAdapterToStart);
persistenceAdapterToStart.start(); persistenceAdapterToStart.start();
LOG.info("Starting Temp Data Store");
getTempDataStore(); getTempDataStore();
if (tempDataStore != null) { if (tempDataStore != null) {
try { try {
@ -685,6 +688,7 @@ public class BrokerService implements Service {
} }
} }
LOG.info("Starting Job Scheduler Store");
getJobSchedulerStore(); getJobSchedulerStore();
if (jobSchedulerStore != null) { if (jobSchedulerStore != null) {
try { try {
@ -696,6 +700,7 @@ public class BrokerService implements Service {
throw exception; throw exception;
} }
} }
LOG.info("Persistence Adapter successfully started");
} }
private void startBroker(boolean async) throws Exception { private void startBroker(boolean async) throws Exception {

2
activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
View File

@ -207,8 +207,8 @@ public class KahaDBStore extends MessageDatabase implements PersistenceAdapter,
public void doStart() throws Exception { public void doStart() throws Exception {
//configure the metadata before start, right now //configure the metadata before start, right now
//this is just the open wire version //this is just the open wire version
LOG.info("Starting KahaDBStore");
configureMetadata(); configureMetadata();
super.doStart(); super.doStart();
if (brokerService != null) { if (brokerService != null) {

1
activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
View File

@ -457,6 +457,7 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe
} }
public void open() throws IOException { public void open() throws IOException {
LOG.info("Opening MessageDatabase");
if( opened.compareAndSet(false, true) ) { if( opened.compareAndSet(false, true) ) {
getJournal().start(); getJournal().start();
try { try {