Package de.unistuttgart.isw.sfsc.commonjava.zmq.reactor

Class Reactor

java.lang.Object

de.unistuttgart.isw.sfsc.commonjava.zmq.reactor.Reactor

All Implemented Interfaces:

NotThrowingAutoCloseable, AutoCloseable

public class Reactor
extends Object
implements NotThrowingAutoCloseable

Method Summary

Modifier and Type	Method	Description
Handle	addShutdownListener(Runnable runnable)
void	close()
static Reactor	create(ContextConfiguration contextConfiguration)
ReactiveSocket	createPublisher()
ReactiveSocket	createSubscriber()

Methods inherited from class java.lang.Object

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

Method Detail

create

public static Reactor create(ContextConfiguration contextConfiguration)
                      throws InterruptedException

Throws:

InterruptedException

createSubscriber

public ReactiveSocket createSubscriber()
                                throws ExecutionException,
                                       InterruptedException

Throws:

ExecutionException

InterruptedException

createPublisher

public ReactiveSocket createPublisher()
                               throws ExecutionException,
                                      InterruptedException

Throws:

ExecutionException

InterruptedException

addShutdownListener

public Handle addShutdownListener(Runnable runnable)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface NotThrowingAutoCloseable