org.zeromq.jzmq.reactor

Class ReactorBuilder

java.lang.Object

org.zeromq.jzmq.reactor.ReactorBuilder

public class ReactorBuilder
extends Object

Constructor Summary

Constructors

Constructor and Description
ReactorBuilder(ManagedContext context)

Method Summary

Modifier and Type	Method and Description
Reactor	build()
void	run()
void	start()
ReactorBuilder	withAllPollable(SelectableChannel channel, LoopHandler handler)
ReactorBuilder	withAllPollable(Socket socket, LoopHandler handler)
ReactorBuilder	withErrorPollable(SelectableChannel channel, LoopHandler handler)
ReactorBuilder	withErrorPollable(Socket socket, LoopHandler handler)
ReactorBuilder	withInOutPollable(SelectableChannel channel, LoopHandler handler)
ReactorBuilder	withInOutPollable(Socket socket, LoopHandler handler)
ReactorBuilder	withInPollable(SelectableChannel channel, LoopHandler handler)
ReactorBuilder	withInPollable(Socket socket, LoopHandler handler)
ReactorBuilder	withOutPollable(SelectableChannel channel, LoopHandler handler)
ReactorBuilder	withOutPollable(Socket socket, LoopHandler handler)
ReactorBuilder	withPollable(Pollable pollable, LoopHandler handler)
ReactorBuilder	withTimer(long initialDelay, int numIterations, LoopHandler handler)
ReactorBuilder	withTimerOnce(long initialDelay, LoopHandler handler)
ReactorBuilder	withTimerOnce(long initialDelay, TimeUnit unit, LoopHandler handler)
ReactorBuilder	withTimerRepeating(long initialDelay, LoopHandler handler)
ReactorBuilder	withTimerRepeating(long initialDelay, TimeUnit unit, LoopHandler handler)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactorBuilder

public ReactorBuilder(ManagedContext context)

Method Detail

withPollable

public ReactorBuilder withPollable(Pollable pollable,
                                   LoopHandler handler)

withInPollable

public ReactorBuilder withInPollable(Socket socket,
                                     LoopHandler handler)

withOutPollable

public ReactorBuilder withOutPollable(Socket socket,
                                      LoopHandler handler)

withErrorPollable

public ReactorBuilder withErrorPollable(Socket socket,
                                        LoopHandler handler)

withInOutPollable

public ReactorBuilder withInOutPollable(Socket socket,
                                        LoopHandler handler)

withAllPollable

public ReactorBuilder withAllPollable(Socket socket,
                                      LoopHandler handler)

withInPollable

public ReactorBuilder withInPollable(SelectableChannel channel,
                                     LoopHandler handler)

withOutPollable

public ReactorBuilder withOutPollable(SelectableChannel channel,
                                      LoopHandler handler)

withErrorPollable

public ReactorBuilder withErrorPollable(SelectableChannel channel,
                                        LoopHandler handler)

withInOutPollable

public ReactorBuilder withInOutPollable(SelectableChannel channel,
                                        LoopHandler handler)

withAllPollable

public ReactorBuilder withAllPollable(SelectableChannel channel,
                                      LoopHandler handler)

withTimer

public ReactorBuilder withTimer(long initialDelay,
                                int numIterations,
                                LoopHandler handler)

withTimerOnce

public ReactorBuilder withTimerOnce(long initialDelay,
                                    LoopHandler handler)

withTimerOnce

public ReactorBuilder withTimerOnce(long initialDelay,
                                    TimeUnit unit,
                                    LoopHandler handler)

withTimerRepeating

public ReactorBuilder withTimerRepeating(long initialDelay,
                                         LoopHandler handler)

withTimerRepeating

public ReactorBuilder withTimerRepeating(long initialDelay,
                                         TimeUnit unit,
                                         LoopHandler handler)

build

public Reactor build()

start

public void start()

run

public void run()