Class: Artery::Publisher

Inherits:
Object
  • Object
show all
Defined in:
lib/artery/publisher.rb

Constant Summary collapse

DISCOVERY_INTERVAL = 
30
POLL_INTERVAL = 
0.5
BATCH_SIZE = 
100

Instance Method Summary collapse

Instance Method Details

#run ⇒ Object 



11
12
13
14
 
# File 'lib/artery/publisher.rb', line 11

def run
  Artery.handle_signals { shutdown }
  Artery.start { publisher_loop }
end

#shutdown ⇒ Object 



16
17
18
19
 
# File 'lib/artery/publisher.rb', line 16

def shutdown
  @pool&.shutdown
  @pool&.wait_for_termination(10)
end