From a45c1e88db48cc9037662532aabcfd10397f3ad7 Mon Sep 17 00:00:00 2001
From: Giovanni Gargiulo <gargiulo.gianni@gmail.com>
Date: Wed, 17 Apr 2024 15:46:12 +0100
Subject: [PATCH] chore: fixing removal of TX from FIFO queue

---
 .../yaci/core/protocol/txsubmission/TxSubmissionAgent.java | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

diff --git a/core/src/main/java/com/bloxbean/cardano/yaci/core/protocol/txsubmission/TxSubmissionAgent.java b/core/src/main/java/com/bloxbean/cardano/yaci/core/protocol/txsubmission/TxSubmissionAgent.java
index 9bcd439..0f84cca 100644
--- a/core/src/main/java/com/bloxbean/cardano/yaci/core/protocol/txsubmission/TxSubmissionAgent.java
+++ b/core/src/main/java/com/bloxbean/cardano/yaci/core/protocol/txsubmission/TxSubmissionAgent.java
@@ -80,11 +80,8 @@ private ReplyTxs getReplyTxs() {
             return new ReplyTxs();
 
         ReplyTxs replyTxs = new ReplyTxs();
-        requestedTxIds.forEach(txId -> removeTxIdAndHash(txId).ifPresent(txSubmissionRequest -> replyTxs.addTx(txSubmissionRequest.getTxnBytes())));
+        requestedTxIds.forEach(txId -> findTxIdAndHash(txId).ifPresent(txSubmissionRequest -> replyTxs.addTx(txSubmissionRequest.getTxnBytes())));
 
-        // Ids of requested TXs don't seem to be acked from server.
-        // Removing them right away now.
-        requestedTxIds.forEach(pendingTxIds::remove);
         if (log.isDebugEnabled())
             log.debug("Txs: {}", replyTxs.getTxns().size());
         return replyTxs;
@@ -161,8 +158,6 @@ private void removeAcknowledgedTxs(int numAcknowledgedTransactions) {
                 if (txHash != null) {
                     // remove from map
                     removeTxIdAndHash(txHash);
-                    // removed from queue
-                    pendingTxIds.remove(txHash);
                 }
             }