aboutsummaryrefslogtreecommitdiffstats
path: root/lib/action_cable/worker.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/action_cable/worker.rb')
-rw-r--r--lib/action_cable/worker.rb30
1 files changed, 0 insertions, 30 deletions
diff --git a/lib/action_cable/worker.rb b/lib/action_cable/worker.rb
deleted file mode 100644
index 6800a75d1d..0000000000
--- a/lib/action_cable/worker.rb
+++ /dev/null
@@ -1,30 +0,0 @@
-module ActionCable
- class Worker
- include ActiveSupport::Callbacks
- include Celluloid
-
- define_callbacks :work
-
- def invoke(receiver, method, *args)
- run_callbacks :work do
- receiver.send method, *args
- end
- rescue Exception => e
- logger.error "There was an exception - #{e.class}(#{e.message})"
- logger.error e.backtrace.join("\n")
-
- receiver.handle_exception if receiver.respond_to?(:handle_exception)
- end
-
- def run_periodic_timer(channel, callback)
- run_callbacks :work do
- callback.respond_to?(:call) ? channel.instance_exec(&callback) : channel.send(callback)
- end
- end
-
- private
- def logger
- ActionCable::Server.logger
- end
- end
-end