Compatibility with que 1.0.0.beta3 config feature

README.md

@@ -9,6 +9,17 @@ publishing using [Que](https://github.com/chanks/que) actors.
 gem 'wisper-que'
 ```
 
+## Configuration
+
+Custom Queue Name
+
+`config/initializers/wisper_que.rb`
+```
+WisperQue.configure do |c|
+  c.queue_name = 'wisper' # or 'default'
+end
+```
+
 ## Usage
 
 ```ruby
@@ -32,6 +43,12 @@ joe.subscribe(SomeJob, async: true)
 joe.call
 ```
 
+Run Que with custom queue name:
+```bash
+ que -q wisper
+```
+
+
 ## Contributing
 
 Yes please, either submit a PR or open an issue first to discuss your thoughts.

lib/wisper/que.rb

@@ -1,11 +1,13 @@
 require "wisper/que/version"
+require "wisper/que/wisper_que"
 require "que"
 require "wisper"
 
 module Wisper
   class Que
-    def broadcast(subscriber, publisher, event, args)
-      Wrapper.enqueue(subscriber.name, event, args)
+
+    def broadcast(subscriber, _publisher, event, args)
+      Wrapper.enqueue(subscriber.name, event, args, queue: WisperQue.instance.queue_name)
     end
 
     class Wrapper < ::Que::Job

lib/wisper/que/version.rb

@@ -1,5 +1,5 @@
 module Wisper
   class Que
-    VERSION = "0.1.0"
+    VERSION = "0.2.0"
   end
 end

lib/wisper/que/wisper_que.rb

@@ -0,0 +1,15 @@
+require 'singleton'
+
+class WisperQue
+  include Singleton
+
+  attr_accessor :queue_name
+
+  def initialize
+    @queue_name = Que.default_queue
+  end
+
+  def self.configure
+    yield self.instance
+  end
+end

spec/wisper/que_spec.rb

@@ -1,8 +1,19 @@
 require 'spec_helper'
+require 'uri'
 require 'pg'
+require 'connection_pool'
 
-Que.connection = PG::Connection.open(ENV['DATABASE_URL'] || "postgres://localhost/wisper-que-test")
-Que.mode = :sync
+uri = URI.parse(ENV['DATABASE_URL'] || "postgres://localhost/wisper-que-test")
+
+Que.connection = ConnectionPool.new(size: 1) do
+  PG::Connection.open(
+      host:     uri.host,
+      user:     uri.user,
+      password: uri.password,
+      port:     uri.port || 5432,
+      dbname:   uri.path[1..-1]
+  )
+end
 
 describe Wisper::Que do
   it 'has a version number' do

wisper-que.gemspec

@@ -19,10 +19,11 @@ Gem::Specification.new do |spec|
   spec.executables   = spec.files.grep(%r{^exe/}) { |f| File.basename(f) }
   spec.require_paths = ["lib"]
 
-  spec.add_dependency "que", "~> 0.11"
-  spec.add_dependency "wisper", "~> 1.0"
+  spec.add_dependency "que", "~> 1.0.0.beta"
+  spec.add_dependency "wisper", "~> 2.0"
 
   spec.add_development_dependency "bundler", "~> 1.8"
   spec.add_development_dependency "rake", "~> 10.0"
   spec.add_development_dependency "pg", ">= 0"
+  spec.add_development_dependency "connection_pool", ">= 0"
 end