Skip to content

Commit

Permalink
force channels to be strings
Browse files Browse the repository at this point in the history
  • Loading branch information
jipiboily authored and ryandotsmith committed Apr 3, 2014
1 parent 4bb148c commit bb48a86
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions lib/queue_classic/conn_adapter.rb
Expand Up @@ -30,10 +30,10 @@ def execute(stmt, *params)

def wait(time, *channels)
@mutex.synchronize do
listen_cmds = channels.map {|c| 'LISTEN "' + c + '"'}
listen_cmds = channels.map {|c| 'LISTEN "' + c.to_s + '"'}
@connection.exec(listen_cmds.join(';'))
wait_for_notify(time)
unlisten_cmds = channels.map {|c| 'UNLISTEN "' + c +'"'}
unlisten_cmds = channels.map {|c| 'UNLISTEN "' + c.to_s + '"'}
@connection.exec(unlisten_cmds.join(';'))
drain_notify
end
Expand Down

0 comments on commit bb48a86

Please sign in to comment.