Package org.citrusframework.endpoint.direct

Class DirectProducer

java.lang.Object
org.citrusframework.endpoint.direct.DirectProducer
All Implemented Interfaces:
org.citrusframework.messaging.Producer
Direct Known Subclasses:
DirectSyncProducer
public class DirectProducer extends Object implements org.citrusframework.messaging.Producer

  • Constructor Details

    • DirectProducer

      public DirectProducer(String name, DirectEndpointConfiguration endpointConfiguration)
      Default constructor using endpoint configuration.
      Parameters:
      name -
      endpointConfiguration -

  • Method Details

    • send

      public void send(org.citrusframework.message.Message message, org.citrusframework.context.TestContext context)
      Specified by:
      send in interface org.citrusframework.messaging.Producer

    • getDestinationQueue

      protected org.citrusframework.message.MessageQueue getDestinationQueue(org.citrusframework.context.TestContext context)
      Get the destination queue depending on settings in this message sender. Either a direct queue object is set or a queue name which will be resolved to a queue.
      Parameters:
      context -
      Returns:
      the destination queue object.

    • getDestinationQueueName

      protected String getDestinationQueueName()
      Gets the queue name depending on what is set in this message sender. Either queue name is set directly or queue object is consulted for queue name.
      Returns:
      the queue name.

    • resolveQueueName

      protected org.citrusframework.message.MessageQueue resolveQueueName(String queueName, org.citrusframework.context.TestContext context)
      Resolve the queue by name.
      Parameters:
      queueName - the name to resolve
      context - the test context
      Returns:
      the MessageQueue object

    • getName

      public String getName()
      Specified by:
      getName in interface org.citrusframework.messaging.Producer