diff --git a/awx/ui/static/js/controllers/Sockets.js b/awx/ui/static/js/controllers/Sockets.js
index f5d0a7f299..1a203a347f 100644
--- a/awx/ui/static/js/controllers/Sockets.js
+++ b/awx/ui/static/js/controllers/Sockets.js
@@ -38,6 +38,23 @@ function SocketsController ($scope, $compile, ClearScope, Socket) {
e = angular.element(document.getElementById('jobs-container'));
e.append(html);
$compile(e)(jobs_scope);
+
+ html = "
Socket url: {{ socket_url }} Status: {{ socket_status }} {{ socket_reason }}
\n" +
+ "\n" +
+ "\n" +
+ "
Subscribed to events for job: {{ jobs_list }}
\n" +
+ "
Received Messages:
\n" +
+ "
\n" +
+ "- {{ message }}
\n" +
+ "
\n" +
+ "
\n";
+
e = angular.element(document.getElementById('job-events-container'));
e.append(html);
$compile(e)(job_events_scope);
@@ -55,6 +72,15 @@ function SocketsController ($scope, $compile, ClearScope, Socket) {
jobs_socket.on("status_changed", function(data) {
jobs_scope.messages.push(data);
});
+
+ job_events_scope.jobs_list = [];
+
+ job_events_scope.subscribeToJobEvent = function() {
+ job_events_scope.jobs_list.push(job_events_scope.job_id);
+ job_events_socket.on("job_events-" + job_events_scope.job_id, function(data) {
+ jobs_scope.messages.push(data);
+ });
+ };
}
SocketsController.$inject = [ '$scope', '$compile', 'ClearScope', 'Socket'];