This is an automated email from the ASF dual-hosted git repository. mblow pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/asterixdb.git
commit f1da2bbdacacf3773ff1a3adc04b8937e3396b65 Author: Michael Blow <[email protected]> AuthorDate: Mon Sep 8 13:33:56 2025 -0400 [NO ISSUE][*DB][RT] Whisper logging for active partition,txn block msgs Ext-ref: MB-68418 Change-Id: Ieca9e6fa9ce2862c892d9444c522e6fde12e1832 Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20365 Tested-by: Michael Blow <[email protected]> Reviewed-by: Michael Blow <[email protected]> --- .../org/apache/asterix/active/message/ActivePartitionMessage.java | 5 +++++ .../java/org/apache/asterix/runtime/message/TxnIdBlockRequest.java | 5 +++++ 2 files changed, 10 insertions(+) diff --git a/asterixdb/asterix-active/src/main/java/org/apache/asterix/active/message/ActivePartitionMessage.java b/asterixdb/asterix-active/src/main/java/org/apache/asterix/active/message/ActivePartitionMessage.java index 2955271afc..5a4ca2edcf 100644 --- a/asterixdb/asterix-active/src/main/java/org/apache/asterix/active/message/ActivePartitionMessage.java +++ b/asterixdb/asterix-active/src/main/java/org/apache/asterix/active/message/ActivePartitionMessage.java @@ -78,6 +78,11 @@ public class ActivePartitionMessage implements ICcAddressedMessage { activeListener.receive(this); } + @Override + public boolean isWhispered() { + return true; + } + @Override public String toString() { return activeRuntimeId + ":" + ActivePartitionMessage.class.getSimpleName() + '-' + event + '(' + desc + ')'; diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/message/TxnIdBlockRequest.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/message/TxnIdBlockRequest.java index 2d9acf44a1..9ca3b81319 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/message/TxnIdBlockRequest.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/message/TxnIdBlockRequest.java @@ -73,6 +73,11 @@ public class TxnIdBlockRequest implements ICcAddressedMessage { blockQueue.offer(response); } + @Override + public boolean isWhispered() { + return true; + } + @Override public String toString() { return TxnIdBlockRequest.class.getSimpleName();
