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

Class PubSubSocketPair

java.lang.Object

de.unistuttgart.isw.sfsc.commonjava.zmq.pubsubsocketpair.PubSubSocketPair

All Implemented Interfaces:

NotThrowingAutoCloseable, AutoCloseable

public class PubSubSocketPair
extends Object
implements NotThrowingAutoCloseable

Method Summary

Modifier and Type	Method	Description
void	close()
static PubSubSocketPair	create(Reactor reactor)
ReactiveSocket.Inbox	dataInbox()
ReactiveSocket.Outbox	dataOutbox()
ReactiveSocket.Settings	publisherSettings()
ReactiveSocket.Connector	publisherSocketConnector()
ReactiveSocket.Settings	subscriberSettings()
ReactiveSocket.Connector	subscriberSocketConnector()
ReactiveSocket.Inbox	subscriptionInbox()
ReactiveSocket.Outbox	subscriptionOutbox()

Methods inherited from class java.lang.Object

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

Method Detail

create

public static PubSubSocketPair create(Reactor reactor)
                               throws ExecutionException,
                                      InterruptedException

Throws:

ExecutionException

InterruptedException

dataOutbox

public ReactiveSocket.Outbox dataOutbox()

dataInbox

public ReactiveSocket.Inbox dataInbox()

subscriptionOutbox

public ReactiveSocket.Outbox subscriptionOutbox()

subscriptionInbox

public ReactiveSocket.Inbox subscriptionInbox()

publisherSocketConnector

public ReactiveSocket.Connector publisherSocketConnector()

subscriberSocketConnector

public ReactiveSocket.Connector subscriberSocketConnector()

publisherSettings

public ReactiveSocket.Settings publisherSettings()

subscriberSettings

public ReactiveSocket.Settings subscriberSettings()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface NotThrowingAutoCloseable