lib/manageiq/messaging/client.rb
def subscribe_background_job(options)
        assert_options(options, [:service])

        subscribe_background_job_impl(options)
      end
# Subscribe to receive from a queue and run each message as a background job.
# Expected keys in +options+ are:
# * :service  (service and affinity are used to determine the queue)
# * :affinity (optional)
# * :auto_ack (default true, if it is false, client.ack method must be explicitly called)
# Other options are underlying messaging system specific.
#
# This subscriber consumes messages sent through +publish_message+ with required
# +options+ keys, for example:
#
#     client.publish_message(
#       :service    => 'generic',
#       :class_name => 'MiqTask',
#       :message    => 'update_attributes', # method name, for instance method :instance_id is required
#       :payload    => {
#         :instance_id => 2, # database id of class instance stored in rails DB
#         :args        => [{:status => 'Timeout'}] # argument list expected by the method
#       }
#     )
#
# Background job assumes each job is not re-triable. It is auto-acked as soon as a request
# is received
Subscribe to receive from a queue and run each message as a background job.
Expected keys in +options+ are:
:service  (service and affinity are used to determine the queue)
:affinity (optional)
:auto_ack (default true, if it is false, client.ack method must be explicitly called)
Other options are underlying messaging system specific.

This subscriber consumes messages sent through +publish_message+ with required
+options+ keys, for example.



Background job assumes each job is not re-triable. It is auto-acked as soon as a request
is received
Subscribe to receive from a queue and run each message as a background job . Expected keys in + options + are : : service ( service and affinity are used to determine the queue ) : affinity ( optional ) : auto_ack ( default true if it is false client . ack method must be explicitly called ) Other options are underlying messaging system specific . This subscriber consumes messages sent through + publish_message + with required + options + keys for example . Background job assumes each job is not re - triable . It is auto - acked as soon as a request is received
def subscribe_background_job(options)
        assert_options(options, [:service])
        subscribe_background_job_impl(options)
      end
def subscribe_background_job ( options ) assert_options ( options , [ :service ] ) subscribe_background_job_impl ( options ) end
Subscribe to receive from a queue and run each message as a background job.
Subscribe to receive from a queue and run each message as a background job .
options