Package org.springframework.cloud.fn.consumer.zeromq

Class ZeroMqConsumerProperties

java.lang.Object
org.springframework.cloud.fn.consumer.zeromq.ZeroMqConsumerProperties
@ConfigurationProperties("zeromq.consumer") @Validated public class ZeroMqConsumerProperties extends Object
Since:
3.1.0
Author:
Daniel Frey

  • Constructor Details

    • ZeroMqConsumerProperties

      public ZeroMqConsumerProperties()

  • Method Details

    • getSocketType

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

    • setSocketType

      public void setSocketType(org.zeromq.SocketType socketType)
      Parameters:
      socketType - the SocketType to establish.

    • getConnectUrl

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

    • setConnectUrl

      public void setConnectUrl(String connectUrl)
      Parameters:
      connectUrl - The ZeroMQ socket to expose

    • getTopic

      public Expression getTopic()

    • setTopic

      public void setTopic(Expression topic)
      Parameters:
      topic - The 'topic' SpEL expression to set