Package org.citrusframework.endpoint.direct

Class DirectSyncConsumer

java.lang.Object
org.citrusframework.messaging.AbstractMessageConsumer
org.citrusframework.messaging.AbstractSelectiveMessageConsumer
org.citrusframework.endpoint.direct.DirectConsumer
org.citrusframework.endpoint.direct.DirectSyncConsumer
All Implemented Interfaces:
org.citrusframework.messaging.Consumer, org.citrusframework.messaging.Producer, org.citrusframework.messaging.ReplyProducer, org.citrusframework.messaging.SelectiveConsumer
public class DirectSyncConsumer extends DirectConsumer implements org.citrusframework.messaging.ReplyProducer

  • Constructor Summary

    Constructors
    Constructor
    Description
    DirectSyncConsumer(String name, DirectSyncEndpointConfiguration endpointConfiguration)
    Default constructor using emdpoint configuration.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.citrusframework.message.correlation.CorrelationManager<org.citrusframework.message.MessageQueue>
    getCorrelationManager()
    Gets the correlation manager.
    org.citrusframework.message.Message
    receive(String selector, org.citrusframework.context.TestContext context, long timeout)
     
    void
    saveReplyMessageQueue(org.citrusframework.message.Message receivedMessage, org.citrusframework.context.TestContext context)
    Store reply message channel.
    void
    send(org.citrusframework.message.Message message, org.citrusframework.context.TestContext context)
     
    void
    setCorrelationManager(org.citrusframework.message.correlation.CorrelationManager<org.citrusframework.message.MessageQueue> correlationManager)
    Sets the correlation manager.

    Methods inherited from class org.citrusframework.endpoint.direct.DirectConsumer

    getDestinationQueue, getDestinationQueueName, resolveQueueName

    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

    Methods inherited from interface org.citrusframework.messaging.Producer

    getName

  • Constructor Details

    • DirectSyncConsumer

      public DirectSyncConsumer(String name, DirectSyncEndpointConfiguration endpointConfiguration)
      Default constructor using emdpoint configuration.
      Parameters:
      name -
      endpointConfiguration -

  • Method Details

    • receive

      public org.citrusframework.message.Message receive(String selector, org.citrusframework.context.TestContext context, long timeout)
      Specified by:
      receive in interface org.citrusframework.messaging.SelectiveConsumer
      Overrides:
      receive in class DirectConsumer

    • send

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

    • saveReplyMessageQueue

      public void saveReplyMessageQueue(org.citrusframework.message.Message receivedMessage, org.citrusframework.context.TestContext context)
      Store reply message channel.
      Parameters:
      receivedMessage -
      context -

    • getCorrelationManager

      public org.citrusframework.message.correlation.CorrelationManager<org.citrusframework.message.MessageQueue> getCorrelationManager()
      Gets the correlation manager.
      Returns:

    • setCorrelationManager

      public void setCorrelationManager(org.citrusframework.message.correlation.CorrelationManager<org.citrusframework.message.MessageQueue> correlationManager)
      Sets the correlation manager.
      Parameters:
      correlationManager -