From c0cd83870c970ac9534e9fba63afe8e9744892a9 Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Thu, 1 Mar 2007 21:13:40 +0000 Subject: [PATCH] turbo charge performance ;) git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513494 13f79535-47bb-0310-9956-ffa450edef68 --- .../store/amq/AMQPersistenceAdapter.java | 17 ++++++++++++++--- 1 file changed, 14 insertions(+), 3 deletions(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java b/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java index e07f551864..9f7c2fe8f6 100644 --- a/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java +++ b/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java @@ -106,6 +106,7 @@ public class AMQPersistenceAdapter implements PersistenceAdapter, UsageListener private Runnable periodicCleanupTask; private boolean deleteAllMessages; + private boolean syncOnWrite; private File directory = new File(IOHelper.getDefaultDataDirectory() + "/amq"); @@ -560,12 +561,12 @@ public class AMQPersistenceAdapter implements PersistenceAdapter, UsageListener /** * * @param command - * @param sync + * @param syncHint * @return * @throws IOException */ - public Location writeCommand(DataStructure command, boolean sync) throws IOException { - return asyncDataManager.write(wireFormat.marshal(command), sync); + public Location writeCommand(DataStructure command, boolean syncHint) throws IOException { + return asyncDataManager.write(wireFormat.marshal(command), (syncHint && syncOnWrite)); } private Location writeTraceMessage(String message, boolean sync) throws IOException { @@ -677,4 +678,14 @@ public class AMQPersistenceAdapter implements PersistenceAdapter, UsageListener this.directory = directory; } + public boolean isSyncOnWrite(){ + return this.syncOnWrite; + } + + public void setSyncOnWrite(boolean syncOnWrite){ + this.syncOnWrite=syncOnWrite; + } + + + }