Package org.mule.tests.internal

Class QueueOperations

java.lang.Object

org.mule.tests.internal.QueueOperations

public class QueueOperations
extends Object

This class is a container for operations, every public method in this class will be taken as an extension operation.

Constructor Summary

Constructors

Constructor	Description
QueueOperations()

Method Summary

Modifier and Type	Method	Description
void	queuePush(QueueConfiguration configuration, TestQueue queue, org.mule.runtime.api.metadata.TypedValue<Object> content, org.mule.runtime.api.metadata.TypedValue<Object> msg, boolean consumeStream)	A stores received events in a in-memory queue.

Methods inherited from class java.lang.Object

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

Constructor Details

QueueOperations

public QueueOperations()

Method Details

queuePush

@MediaType(value="*/*",
           strict=false)
public void queuePush(@Config
 QueueConfiguration configuration,
 @Connection
 TestQueue queue,
 @Content(primary=true) @Optional(defaultValue="#[payload]")
 org.mule.runtime.api.metadata.TypedValue<Object> content,
 @Optional(defaultValue="#[message]")
 org.mule.runtime.api.metadata.TypedValue<Object> msg,
 @Optional(defaultValue="false")
 boolean consumeStream)
               throws InterruptedException

A stores received events in a in-memory queue. Events can be consumed using mule client requests.

Parameters:

content - Content to be sent to the queue. By default it will be the payload content.

Throws:

InterruptedException