03868aec8224ad0553da01e15e54fac6419ee535 - pulsar-connectors

commit	03868aec8224ad0553da01e15e54fac6419ee535	[log] [tgz]
author	gbensa <58692163+gbensa@users.noreply.github.com>	Sat Dec 14 03:40:39 2019 +0100
committer	Jia Zhai <zhaijia@apache.org>	Sat Dec 14 10:40:39 2019 +0800
tree	86bc99df1a9fcabc677f20c9de851868489971b5
parent	88e8dbd5b6f77fa5539c6b31b866d0764a999bc9 [diff]

[Issue 5827][Issue 5828][netty] Fixes for UDP protocol support in netty connector (#5829)


### Motivation
UDP protocol is not working for netty connector

### Modifications
Added a specific handler for UDP and use Channel instead of SocketChannel in NettyChannelInitializer

Successfully tested

* Fixes for UDP protocol support in netty connector

* Added specific handlers for UDP and TCP netty connector

pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/server/NettyServer.java[diff]
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp/NettyTCPChannelInitializer.java[Renamed from pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/server/NettyChannelInitializer.java - diff]
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp/NettyTCPServerHandler.java[Renamed from pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/server/NettyServerHandler.java - diff]
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp/package-info.java[Added - diff]
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp/NettyUDPChannelInitializer.java[Copied from pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/server/NettyChannelInitializer.java - diff]
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp/NettyUDPServerHandler.java[Copied from pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/server/NettyServerHandler.java - diff]
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp/package-info.java[Added - diff]
pulsar-io/netty/src/main/java/package-info.java[Added - diff]
pulsar-io/netty/src/test/java/org/apache/pulsar/io/netty/tcp/NettyTCPChannelInitializerTest.java[Copied from pulsar-io/netty/src/test/java/org/apache/pulsar/io/netty/server/NettyChannelInitializerTest.java - diff]
pulsar-io/netty/src/test/java/org/apache/pulsar/io/netty/udp/NettyUDPChannelInitializerTest.java[Renamed from pulsar-io/netty/src/test/java/org/apache/pulsar/io/netty/server/NettyChannelInitializerTest.java - diff]

10 files changed

tree: 86bc99df1a9fcabc677f20c9de851868489971b5

pulsar-io/