You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2015/05/20 14:43:36 UTC
[7/8] activemq git commit: fix formatting
fix formatting
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/9ae5b414
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/9ae5b414
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/9ae5b414
Branch: refs/heads/master
Commit: 9ae5b4147b9f6f078ca43d6dcdcc2874c907d099
Parents: 9ad65c6
Author: gtully <ga...@gmail.com>
Authored: Wed May 20 12:50:33 2015 +0100
Committer: gtully <ga...@gmail.com>
Committed: Wed May 20 12:50:33 2015 +0100
----------------------------------------------------------------------
.../activemq/store/kahadb/KahaDBStore.java | 34 ++++++++++----------
1 file changed, 17 insertions(+), 17 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/9ae5b414/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
----------------------------------------------------------------------
diff --git a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
index f6ef482..7e06a57 100644
--- a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
+++ b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
@@ -425,26 +425,26 @@ public class KahaDBStore extends MessageDatabase implements PersistenceAdapter {
command.setPrioritySupported(isPrioritizedMessages());
org.apache.activemq.util.ByteSequence packet = wireFormat.marshal(message);
command.setMessage(new Buffer(packet.getData(), packet.getOffset(), packet.getLength()));
- store(command, isEnableJournalDiskSyncs() && message.isResponseRequired(), new IndexAware() {
- // sync add? (for async, future present from getFutureOrSequenceLong)
- Object possibleFuture = message.getMessageId().getFutureOrSequenceLong();
+ store(command, isEnableJournalDiskSyncs() && message.isResponseRequired(), new IndexAware() {
+ // sync add? (for async, future present from getFutureOrSequenceLong)
+ Object possibleFuture = message.getMessageId().getFutureOrSequenceLong();
- @Override
- public void sequenceAssignedWithIndexLocked(final long sequence) {
- message.getMessageId().setFutureOrSequenceLong(sequence);
- if (indexListener != null) {
- if (possibleFuture == null) {
- trackPendingAdd(dest, sequence);
- indexListener.onAdd(new IndexListener.MessageContext(context, message, new Runnable() {
- @Override
- public void run() {
- trackPendingAddComplete(dest, sequence);
- }
- }));
- }
+ @Override
+ public void sequenceAssignedWithIndexLocked(final long sequence) {
+ message.getMessageId().setFutureOrSequenceLong(sequence);
+ if (indexListener != null) {
+ if (possibleFuture == null) {
+ trackPendingAdd(dest, sequence);
+ indexListener.onAdd(new IndexListener.MessageContext(context, message, new Runnable() {
+ @Override
+ public void run() {
+ trackPendingAddComplete(dest, sequence);
+ }
+ }));
}
}
- }, null);
+ }
+ }, null);
}
@Override