Skip to content
This repository was archived by the owner on Nov 14, 2022. It is now read-only.

Commit f228dd1

Browse files
author
Dimitar Tasev
committed
Replace gethostname with getfqdn
1 parent 1d7e420 commit f228dd1

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

queue_processors/queue_processor/handle_message.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -277,7 +277,7 @@ def _common_reduction_run_update(reduction_run, status, message):
277277
reduction_run.finished = timezone.now()
278278
reduction_run.message = message.message
279279
reduction_run.reduction_log = message.reduction_log
280-
message.admin_log += "Running on host: %s" % socket.gethostname()
280+
message.admin_log += "Running on host: %s" % socket.getfqdn()
281281
reduction_run.admin_log = message.admin_log
282282

283283
@staticmethod

utils/clients/queue_client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ def subscribe_queues(self, queue_list, consumer_name, listener):
9494
for queue in queue_list:
9595
# prefetchSize limits the processing to 1 message at a time
9696
self._connection.subscribe(destination=queue,
97-
id=socket.gethostname(),
97+
id=socket.getfqdn(),
9898
ack="client-individual",
9999
header={'activemq.prefetchSize': '1'})
100100
self._logger.info("[%s] Subscribing to %s", consumer_name, queue)

0 commit comments

Comments
 (0)