Sha256: e10f1281ab053fff74e566f36e193a3ee17f74cccd2532f51e0f182c3c6fc8ba

Contents?: true

Size: 707 Bytes

Versions: 4

Compression:

Stored size: 707 Bytes

Contents

module Protobuf
  module Rpc
    class ZmqRunner

      def self.stop
        Protobuf::Rpc::Zmq::Server.stop 
        Protobuf::Logger.info('Shutdown complete')
      end

      def self.run(server)
        Protobuf::Logger.info "ZmqServer Running"
        server_config = case 
                        when server.is_a?(OpenStruct) then 
                          server.marshal_dump
                        when server.respond_to?(:to_hash) then
                          server.to_hash
                        else
                          raise "Cannot parser Zmq Server - server options"
                        end

        Protobuf::Rpc::Zmq::Server.run(server_config)
      end
    end

  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
protobuf-1.4.2 lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-1.4.1 lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-1.4.0 lib/protobuf/rpc/servers/zmq_runner.rb
protobuf-1.3.0 lib/protobuf/rpc/servers/zmq_runner.rb