Package org.springframework.integration.zeromq.dsl

Class ZeroMq

java.lang.Object
org.springframework.integration.zeromq.dsl.ZeroMq
public final class ZeroMq extends Object
Factory class for ZeroMq components DSL.
Since:
5.4
Author:
Artem Bilan

  • Method Details

    • zeroMqChannel

      public static ZeroMqChannelSpec zeroMqChannel(org.zeromq.ZContext context)
      Create an instance of ZeroMqChannelSpec based on the provided ZContext.
      Parameters:
      context - the ZContext to use.
      Returns:
      the spec.

    • pubSubZeroMqChannel

      public static ZeroMqChannelSpec pubSubZeroMqChannel(org.zeromq.ZContext context)
      Create an instance of ZeroMqChannelSpec in pub/sub mode based on the provided ZContext.
      Parameters:
      context - the ZContext to use.
      Returns:
      the spec.

    • outboundChannelAdapter

      public static ZeroMqMessageHandlerSpec outboundChannelAdapter(org.zeromq.ZContext context, String connectUrl)
      Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext and connection URL.
      Parameters:
      context - the ZContext to use.
      connectUrl - the URL to connect a ZeroMq socket to.
      Returns:
      the spec.

    • outboundChannelAdapter

      public static ZeroMqMessageHandlerSpec outboundChannelAdapter(org.zeromq.ZContext context, Supplier<String> connectUrl)
      Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext and connection URL supplier.
      Parameters:
      context - the ZContext to use.
      connectUrl - the supplier for URL to connect a ZeroMq socket to.
      Returns:
      the spec.
      Since:
      5.5.9

    • outboundChannelAdapter

      public static ZeroMqMessageHandlerSpec outboundChannelAdapter(org.zeromq.ZContext context, String connectUrl, org.zeromq.SocketType socketType)
      Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext, connection URL and SocketType.
      Parameters:
      context - the ZContext to use.
      connectUrl - the URL to connect a ZeroMq socket to.
      socketType - the SocketType for ZeroMq socket.
      Returns:
      the spec.

    • outboundChannelAdapter

      public static ZeroMqMessageHandlerSpec outboundChannelAdapter(org.zeromq.ZContext context, Supplier<String> connectUrl, org.zeromq.SocketType socketType)
      Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext, connection URL supplier and SocketType.
      Parameters:
      context - the ZContext to use.
      connectUrl - the supplier for URL to connect a ZeroMq socket to.
      socketType - the SocketType for ZeroMq socket.
      Returns:
      the spec.
      Since:
      5.5.9

    • inboundChannelAdapter

      public static ZeroMqMessageProducerSpec inboundChannelAdapter(org.zeromq.ZContext context)
      Create an instance of ZeroMqMessageProducerSpec for the provided ZContext.
      Parameters:
      context - the ZContext to use.
      Returns:
      the spec.

    • inboundChannelAdapter

      public static ZeroMqMessageProducerSpec inboundChannelAdapter(org.zeromq.ZContext context, org.zeromq.SocketType socketType)
      Create an instance of ZeroMqMessageProducerSpec for the provided ZContext and SocketType.
      Parameters:
      context - the ZContext to use.
      socketType - the SocketType for ZeroMq socket.
      Returns:
      the spec.