From 41647e94f083109e26ce00d12ee5ac19fc0db7a8 Mon Sep 17 00:00:00 2001
From: zzz <zzz@i2pmail.org>
Date: Fri, 1 May 2026 13:10:19 -0400
Subject: [PATCH] I2CP: Wait for queue space on internal queue close()

reported by: bottomlineit.co.za
---
 core/java/src/net/i2p/internal/I2CPMessageQueue.java | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/core/java/src/net/i2p/internal/I2CPMessageQueue.java b/core/java/src/net/i2p/internal/I2CPMessageQueue.java
index 76584255c..dbcb650de 100644
--- a/core/java/src/net/i2p/internal/I2CPMessageQueue.java
+++ b/core/java/src/net/i2p/internal/I2CPMessageQueue.java
@@ -53,9 +53,12 @@ public abstract class I2CPMessageQueue implements Closeable {
     public abstract I2CPMessage take() throws InterruptedException;
 
     /**
-     *  == offer(new PoisonI2CPMessage());
+     *  == put(new PoisonI2CPMessage());
+     *  Blocking if queue is full
      */
     public void close() {
-        offer(new PoisonI2CPMessage());
+        try {
+            put(new PoisonI2CPMessage());
+        } catch (InterruptedException ie) {}
     }
 }