mirror of
https://github.com/ansible/awx.git
synced 2026-05-21 15:57:52 -02:30
Fix callback consumer port to always be a URL, instead of sometimes an int.
This commit is contained in:
@@ -111,7 +111,7 @@ class CallbackModule(object):
|
|||||||
def _start_connection(self):
|
def _start_connection(self):
|
||||||
self.context = zmq.Context()
|
self.context = zmq.Context()
|
||||||
self.socket = self.context.socket(zmq.REQ)
|
self.socket = self.context.socket(zmq.REQ)
|
||||||
self.socket.connect(str(self.callback_consumer_port))
|
self.socket.connect(self.callback_consumer_port)
|
||||||
|
|
||||||
def _post_job_event_queue_msg(self, event, event_data):
|
def _post_job_event_queue_msg(self, event, event_data):
|
||||||
self.counter += 1
|
self.counter += 1
|
||||||
|
|||||||
@@ -493,7 +493,7 @@ else:
|
|||||||
INTERNAL_API_URL = 'http://127.0.0.1:8000'
|
INTERNAL_API_URL = 'http://127.0.0.1:8000'
|
||||||
|
|
||||||
# ZeroMQ callback settings.
|
# ZeroMQ callback settings.
|
||||||
CALLBACK_CONSUMER_PORT = 5556
|
CALLBACK_CONSUMER_PORT = "tcp://127.0.0.1:5556"
|
||||||
CALLBACK_QUEUE_PORT = "ipc:///tmp/callback_receiver.ipc"
|
CALLBACK_QUEUE_PORT = "ipc:///tmp/callback_receiver.ipc"
|
||||||
|
|
||||||
TASK_COMMAND_PORT = 6559
|
TASK_COMMAND_PORT = 6559
|
||||||
|
|||||||
Reference in New Issue
Block a user