config.rb in event_sourcery-0.18.0

- old
+ new

@@ -27,10 +27,13 @@
 
     attr_writer :logger,
                 :event_body_serializer,
                 :event_builder
 
+    # @return Integer
+    attr_accessor :subscription_batch_size
+
     # @api private
     def initialize
       @on_unknown_event = proc { |event, aggregate|
         raise AggregateRoot::UnknownEventError, "#{event.type} is unknown to #{aggregate.class.name}"
       }
@@ -38,9 +41,10 @@
         # app specific custom logic ie. report to an error reporting service like Rollbar.
       }
       @event_builder = nil
       @event_type_serializer = EventStore::EventTypeSerializers::Underscored.new
       @error_handler_class = EventProcessing::ErrorHandlers::ConstantRetry
+      @subscription_batch_size = 1000
     end
 
     # Logger instance used by EventSourcery.
     # By default EventSourcery will log to STDOUT with a log level of Logger::DEBUG
     def logger