flux
Interface RabbitMQTrigger

All Superinterfaces:
flux.Action, Cloneable, RabbitMQ, flux.runtimedatamap.RuntimeDataMap, Serializable, flux.Trigger

public interface RabbitMQTrigger
extends RabbitMQ, flux.Trigger

RabbitMQTrigger that consumes message from AMQP channel. This works with AMQP server that implements 0-9-1 version of the specification.

Author:
arul@fluxcorp.com

Nested Class Summary
static class RabbitMQTrigger.RabbitMQTriggerResult
          The response from the RabbitMQTrigger.
 
Method Summary
 void setPollingDelay(String timeExpression)
          Sets the delay that occurs between message polling.
 
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

setPollingDelay

void setPollingDelay(String timeExpression)
Sets the delay that occurs between message polling. Defaults to +5s, five seconds.

Parameters:
timeExpression - the delay that occurs between message polling.


© 2000-2011 Flux Corporation. All rights reserved.