com.datasift.dropwizard.zeromq.socket

Class ZeroMQSubSocketFactory

java.lang.Object

com.datasift.dropwizard.zeromq.socket.BaseZeroMQSocketFactory

com.datasift.dropwizard.zeromq.socket.ZeroMQSubSocketFactory

All Implemented Interfaces:

ZeroMQSocketFactory

public class ZeroMQSubSocketFactory
extends BaseZeroMQSocketFactory

A factory for a ZeroMQ SUB socket.

See Also:

ZeroMQSocketFactory

Constructor Summary

Constructors

Constructor and Description
ZeroMQSubSocketFactory()

Method Summary

Modifier and Type	Method and Description
org.zeromq.ZMQ.Socket	build(org.zeromq.ZContext context)
List<String>	getTopics()
void	setTopics(List<String> topics)

Methods inherited from class com.datasift.dropwizard.zeromq.socket.BaseZeroMQSocketFactory

bind, bind, bind, build, build, configure, connect, connect, connect, getAffinity, getBacklog, getEndpoints, getHighWaterMark, getIdentity, getInitialReconnectInterval, getLinger, getMaxMessageSize, getMaxMulticastRate, getMaxReconnectInterval, getMulticastHops, getMulticastRecoveryInterval, getReceiveBufferSize, getReceiveHighWaterMark, getReceiveTimeout, getSendBufferSize, getSendHighWaterMark, getSendTimeout, getTcpKeepAlive, getTcpKeepAliveCount, getTcpKeepAliveIdle, getTcpKeepAliveInterval, isDelayAttachOnConnect, isIpv4Only, setAffinity, setBacklog, setDelayAttachOnConnect, setEndpoints, setHighWaterMark, setIdentity, setInitialReconnectInterval, setIpv4Only, setLinger, setMaxMessageSize, setMaxMulticastRate, setMaxReconnectInterval, setMulticastHops, setMulticastRecoveryInterval, setReceiveBufferSize, setReceiveHighWaterMark, setReceiveTimeout, setSendBufferSize, setSendHighWaterMark, setSendTimeout, setTcpKeepAlive, setTcpKeepAliveCount, setTcpKeepAliveIdle, setTcpKeepAliveInterval

Methods inherited from class java.lang.Object

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

Constructor Detail

ZeroMQSubSocketFactory

public ZeroMQSubSocketFactory()

Method Detail

getTopics

public List<String> getTopics()

setTopics

public void setTopics(List<String> topics)

build

public org.zeromq.ZMQ.Socket build(org.zeromq.ZContext context)