CascadedConsumer: re-initialize provider connection when location changes

This will avoid situation when connection is recreated with old connect string.

diff --git a/python/pgq/cascade/consumer.py b/python/pgq/cascade/consumer.py
index cebba94ace4919db217b5aabf9bb8085c1430114..3d20ba78aa0732e022bdb805fb10d1ba403e64f2 100644 (file)
--- 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