fixed bugs
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/2c2c6a2a Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/2c2c6a2a Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/2c2c6a2a Branch: refs/heads/NIFI-274 Commit: 2c2c6a2a1044d3a10f003bb432701c4a023dde35 Parents: fc2da15 Author: Tony Kurc <[email protected]> Authored: Sat Oct 31 12:51:11 2015 -0400 Committer: Tony Kurc <[email protected]> Committed: Sat Oct 31 12:51:11 2015 -0400 ---------------------------------------------------------------------- .../java/org/apache/nifi/processors/standard/ListenSyslog.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/2c2c6a2a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListenSyslog.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListenSyslog.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListenSyslog.java index 066a318..fd93847 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListenSyslog.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListenSyslog.java @@ -330,7 +330,8 @@ public class ListenSyslog extends AbstractSyslogProcessor { continue; } DatagramChannel channel = (DatagramChannel) key.channel(); - SocketAddress sender = channel.receive(buffer); + SocketAddress sender; + buffer.clear(); while (!stopped && (sender = channel.receive(buffer)) != null) { final SyslogEvent event = syslogParser.parseEvent(buffer); logger.trace(event.getFullMessage());
