Added the echo effect for the IRC

Author: ZeusSeinGrossopa

netty-server/src/main/java/de/zeus/server/ExampleServer.java

@@ -11,11 +11,13 @@
  */
 public class ExampleServer {
 
+    public static NettyServer server;
+
     /**
      * The main method
      */
     public static void main(String[] args) {
-        NettyServer server = new NettyServer();
+        server = new NettyServer();
         Scanner scanner = new Scanner(System.in);
 
         System.out.println("Enter the port to start the server on: ");

netty-server/src/main/java/de/zeus/server/NettyServer.java

@@ -108,6 +108,18 @@ public void sendMessage(String message) {
         System.out.println("Sent message: " + message);
     }
 
+    /**
+     * Sends a message to a specific client
+     *
+     * @param message the message to send
+     * @param channel the channel to send the message to
+     */
+    public void sendMessageFor(String message, Channel channel) {
+        if(channel != null && channel.isOpen()) {
+            channel.writeAndFlush(Unpooled.wrappedBuffer(message.getBytes()));
+        }
+    }
+
     public NioEventLoopGroup getNioEventLoopGroup() {
         return nioEventLoopGroup;
     }

netty-server/src/main/java/de/zeus/server/netty/ChannelReader.java

@@ -1,5 +1,6 @@
 package de.zeus.server.netty;
 
+import de.zeus.server.ExampleServer;
 import de.zeus.server.NettyServer;
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;
@@ -31,6 +32,7 @@ protected void channelRead0(ChannelHandlerContext channel, Object object) throws
         String message = ((ByteBuf) object).toString(Charset.defaultCharset());
         System.out.println("Received Message: " + message);
 
+        nettyServer.getRegisteredChannels().stream().filter(e -> e != channel.channel()).forEach(e -> ExampleServer.server.sendMessageFor(message, e));
         nettyServer.getMessageReceivedListeners().forEach(listener -> listener.onMessageReceived(message));
     }