Sha256: 335d3a069713f3a5ff75ba369d23b6fa9dd079d040a03dde431cfc950e8fd8bc
Contents?: true
Size: 909 Bytes
Versions: 5
Compression:
Stored size: 909 Bytes
Contents
require 'salemove/process_handler'
require 'salemove/process_handler/composite_process'
require 'salemove/process_handler/cron_process'
require 'salemove/process_handler/pivot_process'
module Salemove
class EchoResultService
QUEUE = 'Dummy'
def call(params={})
puts "RESULT"
end
end
class Freddy
def respond_to(*)
ResponderHandler.new
end
end
class DummyStatsd
def histogram(*)
end
end
class ResponderHandler
def shutdown
end
end
cron_process = ProcessHandler::CronProcess.new
cron_process.schedule('0.5')
cron_process.schedule('5', some: 'params')
pivot_process = ProcessHandler::PivotProcess.new(
freddy: Freddy.new,
logger: Logger.new('/dev/null'),
statsd: DummyStatsd.new
)
ProcessHandler.start_composite do
add cron_process, EchoResultService.new
add pivot_process, EchoResultService.new
end
end
Version data entries
5 entries across 5 versions & 1 rubygems