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

https://issues.apache.org/jira/browse/AMQ-6292 

allow for batch writes of forwarded acks.
This commit is contained in:
Timothy Bish 2016-05-13 14:56:01 -04:00
parent b9334960e0
commit 15405af2e6
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -16,6 +16,8 @@
*/
package org.apache.activemq.store.kahadb;
import static org.apache.activemq.store.kahadb.disk.journal.Location.NOT_SET;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.DataInput;
@ -111,8 +113,6 @@ import org.apache.activemq.util.ThreadPoolUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import static org.apache.activemq.store.kahadb.disk.journal.Location.NOT_SET;
public abstract class MessageDatabase extends ServiceSupport implements BrokerServiceAware {
protected BrokerService brokerService;
@ -1981,7 +1981,7 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe
compactionMarker.setRewriteType(COMPACTED_JOURNAL_FILE);
ByteSequence payload = toByteSequence(compactionMarker);
appender.storeItem(payload, Journal.USER_RECORD_TYPE, isEnableJournalDiskSyncs());
appender.storeItem(payload, Journal.USER_RECORD_TYPE, false);
LOG.trace("Marked ack rewrites file as replacing file: {}", journalToRead);
Location nextLocation = getNextLocationForAckForward(new Location(journalToRead, 0));
@ -1995,7 +1995,7 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe
if (command != null && command instanceof KahaRemoveMessageCommand) {
payload = toByteSequence(command);
Location location = appender.storeItem(payload, Journal.USER_RECORD_TYPE, isEnableJournalDiskSyncs());
Location location = appender.storeItem(payload, Journal.USER_RECORD_TYPE, false);
updatedAckLocations.put(location.getDataFileId(), journalLogsReferenced);
}