com.datasift.dropwizard.zeromq.socket

Class BaseZeroMQSocketFactory

java.lang.Object

com.datasift.dropwizard.zeromq.socket.BaseZeroMQSocketFactory

All Implemented Interfaces:

ZeroMQSocketFactory

Direct Known Subclasses:

ZeroMQDealerSocketFactory, ZeroMQPubSocketFactory, ZeroMQPullSocketFactory, ZeroMQPushSocketFactory, ZeroMQRepSocketFactory, ZeroMQReqSocketFactory, ZeroMQRouterSocketFactory, ZeroMQSubSocketFactory

public abstract class BaseZeroMQSocketFactory
extends Object
implements ZeroMQSocketFactory

A factory for a ZeroMQ Socket.

Constructor Summary

Constructors

Constructor and Description
BaseZeroMQSocketFactory()

Method Summary

Modifier and Type	Method and Description
org.zeromq.ZMQ.Socket	bind(org.zeromq.ZContext context)
org.zeromq.ZMQ.Socket	bind(org.zeromq.ZContext context, io.dropwizard.setup.Environment environment)
protected org.zeromq.ZMQ.Socket	bind(org.zeromq.ZMQ.Socket socket)
org.zeromq.ZMQ.Socket	build(org.zeromq.ZContext context, io.dropwizard.setup.Environment environment)
protected org.zeromq.ZMQ.Socket	build(org.zeromq.ZContext context, int type)
protected org.zeromq.ZMQ.Socket	configure(org.zeromq.ZMQ.Socket socket)
org.zeromq.ZMQ.Socket	connect(org.zeromq.ZContext context)
org.zeromq.ZMQ.Socket	connect(org.zeromq.ZContext context, io.dropwizard.setup.Environment environment)
protected org.zeromq.ZMQ.Socket	connect(org.zeromq.ZMQ.Socket socket)
long	getAffinity()
long	getBacklog()
Set<URI>	getEndpoints()
long	getHighWaterMark()
com.google.common.base.Optional<String>	getIdentity()
com.google.common.base.Optional<io.dropwizard.util.Duration>	getInitialReconnectInterval()
long	getLinger()
com.google.common.base.Optional<io.dropwizard.util.Size>	getMaxMessageSize()
long	getMaxMulticastRate()
com.google.common.base.Optional<io.dropwizard.util.Duration>	getMaxReconnectInterval()
long	getMulticastHops()
io.dropwizard.util.Duration	getMulticastRecoveryInterval()
com.google.common.base.Optional<io.dropwizard.util.Size>	getReceiveBufferSize()
long	getReceiveHighWaterMark()
com.google.common.base.Optional<io.dropwizard.util.Duration>	getReceiveTimeout()
com.google.common.base.Optional<io.dropwizard.util.Size>	getSendBufferSize()
long	getSendHighWaterMark()
com.google.common.base.Optional<io.dropwizard.util.Duration>	getSendTimeout()
com.google.common.base.Optional<Boolean>	getTcpKeepAlive()
com.google.common.base.Optional<Long>	getTcpKeepAliveCount()
com.google.common.base.Optional<Long>	getTcpKeepAliveIdle()
com.google.common.base.Optional<Long>	getTcpKeepAliveInterval()
boolean	isDelayAttachOnConnect()
boolean	isIpv4Only()
void	setAffinity(long affinity)
void	setBacklog(long backlog)
void	setDelayAttachOnConnect(boolean delayAttachOnConnect)
void	setEndpoints(Set<URI> endpoints)
void	setHighWaterMark(long highWaterMark)
void	setIdentity(com.google.common.base.Optional<String> identity)
void	setInitialReconnectInterval(com.google.common.base.Optional<io.dropwizard.util.Duration> initialReconnectInterval)
void	setIpv4Only(boolean ipv4Only)
void	setLinger(long linger)
void	setMaxMessageSize(com.google.common.base.Optional<io.dropwizard.util.Size> maxMessageSize)
void	setMaxMulticastRate(long maxMulticastRate)
void	setMaxReconnectInterval(com.google.common.base.Optional<io.dropwizard.util.Duration> maxReconnectInterval)
void	setMulticastHops(long multicastHops)
void	setMulticastRecoveryInterval(io.dropwizard.util.Duration multicastRecoveryInterval)
void	setReceiveBufferSize(com.google.common.base.Optional<io.dropwizard.util.Size> receiveBufferSize)
void	setReceiveHighWaterMark(long receiveHighWaterMark)
void	setReceiveTimeout(com.google.common.base.Optional<io.dropwizard.util.Duration> receiveTimeout)
void	setSendBufferSize(com.google.common.base.Optional<io.dropwizard.util.Size> sendBufferSize)
void	setSendHighWaterMark(long sendHighWaterMark)
void	setSendTimeout(com.google.common.base.Optional<io.dropwizard.util.Duration> sendTimeout)
void	setTcpKeepAlive(com.google.common.base.Optional<Boolean> tcpKeepAlive)
void	setTcpKeepAliveCount(com.google.common.base.Optional<Long> tcpKeepAliveCount)
void	setTcpKeepAliveIdle(com.google.common.base.Optional<Long> tcpKeepAliveIdle)
void	setTcpKeepAliveInterval(com.google.common.base.Optional<Long> tcpKeepAliveInterval)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.datasift.dropwizard.zeromq.socket.ZeroMQSocketFactory

build

Constructor Detail

BaseZeroMQSocketFactory

public BaseZeroMQSocketFactory()

Method Detail

getEndpoints

public Set<URI> getEndpoints()

setEndpoints

public void setEndpoints(Set<URI> endpoints)

getAffinity

public long getAffinity()

setAffinity

