* The example uses Java NIO framework to implement the Reactor. * - * @author npathai - * */ public class App { diff --git a/reactor/src/main/java/com/iluwatar/reactor/app/AppClient.java b/reactor/src/main/java/com/iluwatar/reactor/app/AppClient.java index c50e4d3e7..659f5da21 100644 --- a/reactor/src/main/java/com/iluwatar/reactor/app/AppClient.java +++ b/reactor/src/main/java/com/iluwatar/reactor/app/AppClient.java @@ -17,8 +17,6 @@ import java.util.concurrent.TimeUnit; /** * Represents the clients of Reactor pattern. Multiple clients are run concurrently and send logging * requests to Reactor. - * - * @author npathai */ public class AppClient { private final ExecutorService service = Executors.newFixedThreadPool(4); diff --git a/reactor/src/main/java/com/iluwatar/reactor/app/LoggingHandler.java b/reactor/src/main/java/com/iluwatar/reactor/app/LoggingHandler.java index 1f2694b0b..0845303df 100644 --- a/reactor/src/main/java/com/iluwatar/reactor/app/LoggingHandler.java +++ b/reactor/src/main/java/com/iluwatar/reactor/app/LoggingHandler.java @@ -10,8 +10,6 @@ import com.iluwatar.reactor.framework.NioDatagramChannel.DatagramPacket; /** * Logging server application logic. It logs the incoming requests on standard console and returns a * canned acknowledgement back to the remote peer. - * - * @author npathai */ public class LoggingHandler implements ChannelHandler { diff --git a/reactor/src/main/java/com/iluwatar/reactor/framework/AbstractNioChannel.java b/reactor/src/main/java/com/iluwatar/reactor/framework/AbstractNioChannel.java index 09f308731..4abacd86f 100644 --- a/reactor/src/main/java/com/iluwatar/reactor/framework/AbstractNioChannel.java +++ b/reactor/src/main/java/com/iluwatar/reactor/framework/AbstractNioChannel.java @@ -19,9 +19,6 @@ import java.util.concurrent.ConcurrentLinkedQueue; * concrete implementation. It provides a block writing mechanism wherein when any * {@link ChannelHandler} wants to write data back, it queues the data in pending write queue and * clears it in block manner. This provides better throughput. - * - * @author npathai - * */ public abstract class AbstractNioChannel { diff --git a/reactor/src/main/java/com/iluwatar/reactor/framework/ChannelHandler.java b/reactor/src/main/java/com/iluwatar/reactor/framework/ChannelHandler.java index a4a392a34..381738ecd 100644 --- a/reactor/src/main/java/com/iluwatar/reactor/framework/ChannelHandler.java +++ b/reactor/src/main/java/com/iluwatar/reactor/framework/ChannelHandler.java @@ -9,8 +9,6 @@ import java.nio.channels.SelectionKey; *
* A {@link ChannelHandler} can be associated with one or many {@link AbstractNioChannel}s, and * whenever an event occurs on any of the associated channels, the handler is notified of the event. - * - * @author npathai */ public interface ChannelHandler { diff --git a/reactor/src/main/java/com/iluwatar/reactor/framework/Dispatcher.java b/reactor/src/main/java/com/iluwatar/reactor/framework/Dispatcher.java index 0ed53f8fc..78aeb84df 100644 --- a/reactor/src/main/java/com/iluwatar/reactor/framework/Dispatcher.java +++ b/reactor/src/main/java/com/iluwatar/reactor/framework/Dispatcher.java @@ -16,8 +16,6 @@ import java.nio.channels.SelectionKey; * * @see SameThreadDispatcher * @see ThreadPoolDispatcher - * - * @author npathai */ public interface Dispatcher { /** diff --git a/reactor/src/main/java/com/iluwatar/reactor/framework/NioDatagramChannel.java b/reactor/src/main/java/com/iluwatar/reactor/framework/NioDatagramChannel.java index 089911d10..b55480ffc 100644 --- a/reactor/src/main/java/com/iluwatar/reactor/framework/NioDatagramChannel.java +++ b/reactor/src/main/java/com/iluwatar/reactor/framework/NioDatagramChannel.java @@ -10,8 +10,6 @@ import java.nio.channels.SelectionKey; /** * A wrapper over {@link DatagramChannel} which can read and write data on a DatagramChannel. - * - * @author npathai */ public class NioDatagramChannel extends AbstractNioChannel { diff --git a/reactor/src/main/java/com/iluwatar/reactor/framework/NioReactor.java b/reactor/src/main/java/com/iluwatar/reactor/framework/NioReactor.java index 89af20630..b818612e5 100644 --- a/reactor/src/main/java/com/iluwatar/reactor/framework/NioReactor.java +++ b/reactor/src/main/java/com/iluwatar/reactor/framework/NioReactor.java @@ -28,9 +28,6 @@ import java.util.concurrent.TimeUnit; * NOTE: This is one of the ways to implement NIO reactor and it does not take care of all possible * edge cases which are required in a real application. This implementation is meant to demonstrate * the fundamental concepts that lie behind Reactor pattern. - * - * @author npathai - * */ public class NioReactor { diff --git a/reactor/src/main/java/com/iluwatar/reactor/framework/NioServerSocketChannel.java b/reactor/src/main/java/com/iluwatar/reactor/framework/NioServerSocketChannel.java index 17f47a394..c635a6076 100644 --- a/reactor/src/main/java/com/iluwatar/reactor/framework/NioServerSocketChannel.java +++ b/reactor/src/main/java/com/iluwatar/reactor/framework/NioServerSocketChannel.java @@ -11,8 +11,6 @@ import java.nio.channels.SocketChannel; /** * A wrapper over {@link NioServerSocketChannel} which can read and write data on a * {@link SocketChannel}. - * - * @author npathai */ public class NioServerSocketChannel extends AbstractNioChannel { diff --git a/reactor/src/main/java/com/iluwatar/reactor/framework/SameThreadDispatcher.java b/reactor/src/main/java/com/iluwatar/reactor/framework/SameThreadDispatcher.java index baacda9f3..ae995428e 100644 --- a/reactor/src/main/java/com/iluwatar/reactor/framework/SameThreadDispatcher.java +++ b/reactor/src/main/java/com/iluwatar/reactor/framework/SameThreadDispatcher.java @@ -11,8 +11,6 @@ import java.nio.channels.SelectionKey; * For better performance use {@link ThreadPoolDispatcher}. * * @see ThreadPoolDispatcher - * - * @author npathai */ public class SameThreadDispatcher implements Dispatcher { diff --git a/reactor/src/main/java/com/iluwatar/reactor/framework/ThreadPoolDispatcher.java b/reactor/src/main/java/com/iluwatar/reactor/framework/ThreadPoolDispatcher.java index 9fd539adb..4a240659e 100644 --- a/reactor/src/main/java/com/iluwatar/reactor/framework/ThreadPoolDispatcher.java +++ b/reactor/src/main/java/com/iluwatar/reactor/framework/ThreadPoolDispatcher.java @@ -9,9 +9,6 @@ import java.util.concurrent.TimeUnit; * An implementation that uses a pool of worker threads to dispatch the events. This provides better * scalability as the application specific processing is not performed in the context of I/O * (reactor) thread. - * - * @author npathai - * */ public class ThreadPoolDispatcher implements Dispatcher { diff --git a/reactor/src/test/java/com/iluwatar/reactor/app/AppTest.java b/reactor/src/test/java/com/iluwatar/reactor/app/AppTest.java index 2ac9b448a..752192ef3 100644 --- a/reactor/src/test/java/com/iluwatar/reactor/app/AppTest.java +++ b/reactor/src/test/java/com/iluwatar/reactor/app/AppTest.java @@ -11,8 +11,6 @@ import com.iluwatar.reactor.framework.ThreadPoolDispatcher; * * This class tests the Distributed Logging service by starting a Reactor and then sending it * concurrent logging requests using multiple clients. - * - * @author npathai */ public class AppTest {