Package org.jgrapes.io

Class NioDispatcher

java.lang.Object

org.jgrapes.core.internal.ComponentVertex

org.jgrapes.core.Component

org.jgrapes.io.NioDispatcher

All Implemented Interfaces:

Iterable<ComponentType>, Runnable, Channel, ComponentType, Eligible, Manager

public class NioDispatcher
extends Component
implements Runnable

A helper component that provides the central hub for non blocking I/O components.

Exactly one NioDispatcher must exist in any tree with NioHandler components.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	NioDispatcher.Registration	Represents a NIO registration.

Nested classes/interfaces inherited from interface org.jgrapes.core.Channel

Channel.Default

Field Summary

Fields inherited from class org.jgrapes.core.Component

logger

Fields inherited from interface org.jgrapes.core.Channel

BROADCAST, SELF

Constructor Summary

Constructors

Constructor	Description
NioDispatcher()	Creates a new Dispatcher.

Method Summary

Modifier and Type	Method	Description
void	onNioRegistration(NioRegistration event)	Handle the NIO registration.
void	onStart(Start event)	Starts this dispatcher.
void	onStop(Stop event)	Stops the thread that is associated with this dispatcher.
void	run()	Invoked once by the thread associated with the dispatcher.

Methods inherited from class org.jgrapes.core.Component

channel, component, defaultCriterion, isEligibleFor, setName

Methods inherited from class org.jgrapes.core.internal.ComponentVertex

activeEventPipeline, addHandler, attach, channelReplacements, children, componentPath, componentVertex, detach, fire, initComponentsHandlers, iterator, name, newEventPipeline, newEventPipeline, parent, registerAsGenerator, root, toString, unregisterAsGenerator

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface org.jgrapes.core.Manager

stream

Constructor Details

NioDispatcher

public NioDispatcher()
              throws IOException

Creates a new Dispatcher.

Throws:

IOException - if an I/O exception occurred

Method Details

onStart

@Handler
public void onStart(Start event)

Starts this dispatcher.

A dispatcher has an associated thread that keeps it running.

Parameters:

event - the event

onStop

@Handler(priority=-10000)
public void onStop(Stop event)
            throws InterruptedException

Stops the thread that is associated with this dispatcher.

Parameters:

event - the event

Throws:

InterruptedException - if the execution is interrupted

run

public void run()

Invoked once by the thread associated with the dispatcher.

Handles all events from the underlying Selector.

Specified by:

run in interface Runnable

onNioRegistration

@Handler
public void onNioRegistration(NioRegistration event)
                       throws IOException

Handle the NIO registration.

Parameters:

event - the event

Throws:

IOException - Signals that an I/O exception has occurred.