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, Alessio Matricardi

  • 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, int port)
      Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext and binding port.
      Parameters:
      context - the ZContext to use.
      port - the port to bind ZeroMq socket to over TCP.
      Returns:
      the spec.
      Since:
      6.4

    • 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)
      Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext. The created socket will be bound to a random port.
      Parameters:
      context - the ZContext to use.
      Returns:
      the spec.
      Since:
      6.4

    • outboundChannelAdapter

      public static ZeroMqMessageHandlerSpec outboundChannelAdapter(org.zeromq.ZContext context, org.zeromq.SocketType socketType)
      Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext and SocketType. The created socket will be bound to a random port.
      Parameters:
      context - the ZContext to use.
      socketType - the SocketType for ZeroMq socket.
      Returns:
      the spec.
      Since:
      6.4

    • outboundChannelAdapter

      public static ZeroMqMessageHandlerSpec outboundChannelAdapter(org.zeromq.ZContext context, int port, org.zeromq.SocketType socketType)
      Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext, binding port and SocketType.
      Parameters:
      context - the ZContext to use.
      port - the port to bind ZeroMq socket to over TCP.
      socketType - the SocketType for ZeroMq socket.
      Returns:
      the spec.
      Since:
      6.4

    • 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.