Module: EventMachine::Protocols::Zmq2::QueuePerPeer

Included in:
Pub, Router
Defined in:
lib/em/protocols/zmq2/queue_per_peer.rb

Instance Method Summary collapse

Instance Method Details

#initialize(opts = {}) ⇒ Object 



5
6
7
8
 
# File 'lib/em/protocols/zmq2/queue_per_peer.rb', line 5

def initialize(opts = {})
  super
  @queues = {}
end

#peer_free(peer, connection) ⇒ Object 



23
24
25
26
27
28
 
# File 'lib/em/protocols/zmq2/queue_per_peer.rb', line 23

def peer_free(peer, connection)
  super
  peer_conn = @peers[peer]
  queue = @queues[peer]
  flush_queue(queue, peer_conn)
end

#register_peer(peer_identity, connection) ⇒ Object 



10
11
12
13
14
 
# File 'lib/em/protocols/zmq2/queue_per_peer.rb', line 10

def register_peer(peer_identity, connection)
  peer_identity = super
  @queues[peer_identity] ||= []
  peer_identity
end

#unregister_peer(peer_identity) ⇒ Object 



16
17
18
19
20
21
 
# File 'lib/em/protocols/zmq2/queue_per_peer.rb', line 16

def unregister_peer(peer_identity)
  super
  if generated_identity?(peer_identity)
    @queues.delete peer_identity
  end
end