|
|
@@ -66,20 +66,20 @@ public class EventJoinTest {
|
|
|
EventRouterThread main = new EventRouterThread("name", 32, 1000, joiner).start();
|
|
|
|
|
|
main.addEventListener(Event.class, hits.new HitListener<Event>("global") );
|
|
|
- main.addEventListener(IOEvent.class, hits.new HitListener<IOEvent>("io") );
|
|
|
- main.addEventListener(ReadEvent.class, hits.new HitListener<ReadEvent>("read") );
|
|
|
- main.addEventListener(WriteEvent.class, hits.new HitListener<WriteEvent>("write") );
|
|
|
+ main.addEventListener(TIOEvent.class, hits.new HitListener<TIOEvent>("io") );
|
|
|
+ main.addEventListener(TReadEvent.class, hits.new HitListener<TReadEvent>("read") );
|
|
|
+ main.addEventListener(TWriteEvent.class, hits.new HitListener<TWriteEvent>("write") );
|
|
|
main.addEventListener(ShutdownEvent.class, hits.new HitListener<ShutdownEvent>("shutdown") );
|
|
|
main.addEventListener(ExitEvent.class, hits.new HitListener<ExitEvent>("exit") );
|
|
|
|
|
|
- main.signalEvent(new WriteEvent());
|
|
|
- main.signalEvent(new WriteEvent());
|
|
|
- main.signalEvent(new ReadEvent());
|
|
|
- main.signalEvent(new ReadEvent());
|
|
|
- main.signalEvent(new ReadEvent());
|
|
|
+ main.signalEvent(new TWriteEvent());
|
|
|
+ main.signalEvent(new TWriteEvent());
|
|
|
+ main.signalEvent(new TReadEvent());
|
|
|
+ main.signalEvent(new TReadEvent());
|
|
|
+ main.signalEvent(new TReadEvent());
|
|
|
main.signalEvent(new Event(){});
|
|
|
- main.signalEvent(new ReadEvent());
|
|
|
- main.signalEvent(new ReadEvent());
|
|
|
+ main.signalEvent(new TReadEvent());
|
|
|
+ main.signalEvent(new TReadEvent());
|
|
|
|
|
|
main.stop();
|
|
|
|
|
|
@@ -94,11 +94,11 @@ public class EventJoinTest {
|
|
|
}
|
|
|
|
|
|
@SuppressWarnings("PMD")
|
|
|
- class IOEvent implements Event { }
|
|
|
+ class TIOEvent implements Event { }
|
|
|
|
|
|
@SuppressWarnings("PMD")
|
|
|
- class ReadEvent extends IOEvent { }
|
|
|
+ class TReadEvent extends TIOEvent { }
|
|
|
|
|
|
@SuppressWarnings("PMD")
|
|
|
- class WriteEvent extends IOEvent { }
|
|
|
+ class TWriteEvent extends TIOEvent { }
|
|
|
}
|