You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ex...@apache.org on 2021/10/25 20:56:09 UTC
[nifi] branch main updated (8fe7f37 -> 309ab8f)
This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 8fe7f37 NIFI-9329 - Expose event validation in ParseCEF processor (#5477)
add 309ab8f NIFI-8792 - Modified ListenRELP to use Netty
No new revisions were added by this update.
Summary of changes:
.../apache/nifi/remote/io/socket/NetworkUtils.java | 23 +-
.../apache/nifi/event/transport/NetworkEvent.java} | 19 +-
.../event/transport/message/ByteArrayMessage.java | 4 +-
.../AbstractListenEventBatchingProcessor.java | 35 +--
.../util/listen/AbstractListenEventProcessor.java | 17 +-
.../nifi/processor/util/listen/EventBatcher.java | 161 ++++++++++++++
.../processor/util/listen/FlowFileEventBatch.java} | 40 ++--
.../processor/util/listen/ListenerProperties.java | 67 ++++++
.../util/listen/event/NetworkEventFactory.java} | 35 ++-
.../listen/event/StandardNetworkEventFactory.java} | 26 +--
.../processor/util/listen/EventBatcherTest.java | 96 ++++++++
.../nifi-standard-processors/pom.xml | 6 +
.../nifi/processors/standard/ListenRELP.java | 242 ++++++++++++++-------
.../event/{RELPEvent.java => RELPMessage.java} | 14 +-
...LPEventFactory.java => RELPMessageFactory.java} | 12 +-
.../standard/relp/event/RELPMetadata.java | 1 +
.../standard/relp/frame/RELPDecoder.java | 16 +-
.../RELPFrameDecoder.java} | 88 ++++----
.../relp/frame/RELPMessageChannelHandler.java | 58 +++++
.../RELPResponseEncoder.java} | 30 ++-
.../relp/handler/RELPMessageServerFactory.java | 60 +++++
.../relp/handler/RELPSSLSocketChannelHandler.java | 88 --------
.../relp/handler/RELPSocketChannelHandler.java | 98 ---------
.../handler/RELPSocketChannelHandlerFactory.java | 56 -----
.../standard/relp/response/RELPResponse.java | 16 +-
.../nifi/processors/standard/TestListenRELP.java | 214 +++++++++---------
.../nifi/processors/standard/TestListenTCP.java | 3 +-
.../nifi/processors/standard/TestListenUDP.java | 9 +-
.../standard/relp/event/TestRELPEventFactory.java | 55 -----
.../standard/relp/frame/RELPFrameDecoderTest.java | 99 +++++++++
.../relp/frame/RELPResponseEncoderTest.java | 45 ++++
.../relp/handler/TestRELPFrameHandler.java | 166 --------------
.../relp/handler/TestRELPSocketChannelHandler.java | 209 ------------------
33 files changed, 1062 insertions(+), 1046 deletions(-)
copy nifi-nar-bundles/{nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/relp/event/RELPMetadata.java => nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/NetworkEvent.java} (72%)
create mode 100644 nifi-nar-bundles/nifi-extension-utils/nifi-processor-utils/src/main/java/org/apache/nifi/processor/util/listen/EventBatcher.java
copy nifi-nar-bundles/nifi-extension-utils/{nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java => nifi-processor-utils/src/main/java/org/apache/nifi/processor/util/listen/FlowFileEventBatch.java} (52%)
copy nifi-nar-bundles/nifi-extension-utils/{nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java => nifi-processor-utils/src/main/java/org/apache/nifi/processor/util/listen/event/NetworkEventFactory.java} (60%)
copy nifi-nar-bundles/nifi-extension-utils/{nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java => nifi-processor-utils/src/main/java/org/apache/nifi/processor/util/listen/event/StandardNetworkEventFactory.java} (63%)
create mode 100644 nifi-nar-bundles/nifi-extension-utils/nifi-processor-utils/src/test/java/org/apache/nifi/processor/util/listen/EventBatcherTest.java
rename nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/relp/event/{RELPEvent.java => RELPMessage.java} (68%)
copy nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/relp/event/{RELPEventFactory.java => RELPMessageFactory.java} (71%)
rename nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/relp/{handler/RELPFrameHandler.java => frame/RELPFrameDecoder.java} (52%)
create mode 100644 nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/relp/frame/RELPMessageChannelHandler.java
rename nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/relp/{event/RELPEventFactory.java => frame/RELPResponseEncoder.java} (51%)
create mode 100644 nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/relp/handler/RELPMessageServerFactory.java
delete mode 100644 nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/relp/handler/RELPSSLSocketChannelHandler.java
delete mode 100644 nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/relp/handler/RELPSocketChannelHandler.java
delete mode 100644 nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/relp/handler/RELPSocketChannelHandlerFactory.java
delete mode 100644 nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/relp/event/TestRELPEventFactory.java
create mode 100644 nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/relp/frame/RELPFrameDecoderTest.java
create mode 100644 nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/relp/frame/RELPResponseEncoderTest.java
delete mode 100644 nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/relp/handler/TestRELPFrameHandler.java
delete mode 100644 nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/relp/handler/TestRELPSocketChannelHandler.java