95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
# File 'lib/consumer/consumer.rb', line 95
def configure(batch_size: nil, session: nil, position_store: nil, **)
logger.trace { "Configuring (Batch Size: #{batch_size}, Session: #{session.inspect})" }
super if defined?(super)
starting_position = self.position_store.get
Subscription.configure(
self,
stream_name,
get,
position: starting_position,
poll_interval_milliseconds: poll_interval_milliseconds
)
handlers = self.class.handler_registry.get(self)
dispatch = Dispatch.configure(self, handlers)
logger.debug { "Done configuring (Batch Size: #{batch_size}, Session: #{session.inspect}, Starting Position: #{starting_position})" }
end
|