lib/manageiq/messaging/client.rb
# Publish a message to a queue. The message will be delivered to only one subscriber.
# Expected keys in +options+ are:
# * :service    (service and affinity are used to determine the queue name)
# * :affinity   (optional)
# * :class_name (optional)
# * :message    (e.g. method name or message type)
# * :payload    (message body, a string or an user object that can be serialized)
# * :sender     (optional, identify the sender)
# Other options are underlying messaging system specific.
#
# Optionally a call back block can be provided to wait on the consumer to send
# an acknowledgment. Not every underlying messaging system supports callback.
# Example:
#
#   client.publish_message(
#     :service  => 'ems_operation',
#     :affinity => 'ems_amazon1',
#     :message  => 'power_on',
#     :payload  => {
#       :ems_ref => 'u987',
#       :id      => '123'
#     }
#   ) do |result|
#     ansible_install_pkg(vm1) if result == 'running'
#   end
Publish a message to a queue. The message will be delivered to only one subscriber.

Optionally a call back block can be provided to wait on the consumer to send
an acknowledgment. Not every underlying messaging system supports callback.
Example.


Publish a message to a queue . The message will be delivered to only one subscriber . Optionally a call back block can be provided to wait on the consumer to send an acknowledgment . Not every underlying messaging system supports callback . Example .
def publish_message(options, &block)
        assert_options(options, [:message, :service])
        publish_message_impl(options, &block)
      end
def publish_message ( options , & block ) assert_options ( options , [ :message , :service ] ) publish_message_impl ( options , & block ) end
Publish a message to a queue.
Publish a message to a queue .
options
block