Package org.citrusframework.endpoint.direct

Class DirectSyncProducer

java.lang.Object
org.citrusframework.endpoint.direct.DirectProducer
org.citrusframework.endpoint.direct.DirectSyncProducer
All Implemented Interfaces:
org.citrusframework.messaging.Consumer, org.citrusframework.messaging.Producer, org.citrusframework.messaging.ReplyConsumer, org.citrusframework.messaging.SelectiveConsumer
public class DirectSyncProducer extends DirectProducer implements org.citrusframework.messaging.ReplyConsumer

  • Constructor Summary

    Constructors
    Constructor
    Description
    DirectSyncProducer(String name, DirectSyncEndpointConfiguration endpointConfiguration)
    Default constructor using endpoint configuration.

  • Method Summary

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

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

    getDestinationQueue, getDestinationQueueName, getName, resolveQueueName

    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

  • Constructor Details

    • DirectSyncProducer

      public DirectSyncProducer(String name, DirectSyncEndpointConfiguration 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
      Overrides:
      send in class DirectProducer

    • receive

      public org.citrusframework.message.Message receive(org.citrusframework.context.TestContext context)
      Specified by:
      receive in interface org.citrusframework.messaging.Consumer

    • receive

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

    • receive

      public org.citrusframework.message.Message receive(org.citrusframework.context.TestContext context, long timeout)
      Specified by:
      receive in interface org.citrusframework.messaging.Consumer

    • 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

    • getCorrelationManager

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

    • setCorrelationManager

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