def multicast(topic, payload = {})
      begin
        x_topic.publish(
          payload.to_json,
          routing_key: dot_formatted(topic)
        )
        log_message("multicast status: success, Topic : #{topic}, Content : #{payload}")
        :success
      rescue => ex
        log_message("Multicast error:#{ex.message}")
        :error
      end
    end
def multicast(topic, payload = {})
      begin
        x_topic.publish(
          payload.to_json,
          routing_key: dot_formatted(topic)
        )
        log_message("multicast status: success, Topic : #{topic}, Content : #{payload}")
        :success
      rescue => ex
        log_message("Multicast error:#{ex.message}")
        :error
      end
    end
multicast message to queues based on topic subscription