lib/shamu/events/in_memory/service.rb in shamu-0.0.21 vs lib/shamu/events/in_memory/service.rb in shamu-0.0.24

- old
+ new

@@ -10,12 +10,14 @@ # # Messages are volitale and will be lost if the process crashes. class Service < EventsService include ChannelStats - initialize do + def initialize @mutex = Thread::Mutex.new @channels = {} + + super end # (see EventsService#publish) def publish( channel, message ) state = fetch_channel( channel )