Name

adams.flow.source.RabbitMQConsume

Synopsis

Consumes data it receives and forwards it.
It either binds to the specified exchange (if non-empty and ignores the queue name), or it listens to the specified queue.
When using an exchange, this one must be declared via the adams.flow.standalone.RabbitMQChannelAction standalone.
When not automatically acknowledging messages, the delivery tag must be retrieved from the delivery envelope (enabled to output container) and manually acknowledge using adams.flow.sink.RabbitMQMessageDeliveryAction.

Additional information

Flow input/output:
- output: java.lang.String

See also

• adams.data.conversion.RabbitMQEnvelopeToMap
• adams.flow.sink.RabbitMQMessageDeliveryAction

Options

• loggingLevel
  

  The logging level for outputting errors and debugging output.

  command-line	-logging-level <OFF|SEVERE|WARNING|INFO|CONFIG|FINE|FINER|FINEST>
  default	WARNING

  
  
• name
  

  The name of the actor.

  command-line	-name <java.lang.String>
  default	RabbitMQConsume

  
  
• annotations
  

  The annotations to attach to this actor.

  command-line	-annotation <adams.core.base.BaseAnnotation>
  default

  
  
• skip
  

  If set to true, transformation is skipped and the input token is just forwarded as it is.

  command-line	-skip <boolean>
  default	false

  
  
• stopFlowOnError
  

  If set to true, the flow execution at this level gets stopped in case this actor encounters an error; the error gets propagated; useful for critical actors.

  command-line	-stop-flow-on-error <boolean>
  default	false

  
  
• silent
  

  If enabled, then no errors are output in the console; Note: the enclosing actor handler must have this enabled as well.

  command-line	-silent <boolean>
  default	false

  
  
• exchange
  

  The name of the exchange.

  command-line	-exchange <java.lang.String>
  default

  
  
• queue
  

  The name of the queue.

  command-line	-queue <java.lang.String>
  default

  
  
• autoAck
  

  If enabled, jobs are automatically acknowledged (= flagged as successfully processed); otherwise the delivery tag has get extracted with adams.data.conversion.RabbitMQEnvelopeToMap and manually acknowledged using adams.flow.sink.RabbitMQMessageDeliveryAction.

  command-line	-auto-ack <boolean>
  default	true

  
  
• converter
  

  The converter to use.

  command-line	-converter <adams.core.net.rabbitmq.receive.AbstractConverter>
  default	adams.core.net.rabbitmq.receive.StringConverter

  
  
• limit
  

  The limit for data objects received; use <= 0 for unlimited size.

  command-line	-limit <int>
  default	-1
  minimum	-1

  
  
• outputContainer
  

  If enabled, outputs the data along side any properties in a adams.flow.container.RabbitMQConsumptionContainer.

  command-line	-output-container <boolean>
  default	false