You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by tk...@apache.org on 2015/11/02 21:30:33 UTC
[08/10] nifi git commit: fixed bugs
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 <tr...@gmail.com>
Authored: Sat Oct 31 12:51:11 2015 -0400
Committer: Tony Kurc <tr...@gmail.com>
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());