org.zeromq.jzmq.sockets

Class SubSocketBuilder

java.lang.Object

org.zeromq.jzmq.sockets.SocketBuilder

org.zeromq.jzmq.sockets.SubSocketBuilder

All Implemented Interfaces:

Bindable, Connectable, Subscribable

public class SubSocketBuilder
extends SocketBuilder
implements Subscribable

Nested Class Summary

Nested classes/interfaces inherited from class org.zeromq.jzmq.sockets.SocketBuilder

SocketBuilder.SocketSpec

Field Summary

Fields inherited from class org.zeromq.jzmq.sockets.SocketBuilder

context, socketSpec

Constructor Summary

Constructors

Constructor and Description
SubSocketBuilder(ManagedContext context)

Method Summary

Modifier and Type	Method and Description
Socket	bind(String url, String... additionalUrls) Bind to a url.
Socket	connect(String url, String... additionalUrls) Connect to a url.
SubSocketBuilder	subscribe(byte[] data) Subscribe to the given channel.
SubSocketBuilder	subscribeAll() Subscribe to all messages.

Methods inherited from class org.zeromq.jzmq.sockets.SocketBuilder

asRoutable, asSubscribable, bind, bind, connect, connect, createBindableSocketWithStandardSettings, createConnectableSocketWithStandardSettings, getIdentity, getLinger, getReceiveHighWaterMark, getSendHighWaterMark, getSocketSpec, getSocketType, getSwap, newManagedSocket, withBackgroundable, withIdentity, withLinger, withLinger, withReceiveHighWatermark, withReceiveHighWatermark, withReceiveTimeout, withSendHighWatermark, withSendHighWatermark, withSendTimeout, withSwap

Methods inherited from class java.lang.Object

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

Constructor Detail

SubSocketBuilder

public SubSocketBuilder(ManagedContext context)

Method Detail

subscribe

public SubSocketBuilder subscribe(byte[] data)

Description copied from interface: Subscribable

Subscribe to the given channel.

Specified by:

subscribe in interface Subscribable

Parameters:

data - The channel prefix, as bytes

Returns:

This builder object

subscribeAll

public SubSocketBuilder subscribeAll()

Description copied from interface: Subscribable

Subscribe to all messages.

Specified by:

subscribeAll in interface Subscribable

Returns:

This builder object

connect

public Socket connect(String url,
                      String... additionalUrls)

Description copied from interface: Connectable

Connect to a url.

Specified by:

connect in interface Connectable

Overrides:

connect in class SocketBuilder

Parameters:

url - the url to connect to

additionalUrls - additional urls to connect to

Returns:

the socket

bind

public Socket bind(String url,
                   String... additionalUrls)

Description copied from interface: Bindable

Bind to a url.

Specified by:

bind in interface Bindable

Overrides:

bind in class SocketBuilder

Parameters:

url - the url to bind to

additionalUrls - additional urls to bind to

Returns:

the socket