0
@@ -26,10 +26,9 @@ module Beanstalk
0
   class Connection
0
     attr_reader :addr
0
 
0
-    def initialize(addr, jptr=self, default_tube=nil)
0
+    def initialize(addr, default_tube=nil)
0
       @waiting = false
0
       @addr = addr
0
-      @jptr = jptr
0
       connect
0
       @last_used = 'default'
0
       @watch_list = [@last_used]
0
@@ -89,7 +88,7 @@ module Beanstalk
0
         @waiting = false
0
       end
0
 
0
-      Job.new(@jptr, *read_job('RESERVED'))
0
+      Job.new(self, *read_job('RESERVED'))
0
     end
0
 
0
     def delete(id)
0
@@ -181,7 +180,7 @@ module Beanstalk
0
     end
0
 
0
     def found_job()
0
-      Job.new(@jptr, *read_job('FOUND'))
0
+      Job.new(self, *read_job('FOUND'))
0
     rescue NotFoundError
0
       nil
0
     end
0
@@ -225,7 +224,7 @@ module Beanstalk
0
         begin
0
           if !@connections.include?(addr)
0
             puts "connecting to beanstalk at #{addr}"
0
-            @connections[addr] = Connection.new(addr, self, @default_tube)
0
+            @connections[addr] = Connection.new(addr, @default_tube)
0
             prev_watched = @connections[addr].list_tubes_watched()
0
             to_ignore = prev_watched - @watch_list
0
             @watch_list.each{|tube| @connections[addr].watch(tube)}