Interface MessagingConfig

All Superinterfaces:
Prototype.Api, Prototype.Factory<MessagingGraph>
public sealed interface MessagingConfig extends Prototype.Api
Messaging configuration. Use each builder and its configuration to create one graph only. Do not reuse them after a build attempt, including a failed build. Configuration snapshots do not duplicate streams or channel connections.
See Also:

  • Method Details

    • builder

      static MessagingConfig.Builder builder()
      Create a new fluent API builder to customize configuration.
      Returns:
      a new builder

    • builder

      static MessagingConfig.Builder builder(MessagingConfig instance)
      Create a new fluent API builder from an existing instance.
      Parameters:
      instance - an existing instance used as a base for the builder
      Returns:
      a builder based on an instance

    • create

      static MessagingConfig create(Config config)
      Create a new instance from configuration.
      Parameters:
      config - used to configure the new instance
      Returns:
      a new instance configured from configuration

    • create

      static MessagingConfig create()
      Create a new instance with default values.
      Returns:
      a new instance

    • queueCapacity

      int queueCapacity()
      Maximum number of admitted deliveries waiting for execution. Zero disables buffering.
      Returns:
      queue capacity

    • maxPendingAdmissions

      int maxPendingAdmissions()
      Positive maximum number of waiting callers and open connector reservations.
      Returns:
      maximum pending admissions

    • maxPendingMessages

      int maxPendingMessages()
      Positive maximum number of messages retained by waiting callers and open connector reservations.
      Returns:
      maximum pending messages

    • maxInFlightMessages

      int maxInFlightMessages()
      Positive maximum number of admitted messages, including queued and executing deliveries.
      Returns:
      maximum in-flight messages

    • admissionTimeout

      Optional<Duration> admissionTimeout()
      Positive maximum capacity-wait time, representable in nanoseconds. Absence means no timeout.
      Returns:
      admission timeout

    • shutdownTimeout

      Duration shutdownTimeout()
      Positive global maximum shutdown and failed-startup rollback time, representable in nanoseconds. This does not bound startup or readiness and cannot be overridden by a channel.
      Returns:
      shutdown timeout

    • consumerRegistrations

      List<ConsumerRegistration> consumerRegistrations()
      Consumer and processor registrations contributing channel outputs.
      Returns:
      registrations

    • emitterRegistrations

      List<EmitterRegistration> emitterRegistrations()
      Emitter registrations contributing typed producer metadata.
      Returns:
      registrations

    • channelHandles

      List<MessagingChannel<?>> channelHandles()
      Programmatic channel handles.
      Returns:
      channel handles

    • incomingConnections

      Map<MessagingChannel<?>, IncomingChannel> incomingConnections()
      Programmatic incoming channel connections.
      Returns:
      incoming channel connections

    • connector

      List<MessagingConnector> connector()
      Configured messaging connectors.
      Returns:
      configured connectors

    • incoming

      Map<String, MessagingIncomingConfig> incoming()
      Incoming channel configurations, keyed by channel name, whose execution settings take precedence over outgoing configurations of the same logical channel.
      Returns:
      incoming channel configurations

    • outgoing

      Map<String, MessagingOutgoingConfig> outgoing()
      Outgoing channel configurations, keyed by channel name; their execution settings apply only when the logical channel has no incoming configuration.
      Returns:
      outgoing channel configurations