Package org.springframework.cloud.fn.supplier.zeromq

Class ZeroMqSupplierProperties

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

  • Constructor Details

    • ZeroMqSupplierProperties

      public ZeroMqSupplierProperties()

  • Method Details

    • 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 @org.hibernate.validator.constraints.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...)