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);
                 }
             }