lib/dcell.rb in dcell-0.8.0 vs lib/dcell.rb in dcell-0.9.0

- old
+ new

@@ -1,9 +1,11 @@ require 'celluloid' require 'celluloid/zmq' -require 'dcell/version' +Celluloid::ZMQ.init + +require 'dcell/version' require 'dcell/actor_proxy' require 'dcell/directory' require 'dcell/mailbox_proxy' require 'dcell/messages' require 'dcell/node' @@ -12,21 +14,20 @@ require 'dcell/router' require 'dcell/rpc' require 'dcell/server' require 'dcell/registries/redis_adapter' +require 'dcell/registries/moneta_adapter' + require 'dcell/celluloid_ext' # Distributed Celluloid module DCell DEFAULT_PORT = 7777 # Default DCell port - ZMQ_POOL_SIZE = 1 # DCell uses a fixed-size 0MQ thread pool - - @zmq_context = Celluloid::ZMQ.context = ::ZMQ::Context.new(ZMQ_POOL_SIZE) @config_lock = Mutex.new class << self - attr_reader :me, :registry, :zmq_context + attr_reader :me, :registry # Configure DCell with the following options: # # * id: to identify the local node, defaults to hostname # * addr: 0MQ address of the local node (e.g. tcp://4.3.2.1:7777)