diff --git a/LCS/Messaging/python/messaging/messagebus.py b/LCS/Messaging/python/messaging/messagebus.py index f3079f2fef395dcef6d8e885b33a901e9ba47d84..0d2bb0c38a2af9b4f9b6a49a058cca1d6c7a582f 100644 --- a/LCS/Messaging/python/messaging/messagebus.py +++ b/LCS/Messaging/python/messaging/messagebus.py @@ -30,6 +30,7 @@ from lofar.messaging.exceptions import MessageBusError, MessageFactoryError from lofar.messaging.messages import to_qpid_message, MESSAGE_FACTORY from lofar.common.util import raise_exception, is_iterable from lofar.common.datetimeutils import to_milliseconds_since_unix_epoch, from_milliseconds_since_unix_epoch +from lofar.common import isProductionEnvironment, isTestEnvironment import proton import proton.utils @@ -43,12 +44,17 @@ from copy import deepcopy logger = logging.getLogger(__name__) # Default settings for often used parameters. -DEFAULT_BROKER = "localhost:5672" +if isProductionEnvironment(): + DEFAULT_BROKER = "scu001.control.lofar" +elif isTestEnvironment(): + DEFAULT_BROKER = "scu199.control.lofar" +else: # development environment + DEFAULT_BROKER = "localhost" + DEFAULT_BROKER_OPTIONS = {'reconnect': True} DEFAULT_RECEIVER_CAPACITY = 128 DEFAULT_TIMEOUT = 5 - class _ProtonSubjectFilter(proton.reactor.Filter): """ helper class for filtering by subject