Sha256: 9cf115f60e64677f2f321f50f2d48abc8f6678742888bc44a536999d85da02ec
Contents?: true
Size: 800 Bytes
Versions: 8
Compression:
Stored size: 800 Bytes
Contents
module Pione module Front # BrokerFront is a front class for pione-broker command. class BrokerFront < BasicFront include TaskWorkerOwner def_delegator :@command, :broker # Create a new front. def initialize(command) super(command, Global.broker_front_port_range) initialize_task_worker_owner end def get_tuple_space_server(connection_id) broker.get_tuple_space_server(connection_id) end # Override the method with adding task worker agent to broker. def add_task_worker_front(task_worker_front, connection_id) super broker.task_workers << task_worker_front.agent end def set_tuple_space_receiver(uri) Global.set_tuple_space_receiver_uri(uri) end end end end
Version data entries
8 entries across 8 versions & 1 rubygems