Package com.mayam.wf.mq

Class MqDestination

java.lang.Object
com.mayam.wf.mq.MqDestination
public final class MqDestination extends Object
Message topic/queue.
Author:
Markus Mårtensson
See Also:

  • Method Details

    • url

      public String url()
      Returns:
      a "queue://" style destination URL used to access a topic or a queue.

    • of

      public static MqDestination of(@NotNull @NotNull String url)
      MqDestination factory.
      Parameters:
      url - destination url.
      Returns:
      matching MqDestination object.

    • parseQueryFromURI

      public static ValueList parseQueryFromURI(URI uri)

    • verifyConsumeUrl

      protected static MqDestination.ConsumerArguments verifyConsumeUrl(String url)
      For a none durable consumer, the following can be used (all are mandatory, binding_key can be repeated)
      consume://[exchangeName]?exchange_type=[fanout|direct|topic]invalid input: '&binding_key'=[key1]

      For a durable consumer, the following can be used (all are mandatory, binding_key can be repeated)
      consume://[exchangeName]?exchange_type=[fanout|direct|topic]invalid input: '&binding_key'=[key1]invalid input: '&queue'=[queueName]

      Please note that things needs to be encoded correctly. So binding_key with a hash needs to be %23

      Parameters:
      url -
      Returns:

    • safeString

      public String safeString()
      Returns:
      a string safe to use as a directory component.

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • equals

      public boolean equals(Object peer)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • getConsumerArguments

      public MqDestination.ConsumerArguments getConsumerArguments()

    • getProducerArguments

      public MqDestination.ProducerArguments getProducerArguments()