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

This closes #943

This commit is contained in:
Jean-Baptiste Onofré 2022-11-29 08:02:13 +01:00
parent 726cc68078 dc55028c00
commit 424be3ee8d
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());
LOG.info("Using Persistence Adapter: {}", persistenceAdapterToStart);
if (deleteAllMessagesOnStartup) {
LOG.info("Deleting all messages on startup because deleteAllMessagesOnStartup configuration has been provided");
deleteAllMessages();
}
LOG.info("Starting Persistence Adapter: {}", persistenceAdapterToStart);
persistenceAdapterToStart.start();
LOG.info("Starting Temp Data Store");
getTempDataStore();
if (tempDataStore != null) {
try {
@ -685,6 +688,7 @@ public class BrokerService implements Service {
}
}
LOG.info("Starting Job Scheduler Store");
getJobSchedulerStore();
if (jobSchedulerStore != null) {
try {
@ -696,6 +700,7 @@ public class BrokerService implements Service {
throw exception;
}
}
LOG.info("Persistence Adapter successfully started");
}
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 {
//configure the metadata before start, right now
//this is just the open wire version
LOG.info("Starting KahaDBStore");
configureMetadata();
super.doStart();
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 {
LOG.info("Opening MessageDatabase");
if( opened.compareAndSet(false, true) ) {
getJournal().start();
try {