Use all messaging options

Author: agrare

workers/event_catcher/event_catcher.rb

@@ -124,11 +124,7 @@ def publish_events(events)
 
   def messaging_client
     @messaging_client ||= ManageIQ::Messaging::Client.open(
-      :host       => messaging["host"],
-      :port       => messaging["port"],
-      :protocol   => :Kafka,
-      :encoding   => "json",
-      :client_ref => "vmware-event-catcher-#{ems_id}"
+      messaging.merge(:client_ref => "vmware-event-catcher-#{ems_id}")
     )
   end
 

workers/event_catcher/worker

@@ -24,7 +24,7 @@ def main(args)
   ems                    = args["ems"].detect { |e| e["type"] == "ManageIQ::Providers::Vmware::InfraManager" }
   default_endpoint       = ems["endpoints"].detect { |ep| ep["role"] == "default" }
   default_authentication = ems["authentications"].detect { |auth| auth["authtype"] == "default" }
-  messaging              = args["messaging"]
+  messaging              = args["messaging"].symbolize_keys
 
   EventCatcher.new(ems["id"], default_endpoint, default_authentication, messaging).run!
 end