Package org.citrusframework.endpoint.direct

Class DirectConsumer

java.lang.Object
org.citrusframework.messaging.AbstractMessageConsumer
org.citrusframework.messaging.AbstractSelectiveMessageConsumer
org.citrusframework.endpoint.direct.DirectConsumer
All Implemented Interfaces:
org.citrusframework.messaging.Consumer, org.citrusframework.messaging.SelectiveConsumer
Direct Known Subclasses:
DirectSyncConsumer
public class DirectConsumer extends org.citrusframework.messaging.AbstractSelectiveMessageConsumer

  • Constructor Summary

    Constructors
    Constructor
    Description
    DirectConsumer(String name, DirectEndpointConfiguration endpointConfiguration)
    Default constructor using endpoint configuration.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected org.citrusframework.message.MessageQueue
    getDestinationQueue(org.citrusframework.context.TestContext context)
    Get the destination queue depending on settings in this message sender.
    protected String
    getDestinationQueueName()
    Gets the queue name depending on what is set in this message sender.
    org.citrusframework.message.Message
    receive(String selector, org.citrusframework.context.TestContext context, long timeout)
     
    protected org.citrusframework.message.MessageQueue
    resolveQueueName(String queueName, org.citrusframework.context.TestContext context)
    Resolve the queue by name.

    Methods inherited from class org.citrusframework.messaging.AbstractSelectiveMessageConsumer

    receive, receive

    Methods inherited from class org.citrusframework.messaging.AbstractMessageConsumer

    getEndpointConfiguration, getName, receive

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.citrusframework.messaging.Consumer

    getName, receive

  • Constructor Details

    • DirectConsumer

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

  • Method Details

    • receive

      public org.citrusframework.message.Message receive(String selector, org.citrusframework.context.TestContext context, long timeout)

    • 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 - the test 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 -
      Returns:
      the MessageQueue object