diff options
| author | jonmv <venstad@gmail.com> | 2023-10-13 17:25:45 +0200 |
|---|---|---|
| committer | jonmv <venstad@gmail.com> | 2023-10-13 17:25:45 +0200 |
| commit | 6606a8d38c25db4180317cb7aa31fa5b9b5c4815 (patch) | |
| tree | 9195f8d19a5a2f85b802c90cb944a225277cceac /messagebus/src/main | |
| parent | 3741bd8da83e2b2b27fd0f746689bb11464576f3 (diff) | |
Test sequencer with messenger and deep reply->send-next recursion
Diffstat (limited to 'messagebus/src/main')
| -rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java b/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java index 2244559b54a..05e71e0f006 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java @@ -148,7 +148,7 @@ public class Sequencer implements MessageHandler, ReplyHandler { private final Message msg; SequencedSendTask(Message msg) { this.msg = msg; } @Override public void run() { sequencedSend(msg); } - @Override public void destroy() { msg.discard(); } + @Override public void destroy() { } } private void sendNextInSequence(long seqId) { |