Method: Que::Connection.wrap

Defined in:
lib/que/connection.rb

.wrap(conn) ⇒ Object 



28
29
30
31
32
33
34
35
36
37
38
39
40
41
 
# File 'lib/que/connection.rb', line 28

def wrap(conn)
  case conn
  when self
    conn
  when PG::Connection
    if conn.instance_variable_defined?(:@que_wrapper)
      conn.instance_variable_get(:@que_wrapper)
    else
      conn.instance_variable_set(:@que_wrapper, new(conn))
    end
  else
    raise Error, "Unsupported input for Connection.wrap: #{conn.class}"
  end
end