From 026ca8e8252af96d5db46df6e3ff74073ff1dad5 Mon Sep 17 00:00:00 2001
From: Marko Kreen <markokr@gmail.com>
Date: Tue, 5 Jun 2012 13:25:17 +0300
Subject: [PATCH] CascadedConsumer: re-initialize provider connection when
 location changes

This will avoid situation when connection is recreated with old connect string.
---
 python/pgq/cascade/consumer.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/python/pgq/cascade/consumer.py b/python/pgq/cascade/consumer.py
index cebba94a..3d20ba78 100644
--- a/python/pgq/cascade/consumer.py
+++ b/python/pgq/cascade/consumer.py
@@ -228,6 +228,8 @@ class CascadedConsumer(Consumer):
         if self.provider_connstr != loc:
             self.close_database(PDB)
             self.provider_connstr = loc
+            # re-initialize provider connection
+            db = self.get_provider_db(state);
 
         return state
 
-- 
2.39.5