public void setAffinity(long affinity)

getBacklog

public long getBacklog()

setBacklog

public void setBacklog(long backlog)

isDelayAttachOnConnect

public boolean isDelayAttachOnConnect()

setDelayAttachOnConnect

public void setDelayAttachOnConnect(boolean delayAttachOnConnect)

getHighWaterMark

public long getHighWaterMark()

setHighWaterMark

public void setHighWaterMark(long highWaterMark)

getReceiveHighWaterMark

public long getReceiveHighWaterMark()

setReceiveHighWaterMark

public void setReceiveHighWaterMark(long receiveHighWaterMark)

getSendHighWaterMark

public long getSendHighWaterMark()

setSendHighWaterMark

public void setSendHighWaterMark(long sendHighWaterMark)

getIdentity

public com.google.common.base.Optional<String> getIdentity()

setIdentity

public void setIdentity(com.google.common.base.Optional<String> identity)

isIpv4Only

public boolean isIpv4Only()

setIpv4Only

public void setIpv4Only(boolean ipv4Only)

getLinger

public long getLinger()

setLinger

public void setLinger(long linger)

getMaxMessageSize

public com.google.common.base.Optional<io.dropwizard.util.Size> getMaxMessageSize()

setMaxMessageSize

public void setMaxMessageSize(com.google.common.base.Optional<io.dropwizard.util.Size> maxMessageSize)

getMulticastHops

public long getMulticastHops()

setMulticastHops

public void setMulticastHops(long multicastHops)

getMulticastRecoveryInterval

public io.dropwizard.util.Duration getMulticastRecoveryInterval()

setMulticastRecoveryInterval

public void setMulticastRecoveryInterval(io.dropwizard.util.Duration multicastRecoveryInterval)

getMaxMulticastRate

public long getMaxMulticastRate()

setMaxMulticastRate

public void setMaxMulticastRate(long maxMulticastRate)

getReceiveBufferSize

public com.google.common.base.Optional<io.dropwizard.util.Size> getReceiveBufferSize()

setReceiveBufferSize

public void setReceiveBufferSize(com.google.common.base.Optional<io.dropwizard.util.Size> receiveBufferSize)

getSendBufferSize

public com.google.common.base.Optional<io.dropwizard.util.Size> getSendBufferSize()

setSendBufferSize

public void setSendBufferSize(com.google.common.base.Optional<io.dropwizard.util.Size> sendBufferSize)

getReceiveTimeout

public com.google.common.base.Optional<io.dropwizard.util.Duration> getReceiveTimeout()

setReceiveTimeout

public void setReceiveTimeout(com.google.common.base.Optional<io.dropwizard.util.Duration> receiveTimeout)

getSendTimeout

public com.google.common.base.Optional<io.dropwizard.util.Duration> getSendTimeout()

setSendTimeout

public void setSendTimeout(com.google.common.base.Optional<io.dropwizard.util.Duration> sendTimeout)

getInitialReconnectInterval

public com.google.common.base.Optional<io.dropwizard.util.Duration> getInitialReconnectInterval()

setInitialReconnectInterval

public void setInitialReconnectInterval(com.google.common.base.Optional<io.dropwizard.util.Duration> initialReconnectInterval)

getMaxReconnectInterval

public com.google.common.base.Optional<io.dropwizard.util.Duration> getMaxReconnectInterval()

setMaxReconnectInterval

public void setMaxReconnectInterval(com.google.common.base.Optional<io.dropwizard.util.Duration> maxReconnectInterval)

getTcpKeepAlive

public com.google.common.base.Optional<Boolean> getTcpKeepAlive()

setTcpKeepAlive

public void setTcpKeepAlive(com.google.common.base.Optional<Boolean> tcpKeepAlive)

getTcpKeepAliveCount

public com.google.common.base.Optional<Long> getTcpKeepAliveCount()

setTcpKeepAliveCount

public void setTcpKeepAliveCount(com.google.common.base.Optional<Long> tcpKeepAliveCount)

getTcpKeepAliveIdle

public com.google.common.base.Optional<Long> getTcpKeepAliveIdle()

setTcpKeepAliveIdle

public void setTcpKeepAliveIdle(com.google.common.base.Optional<Long> tcpKeepAliveIdle)

getTcpKeepAliveInterval

public com.google.common.base.Optional<Long> getTcpKeepAliveInterval()

setTcpKeepAliveInterval

public void setTcpKeepAliveInterval(com.google.common.base.Optional<Long> tcpKeepAliveInterval)

build

public org.zeromq.ZMQ.Socket build(org.zeromq.ZContext context,
                                   io.dropwizard.setup.Environment environment)

Specified by:

build in interface ZeroMQSocketFactory

connect

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

Specified by:

connect in interface ZeroMQSocketFactory

connect

public org.zeromq.ZMQ.Socket connect(org.zeromq.ZContext context,
                                     io.dropwizard.setup.Environment environment)

Specified by:

connect in interface ZeroMQSocketFactory

bind

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

Specified by:

bind in interface ZeroMQSocketFactory

bind

public org.zeromq.ZMQ.Socket bind(org.zeromq.ZContext context,
                                  io.dropwizard.setup.Environment environment)

Specified by:

bind in interface ZeroMQSocketFactory

build

protected org.zeromq.ZMQ.Socket build(org.zeromq.ZContext context,
                                      int type)

connect

protected org.zeromq.ZMQ.Socket connect(org.zeromq.ZMQ.Socket socket)

bind

protected org.zeromq.ZMQ.Socket bind(org.zeromq.ZMQ.Socket socket)

configure

protected org.zeromq.ZMQ.Socket configure(org.zeromq.ZMQ.Socket socket)