Skip to content
Snippets Groups Projects
Commit 2ae3d098 authored by Jan David Mol's avatar Jan David Mol
Browse files

SW-657: Use scu001/199 directly for LCS/Messaging/python, to avoid relying on...

SW-657: Use scu001/199 directly for LCS/Messaging/python, to avoid relying on qpid infrastructure for our services.
parent f66ea345
No related branches found
No related tags found
No related merge requests found
......@@ -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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment