@ConfigurationProperties(value="zeromq.consumer") @Validated public class ZeroMqConsumerProperties extends Object
Constructor and Description |
---|
ZeroMqConsumerProperties() |
Modifier and Type | Method and Description |
---|---|
@NotEmpty(message="connectUrl is required like protocol://server:port") String |
getConnectUrl() |
@NotNull(message="\'socketType\' is required") org.zeromq.SocketType |
getSocketType() |
org.springframework.expression.Expression |
getTopic() |
void |
setConnectUrl(String connectUrl) |
void |
setSocketType(org.zeromq.SocketType socketType) |
void |
setTopic(org.springframework.expression.Expression topic) |
@NotNull(message="\'socketType\' is required") public @NotNull(message="\'socketType\' is required") org.zeromq.SocketType getSocketType()
public void setSocketType(org.zeromq.SocketType socketType)
socketType
- the SocketType
to establish.@NotEmpty(message="connectUrl is required like protocol://server:port") public @NotEmpty(message="connectUrl is required like protocol://server:port") String getConnectUrl()
public void setConnectUrl(String connectUrl)
connectUrl
- The ZeroMQ socket to exposepublic org.springframework.expression.Expression getTopic()
public void setTopic(org.springframework.expression.Expression topic)
topic
- The 'topic' SpEL expression to setCopyright © 2022. All rights reserved.