lib/kafkr/producer.rb in kafkr-0.5.5 vs lib/kafkr/producer.rb in kafkr-0.5.6
- old
+ new
@@ -16,9 +16,10 @@
FileUtils.mkdir_p "./.kafkr"
@configuration ||= OpenStruct.new
@configuration.queue_file = MESSAGE_QUEUE
@configuration.acknowledged_file = ACKNOWLEDGED_MESSAGE_QUEUE
@configuration.message_queue = []
+ @configuration.acknowledged_messages = []
@configuration.acknowledged_messages = load_acknowledged_messages
load_queue_from_file
@configuration
end