This is an automated email from the ASF dual-hosted git repository.
thenatog pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 5108d7c NIFI-8439 Update parquet-avro to allow reading parquet INT96
timestamps as byte arrays (instead of throwing an exception).
add a3365c8 NIFI-8462 Refactored PutSyslog and ListenSyslog using Netty
No new revisions were added by this update.
Summary of changes:
.../apache/nifi/remote/io/socket/NetworkUtils.java | 53 ++-
.../{ => nifi-event-transport}/pom.xml | 41 +-
.../nifi/event/transport/EventException.java | 32 ++
.../apache/nifi/event/transport/EventSender.java | 31 ++
.../nifi/event/transport/EventSenderFactory.java | 31 ++
.../apache/nifi/event/transport/EventServer.java | 28 ++
.../nifi/event/transport/EventServerFactory.java | 30 ++
.../event/transport/configuration/LineEnding.java | 25 ++
.../transport/configuration/TransportProtocol.java | 25 ++
.../event/transport/message/ByteArrayMessage.java | 39 ++
.../ByteArrayMessageNettyEventServerFactory.java | 78 ++++
.../transport/netty/EventLoopGroupFactory.java | 63 +++
.../event/transport/netty/NettyEventSender.java | 100 +++++
.../transport/netty/NettyEventSenderFactory.java | 160 +++++++
.../event/transport/netty/NettyEventServer.java | 53 +++
.../transport/netty/NettyEventServerFactory.java | 148 +++++++
.../netty/StringNettyEventSenderFactory.java | 57 +++
.../channel/ByteArrayMessageChannelHandler.java | 52 +++
.../netty/channel/LogExceptionChannelHandler.java | 48 ++
.../netty/channel/StandardChannelInitializer.java | 64 +++
.../pool/InitializingChannelPoolHandler.java | 49 +++
.../ssl/ClientSslStandardChannelInitializer.java | 61 +++
.../ssl/ServerSslHandlerChannelInitializer.java | 70 +++
.../codec/DatagramByteArrayMessageDecoder.java | 51 +++
.../netty/codec/SocketByteArrayMessageDecoder.java | 44 ++
.../netty/NettyEventSenderFactoryTest.java | 64 +++
.../netty/StringNettyEventSenderFactoryTest.java | 158 +++++++
nifi-nar-bundles/nifi-extension-utils/pom.xml | 1 +
.../nifi-standard-processors/pom.xml | 5 +
.../nifi/processors/standard/ListenSyslog.java | 376 ++++++----------
.../apache/nifi/processors/standard/PutSyslog.java | 264 ++++-------
.../standard/ITListenSyslogGroovy.groovy | 111 -----
.../processors/standard/ITListenAndPutSyslog.java | 184 --------
.../nifi/processors/standard/ITListenSyslog.java | 402 -----------------
.../nifi/processors/standard/TestListenSyslog.java | 378 +++++++---------
.../nifi/processors/standard/TestPutSyslog.java | 486 ++++-----------------
36 files changed, 2058 insertions(+), 1804 deletions(-)
copy nifi-nar-bundles/nifi-extension-utils/{ => nifi-event-transport}/pom.xml
(60%)
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/EventException.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/EventSender.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/EventSenderFactory.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/EventServer.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/EventServerFactory.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/configuration/LineEnding.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/configuration/TransportProtocol.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/ByteArrayMessageNettyEventServerFactory.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/EventLoopGroupFactory.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/NettyEventSender.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/NettyEventSenderFactory.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/NettyEventServer.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/NettyEventServerFactory.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/StringNettyEventSenderFactory.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/channel/ByteArrayMessageChannelHandler.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/channel/LogExceptionChannelHandler.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/channel/StandardChannelInitializer.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/channel/pool/InitializingChannelPoolHandler.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/channel/ssl/ClientSslStandardChannelInitializer.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/channel/ssl/ServerSslHandlerChannelInitializer.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/codec/DatagramByteArrayMessageDecoder.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/codec/SocketByteArrayMessageDecoder.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/test/java/org/apache/nifi/event/transport/netty/NettyEventSenderFactoryTest.java
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/test/java/org/apache/nifi/event/transport/netty/StringNettyEventSenderFactoryTest.java
delete mode 100644
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/groovy/org/apache/nifi/processors/standard/ITListenSyslogGroovy.groovy
delete mode 100644
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/ITListenAndPutSyslog.java
delete mode 100644
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/ITListenSyslog.java
