Class: Consumer::Actor

Inherits:
Object
  • Object
show all
Includes:
Actor, Log::Dependency
Defined in:
lib/consumer/actor.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.build(consumer, subscription) ⇒ Object 



10
11
12
13
14
15
 
# File 'lib/consumer/actor.rb', line 10

def self.build(consumer, subscription)
  instance = new subscription.address
  instance.consumer = consumer
  instance.configure
  instance
end

Instance Method Details

#request_batch ⇒ Object 



35
36
37
38
39
40
41
42
43
 
# File 'lib/consumer/actor.rb', line 35

def request_batch
  logger.trace { "Requesting batch" }

  get_batch = Subscription::GetBatch.new(address)

  send.(get_batch, subscription_address)

  logger.debug { "Send batch request" }
end