[mina] 02/02: Fix DIRMINA-996 adds "break" to prevent message sent loop

[johnnyv]

This is an automated email from the ASF dual-hosted git repository.

johnnyv pushed a commit to branch 2.1.X
in repository https://gitbox.apache.org/repos/asf/mina.git

commit 55f4b4d66bd05b4f26d61e1ad51f025e20452889
Author: johnnyv <john...@apache.org>
AuthorDate: Wed Apr 15 11:41:23 2020 -0400

    Fix DIRMINA-996 adds "break" to prevent message sent loop
---
 .../org/apache/mina/transport/socket/nio/NioDatagramAcceptor.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/mina-core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramAcceptor.java
 
b/mina-core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramAcceptor.java
index a2f7420..42b74ce 100644
--- 
a/mina-core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramAcceptor.java
+++ 
b/mina-core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramAcceptor.java
@@ -896,8 +896,10 @@ public final class NioDatagramAcceptor extends 
AbstractIoAcceptor implements Dat
                     // Kernel buffer is full or wrote too much
                     setInterestedInWrite(session, true);
 
-                    session.getWriteRequestQueue().offer(session, 
writeRequest);
+                    writeRequestQueue.offer(session, writeRequest);
                     scheduleFlush(session);
+                    
+                    break;
                 } else {
                     setInterestedInWrite(session, false);