flux
Interface RabbitMQAction

All Superinterfaces:

flux.Action, Cloneable, RabbitMQ, flux.runtimedatamap.RuntimeDataMap, Serializable

public interface RabbitMQAction
extends RabbitMQ, flux.Action

RabbitMQAction that publishes messages to RabbitMQ queues.

Author:

arul@fluxcorp.com

Method Summary

void	setExchangeName(String exchangeName) RabbitMQ exchange name.
void	setExchangeType(String exchangeType) RabbitMQ exchange type: DIRECT, FANOUT, TOPIC, HEADERS.
void	setMessage(String message) Sets the message to be published to the queue.
void	setQueueType(String queueType) Sets the queue type: EXCLUSIVE, SHARED.
void	setRoutingKey(String routingKey) Sets the routing key.

Methods inherited from interface flux.RabbitMQ

setHost, setPassword, setPort, setQueueName, setUsername, setVirtualHost

Methods inherited from interface flux.Action

addFlow, addFlow, addSignalFlow, clone, execute, getDescription, getFlows, getHiddenVariableNames, getJoinExpression, getName, getPostscript, getPostscriptLanguage, getPrescript, getPrescriptLanguage, getResultInfo, getSignalsToMonitor, getTimeoutBusinessInterval, getTimeoutExpression, getVariableManager, isEndOfRun, isJoinPoint, isSkippable, isStartAction, isStartOfRun, isTransactionBreak, removeFlow, reset, setDescription, setElseFlow, setEndOfRun, setErrorFlow, setErrorFlowWithoutRollback, setErrorFlowWithRollback, setJoinExpression, setJoinPoint, setName, setPostscript, setPostscriptLanguage, setPrescript, setPrescriptLanguage, setSignalsToMonitor, setSkippable, setStartAction, setStartOfRun, setTimeoutBusinessInterval, setTimeoutExpression, setTimeoutFlow, setTransactionBreak, verify, verifyOnClient

Methods inherited from interface flux.runtimedatamap.RuntimeDataMap

getRuntimeDataMap, setRuntimeDataMap

Method Detail

setExchangeName

void setExchangeName(String exchangeName)

RabbitMQ exchange name.

Parameters:

exchangeName - exchange name.

setExchangeType

void setExchangeType(String exchangeType)

RabbitMQ exchange type: DIRECT, FANOUT, TOPIC, HEADERS. Default is DIRECT.

Parameters:

exchangeType - exchange type.

setQueueType

void setQueueType(String queueType)

Sets the queue type: EXCLUSIVE, SHARED. Default is SHARED. Queues are durable.

Parameters:

queueType - queue type.

setRoutingKey

void setRoutingKey(String routingKey)

Sets the routing key.

Parameters:

routingKey - routing key.

setMessage

void setMessage(String message)

Sets the message to be published to the queue.

Parameters:

message - message.