From 401b7d07fabea4b846d103c767f585b5ad46a144 Mon Sep 17 00:00:00 2001 From: Jochen Schalanda Date: Thu, 18 Feb 2016 14:41:58 +0100 Subject: [PATCH] Add length check of UDP packet to UDPNetSyslogServer#run() Fixes #5 --- .../syslog4j/server/impl/net/udp/UDPNetSyslogServer.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/org/graylog2/syslog4j/server/impl/net/udp/UDPNetSyslogServer.java b/src/main/java/org/graylog2/syslog4j/server/impl/net/udp/UDPNetSyslogServer.java index de943ea..3b035af 100644 --- a/src/main/java/org/graylog2/syslog4j/server/impl/net/udp/UDPNetSyslogServer.java +++ b/src/main/java/org/graylog2/syslog4j/server/impl/net/udp/UDPNetSyslogServer.java @@ -81,10 +81,10 @@ public class UDPNetSyslogServer extends AbstractSyslogServer { this.ds.receive(dp); - SyslogServerEventIF event = createEvent(this.getConfig(), receiveData, dp.getLength(), dp.getAddress()); - - handleEvent(null, this, dp, event); - + if(dp.getLength() > 0) { + SyslogServerEventIF event = createEvent(this.getConfig(), receiveData, dp.getLength(), dp.getAddress()); + handleEvent(null, this, dp, event); + } } catch (SocketException se) { int i = se.getMessage() == null ? -1 : se.getMessage().toLowerCase().indexOf("socket closed");