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