Module: Octokiq::Server

Extended by:
Server
Included in:
Server
Defined in:
lib/octokiq/server.rb

Defined Under Namespace

Classes: Configuration

Instance Method Summary collapse

Instance Method Details

#configuration ⇒ Object 



23
24
25
 
# File 'lib/octokiq/server.rb', line 23

def configuration
  @configuration ||= Configuration.new
end

#configure {|configuration| ... } ⇒ Object

Yields:



19
20
21
 
# File 'lib/octokiq/server.rb', line 19

def configure
  yield(configuration)
end

#start ⇒ Object 



27
28
29
30
31
32
33
34
 
# File 'lib/octokiq/server.rb', line 27

def start
  configuration.thread_mode ? handle_thread_jobs : ractor_workers

  loop do
    job = connection.fetch(queues)
    pipe << job
  end
end