lib/smart_que/publisher.rb in smart-que-0.2.0 vs lib/smart_que/publisher.rb in smart-que-0.2.3

@@ -4,32 +4,58 @@
   class Publisher < Publishers::Base
     
     # Initialize
     def initialize
       queue_list.each do |q_name|
-        q = get_queue(q_name)
-        q.bind(x_direct, routing_key: q.name)
+        find_or_initialize_queue(q_name)
       end
     end
 
     # Instance methods
 
     # Publish message to the respective queue
-    def publish(queue, options = {})
+    def publish(queue, payload = {})
       # Check queue name includes in the configured list
       # Return if queue doesn't exist
       if queue_list.include? queue
         # Publish sms to queue
         x_direct.publish(
-                          options.to_json,
-                          mandatory: true,
-                          routing_key: get_queue(queue).name
-                        )
-        log_message("Publish status: success, Queue : #{queue}, Content : #{options}")
+          payload.to_json,
+          mandatory: true,
+          routing_key: get_queue(queue).name
+        )
+        log_message("Publish status: success, Queue : #{queue}, Content : #{payload}")
       else
         log_message("Publish status: failed, Queue(#{queue}) doesn't exist.")
-        log_message("Content : #{options}")
+        log_message("Content : #{payload}")
         raise QueueNotFoundError
       end
+    end
+
+    # unicast message to queues
+    def unicast(q_name, payload = {})
+      x_default.publish(
+        payload.to_json,
+        routing_key: dot_formatted(q_name)
+      )
+      log_message("unicast status: success, Queue : #{q_name}, Content : #{payload}")
+    end
+
+
+    # multicast message to queues based on topic subscription
+    def multicast(topic, payload = {})
+      x_topic.publish(
+        payload.to_json,
+        routing_key: dot_formatted(topic)
+      )
+      log_message("multicast status: success, Topic : #{topic}, Content : #{payload}")
+    end
+
+    # broadcast message to queues based on topic subscription
+    def broadcast(payload = {})
+      x_fanout.publish(
+        payload.to_json
+      )
+      log_message("broadcast status: success, Content : #{payload}")
     end
   end
 end
\ No newline at end of file