Adjusted the size of UDP receive buffer

monkeymq · Dec 14, 2020 · 59ba21e · 59ba21e
1 parent 3507652
commit 59ba21e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/java/net/lvsq/jgossip/net/udp/UDPMsgService.java b/src/main/java/net/lvsq/jgossip/net/udp/UDPMsgService.java
@@ -38,7 +38,9 @@ public class UDPMsgService implements MsgService {
 
     @Override
     public void listen(String ipAddress, int port) {
-        socket = Vertx.vertx().createDatagramSocket(new DatagramSocketOptions());
+        DatagramSocketOptions options = new DatagramSocketOptions();
+        options.setReceiveBufferSize(65535);
+        socket = Vertx.vertx().createDatagramSocket(options);
         socket.listen(port, ipAddress, asyncResult -> {
             if (asyncResult.succeeded()) {
                 socket.handler(packet -> handleMsg(packet.data()));