lib/refinery/queueable.rb in refinery-0.10.8 vs lib/refinery/queueable.rb in refinery-0.10.9

@@ -21,13 +21,20 @@
     
     protected
     # Get the queue provider. Defaults to RightAws::SqsGen2 running
     # in multi-thread mode.
     def queue_provider
-      @queue_provider ||= RightAws::SqsGen2.new(
-        config['aws']['credentials']["access_key_id"], 
-        config['aws']['credentials']["secret_access_key"],
-        {:multi_thread => true}
-      )
+      if defined?(Typica)
+        @queue_provider ||= Typica::Sqs::QueueService.new(
+          config['aws']['credentials']["access_key_id"], 
+          config['aws']['credentials']["secret_access_key"]
+        )
+      else
+        @queue_provider ||= RightAws::SqsGen2.new(
+          config['aws']['credentials']["access_key_id"], 
+          config['aws']['credentials']["secret_access_key"],
+          {:multi_thread => true}
+        )
+      end
     end
   end
 end
\ No newline at end of file