Resolved issue YACS-RCOS#7 & YACS-RCOS#8

app/app/consumers/courses_consumer.rb

@@ -1,13 +1,14 @@
 require 'karafka'
-require_relative 'application_consumer'
 require 'plezi'
+require 'iodine'
+require_relative 'application_consumer'
 
 class CourseConsumer < ApplicationConsumer
   def consume
 	  if ( Object.const_defined?('EventStream') == false )
 	    puts "EventStream class not initialized" 
 	  else 
-	    EventStream.on_message(params)
+	    EventStream.new.notify(params)
 	    puts "Consumer message sent to websocket"
 	  end	
   end

app/app/consumers/sections_consumer.rb

@@ -1,13 +1,14 @@
 require 'karafka'
-require_relative 'application_consumer'
 require 'plezi'
+require 'iodine'
+require_relative 'application_consumer'
 
 class SectionConsumer < ApplicationConsumer
   def consume
     if ( Object.const_defined?('EventStream') == false )
       puts "EventStream class not initialized" 
     else 
-      EventStream.on_message(params)
+      EventStream.new.notify(params)
       puts "Consumer message sent to websocket"
     end	
   end

app/app/controllers/eventstream.rb

@@ -1,19 +1,23 @@
 require 'plezi'
+require 'iodine'
 require 'json'
 
 class EventStream
-
+  #@auto_dispatch = true
+
   def on_open
     puts 'Opened the YACS-EventStream Websocket!'
   end
 
-  ## When receiving a single message from Consumer pusblish to socket
-  def on_message(data)
-    event = {:notifications => :data }
-    write event.to_json
+  #def on_message data
+  def notify(data)
+    puts data
+    #event = {:notifications => data }
+    #puts event.to_json  # need to figure out this shit
   end 
 
   def on_close
   end
 end
-Plezi.route '/notifications', EventStream
+#Plezi.route '/notifications', EventStream
+#ip address 172.19.0.9:9094

app/controllers/eventstream.rb

@@ -7,7 +7,7 @@ def on_open
   end
 
   ## When receiving a single message from Consumer pusblish to socket
-  def on_message(data)
+  def on_message data
     unless write { notifications: :data }.to_json
       write "no message sent"
     end