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 )