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. This works with AMQP server that implements 0-9-1 version of the specification.

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.


© 2000-2011 Flux Corporation. All rights reserved.