org.springframework.cloud.fn.supplier.zeromq

Class ZeroMqSupplierProperties

java.lang.Object

org.springframework.cloud.fn.supplier.zeromq.ZeroMqSupplierProperties

@ConfigurationProperties(value="zeromq.supplier")
 @Validated
public class ZeroMqSupplierProperties
extends Object

Since:

3.1.0

Author:

Daniel Frey

Constructor Summary

Constructors

Constructor and Description
ZeroMqSupplierProperties()

Method Summary

Modifier and Type	Method and Description
@Range(min=0L,message="\'bindPort\' must not be negative") int	getBindPort()
@NotEmpty(message="connectUrl is required like tcp://server:port") String	getConnectUrl()
@NotNull(message="\'consumeDelay\' is required") Duration	getConsumeDelay()
@NotNull(message="\'socketType\' is required") org.zeromq.SocketType	getSocketType()
String[]	getTopics()
void	setBindPort(int bindPort)
void	setConnectUrl(String connectUrl)
void	setConsumeDelay(Duration consumeDelay) Specify a Duration to delay consumption when no data received.
void	setSocketType(org.zeromq.SocketType socketType)
void	setTopics(String... topics)

Methods inherited from class java.lang.Object

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

Constructor Detail

ZeroMqSupplierProperties

public ZeroMqSupplierProperties()

Method Detail

setSocketType

public void setSocketType(org.zeromq.SocketType socketType)

Parameters:

socketType - the SocketType to establish.

getSocketType

@NotNull(message="\'socketType\' is required")
public @NotNull(message="\'socketType\' is required") org.zeromq.SocketType getSocketType()

getConnectUrl

@NotEmpty(message="connectUrl is required like tcp://server:port")
public @NotEmpty(message="connectUrl is required like tcp://server:port") String getConnectUrl()

setConnectUrl

public void setConnectUrl(String connectUrl)

Parameters:

connectUrl - The ZeroMQ server connect url

See Also:

ZeroMqMessageProducer.setConnectUrl(String)

getBindPort

@Range(min=0L,
       message="\'bindPort\' must not be negative")
public @Range(min=0L,message="\'bindPort\' must not be negative") int getBindPort()

setBindPort

public void setBindPort(int bindPort)

Parameters:

bindPort - The Port to bind to on all interfaces

See Also:

ZeroMqMessageProducer.setBindPort(int)

getConsumeDelay

@NotNull(message="\'consumeDelay\' is required")
public @NotNull(message="\'consumeDelay\' is required") Duration getConsumeDelay()

setConsumeDelay

public void setConsumeDelay(Duration consumeDelay)

Specify a Duration to delay consumption when no data received.

Parameters:

consumeDelay - the Duration to delay consumption when empty.

getTopics

public String[] getTopics()

setTopics

public void setTopics(String... topics)

Parameters:

topics - The ZeroMQ Topics to subscribe to

See Also:

ZeroMqMessageProducer.setTopics(String...)