Sha256: bbd971b4edd000d79e4df1abed8f5ed96e4b69975bc7fc71de04e42595ed79b6

Contents?: true

Size: 758 Bytes

Versions: 20

Compression:

Stored size: 758 Bytes

Contents

module Invoker
  module IPC
    class BaseCommand
      attr_accessor :client_socket
      def initialize(client_socket)
        @client_socket = client_socket
      end

      def send_data(message_object)
        client_socket.write(message_object.encoded_message)
      end

      # Invoke the command that actual processes incoming message
      # returning true from this message means, command has been processed
      # and client socket can be closed. returning false means, it is a
      # long running command and socket should not be closed immediately
      # @param [Invoker::IPC::Message] incoming message
      # @return [Boolean] true or false
      def run_command(message_object)
        raise "Not implemented"
      end
    end
  end
end

Version data entries

20 entries across 20 versions & 3 rubygems

Version Path
itrg-invoker-1.6.1 lib/invoker/ipc/base_command.rb
itrg-invoker-1.6.0 lib/invoker/ipc/base_command.rb
invoker-1.5.8 lib/invoker/ipc/base_command.rb
invoker-1.5.7 lib/invoker/ipc/base_command.rb
invoker-1.5.6 lib/invoker/ipc/base_command.rb
invoker-1.5.5 lib/invoker/ipc/base_command.rb
invoker-1.5.4 lib/invoker/ipc/base_command.rb
invoker-1.5.3 lib/invoker/ipc/base_command.rb
meepo-1.5.2 lib/invoker/ipc/base_command.rb
invoker-1.5.1 lib/invoker/ipc/base_command.rb
invoker-1.4.1 lib/invoker/ipc/base_command.rb
invoker-1.4.0 lib/invoker/ipc/base_command.rb
invoker-1.3.2 lib/invoker/ipc/base_command.rb
invoker-1.3.1 lib/invoker/ipc/base_command.rb
invoker-1.3.0 lib/invoker/ipc/base_command.rb
invoker-1.2.0 lib/invoker/ipc/base_command.rb
invoker-1.2.0.pre2 lib/invoker/ipc/base_command.rb
invoker-1.2.0.pre1 lib/invoker/ipc/base_command.rb
invoker-1.2.0.pre lib/invoker/ipc/base_command.rb
invoker-1.1.0 lib/invoker/ipc/base_command.rb