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

ARTEMIS-1628 Limit pool size on artemis journal

This commit is contained in:
Clebert Suconic 2018-01-22 12:33:14 -05:00 committed by Howard Gao
parent 42049bf96a
commit 35222485e8
3 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/broker.xml
View File

@ -49,7 +49,7 @@ ${jdbc}
<journal-min-files>2</journal-min-files> <journal-min-files>2</journal-min-files>
<journal-pool-files>-1</journal-pool-files> <journal-pool-files>10</journal-pool-files>
<journal-file-size>10M</journal-file-size> <journal-file-size>10M</journal-file-size>
${journal-buffer.settings}${ping-config.settings}${connector-config.settings} ${journal-buffer.settings}${ping-config.settings}${connector-config.settings}

3
artemis-server/src/main/java/org/apache/activemq/artemis/core/config/impl/ConfigurationImpl.java
View File

@ -862,6 +862,9 @@ public class ConfigurationImpl implements Configuration, Serializable {
@Override @Override
public Configuration setJournalPoolFiles(int poolSize) { public Configuration setJournalPoolFiles(int poolSize) {
this.journalPoolFiles = poolSize; this.journalPoolFiles = poolSize;
if (!Env.isTestEnv()) {
ActiveMQServerLogger.LOGGER.useFixedValueOnJournalPoolFiles();
}
return this; return this;
} }

4
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java
View File

@ -1574,6 +1574,10 @@ public interface ActiveMQServerLogger extends BasicLogger {
@Message(id = 222268, value = "Failed to remove a record", format = Message.Format.MESSAGE_FORMAT) @Message(id = 222268, value = "Failed to remove a record", format = Message.Format.MESSAGE_FORMAT)
void failedToRemoveRecord(@Cause Exception e); void failedToRemoveRecord(@Cause Exception e);
@LogMessage(level = Logger.Level.WARN)
@Message(id = 222269, value = "Please use a fixed value for \"journal-pool-files\". Default changed per https://issues.apache.org/jira/browse/ARTEMIS-1628", format = Message.Format.MESSAGE_FORMAT)
void useFixedValueOnJournalPoolFiles();
@LogMessage(level = Logger.Level.ERROR) @LogMessage(level = Logger.Level.ERROR)
@Message(id = 224000, value = "Failure in initialisation", format = Message.Format.MESSAGE_FORMAT) @Message(id = 224000, value = "Failure in initialisation", format = Message.Format.MESSAGE_FORMAT)
void initializationError(@Cause Throwable e); void initializationError(@Cause Throwable e);