journal, integrated in bot

1 files changed, 6 insertions, 2 deletions

diff --git a/lib/rbot/journal.rb b/lib/rbot/journal.rb
index a25f3a9f..5045f9d5 100644
--- a/lib/rbot/journal.rb
+++ b/lib/rbot/journal.rb
@@ -125,8 +125,8 @@ module Journal
       end
     end
 
-    def create(name, uri)
-      log 'load journal storage adapter: ' + name
+    def self.create(name, uri)
+      warning 'load journal storage adapter: ' + name
       load File.join(File.dirname(__FILE__), 'journal', name + '.rb')
       cls = AbstractStorage.get_impl.first
       cls.new(uri: uri)
@@ -285,6 +285,7 @@ module Journal
     def initialize(opts={})
       # overrides the internal consumer with a block
       @consumer = opts[:consumer]
+      @bot = opts[:bot]
       # storage backend
       if @bot
         @storage = opts[:storage] || Storage.create(
@@ -292,6 +293,9 @@ module Journal
       else
         @storage = opts[:storage]
       end
+      unless @storage
+        warning 'journal broker: no storage set up, won\'t persist messages'
+      end
       @queue = Queue.new
       # consumer thread:
       @thread = Thread.new do