diff --git a/deriva/core/__init__.py b/deriva/core/__init__.py
index e54f18b..89f4f73 100644
--- a/deriva/core/__init__.py
+++ b/deriva/core/__init__.py
@@ -1,4 +1,4 @@
-__version__ = "1.4.0"
+__version__ = "1.4.1"
 
 from deriva.core.utils.core_utils import *
 from deriva.core.base_cli import BaseCLI, KeyValuePairArgs
diff --git a/deriva/core/polling_ermrest_catalog.py b/deriva/core/polling_ermrest_catalog.py
index 53cd34e..178133d 100644
--- a/deriva/core/polling_ermrest_catalog.py
+++ b/deriva/core/polling_ermrest_catalog.py
@@ -46,7 +46,7 @@ def look_for_work():
 
     """
 
-    def __init__(self, scheme, server, catalog_id, credentials={}, caching=True, session_config=None):
+    def __init__(self, scheme, server, catalog_id, credentials={}, caching=True, session_config=None, amqp_server=None):
         """Create ERMrest catalog binding.
 
            Arguments:
@@ -58,7 +58,7 @@ def __init__(self, scheme, server, catalog_id, credentials={}, caching=True, ses
 
         """
         ErmrestCatalog.__init__(self, scheme, server, catalog_id, credentials, caching, session_config)
-        self.amqp_server = server
+        self.amqp_server = amqp_server if amqp_server else server
         self.amqp_connection = None
         self.notice_exchange = "ermrest_changes"