lib/rubyrep/proxy_connection.rb in rubyrep-1.1.2 vs lib/rubyrep/proxy_connection.rb in rubyrep-1.2.0

@@ -237,9 +237,14 @@
       cursors.each_key do |cursor|
         cursor.destroy
       end
       cursors.clear
 
+      if connection.log_subscriber
+        ActiveSupport::Notifications.notifier.unsubscribe connection.log_subscriber
+        connection.log_subscriber = nil
+      end
+
       self.connection.disconnect!
     end
     
     # Quotes the given value. It is assumed that the value belongs to the specified column name and table name.
     # Caches the column objects for higher speed.