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

Version Path
pione-0.2.2 lib/pione/front/broker-front.rb
pione-0.2.1 lib/pione/front/broker-front.rb
pione-0.2.0 lib/pione/front/broker-front.rb
pione-0.1.4 lib/pione/front/broker-front.rb
pione-0.1.3 lib/pione/front/broker-front.rb
pione-0.1.2 lib/pione/front/broker-front.rb
pione-0.1.1 lib/pione/front/broker-front.rb
pione-0.1.0 lib/pione/front/broker-front.rb