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

fix formatting

This commit is contained in:
gtully 2015-05-20 12:50:33 +01:00
parent 9ad65c62ed
commit 9ae5b4147b
1 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
View File

@ -425,26 +425,26 @@ public class KahaDBStore extends MessageDatabase implements PersistenceAdapter {
command.setPrioritySupported(isPrioritizedMessages()); command.setPrioritySupported(isPrioritizedMessages());
org.apache.activemq.util.ByteSequence packet = wireFormat.marshal(message); org.apache.activemq.util.ByteSequence packet = wireFormat.marshal(message);
command.setMessage(new Buffer(packet.getData(), packet.getOffset(), packet.getLength())); command.setMessage(new Buffer(packet.getData(), packet.getOffset(), packet.getLength()));
store(command, isEnableJournalDiskSyncs() && message.isResponseRequired(), new IndexAware() { store(command, isEnableJournalDiskSyncs() && message.isResponseRequired(), new IndexAware() {
// sync add? (for async, future present from getFutureOrSequenceLong) // sync add? (for async, future present from getFutureOrSequenceLong)
Object possibleFuture = message.getMessageId().getFutureOrSequenceLong(); Object possibleFuture = message.getMessageId().getFutureOrSequenceLong();
@Override @Override
public void sequenceAssignedWithIndexLocked(final long sequence) { public void sequenceAssignedWithIndexLocked(final long sequence) {
message.getMessageId().setFutureOrSequenceLong(sequence); message.getMessageId().setFutureOrSequenceLong(sequence);
if (indexListener != null) { if (indexListener != null) {
if (possibleFuture == null) { if (possibleFuture == null) {
trackPendingAdd(dest, sequence); trackPendingAdd(dest, sequence);
indexListener.onAdd(new IndexListener.MessageContext(context, message, new Runnable() { indexListener.onAdd(new IndexListener.MessageContext(context, message, new Runnable() {
@Override @Override
public void run() { public void run() {
trackPendingAddComplete(dest, sequence); trackPendingAddComplete(dest, sequence);
} }
})); }));
}
} }
} }
}, null); }
}, null);
} }
@Override @Override