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)