diff options
| -rwxr-xr-x | bin/emq-cli | 4 | ||||
| -rw-r--r-- | eventmq/utils/messages.py | 6 |
2 files changed, 7 insertions, 3 deletions
diff --git a/bin/emq-cli b/bin/emq-cli index 52cf180..0c065fe 100755 --- a/bin/emq-cli +++ b/bin/emq-cli | |||
| @@ -95,6 +95,10 @@ class Shell(cmd.Cmd): | |||
| 95 | self.send_message('STATUS') | 95 | self.send_message('STATUS') |
| 96 | pprint(self.recv_reply()) | 96 | pprint(self.recv_reply()) |
| 97 | 97 | ||
| 98 | def do_show_scheduled_jobs(self, line): | ||
| 99 | self.send_message('SCHEDULER_SHOW_SCHEDULED_JOBS') | ||
| 100 | pprint(self.recv_reply()) | ||
| 101 | |||
| 98 | def do_show_workers(self, line): | 102 | def do_show_workers(self, line): |
| 99 | """ | 103 | """ |
| 100 | Request the status of the connected workers and queues | 104 | Request the status of the connected workers and queues |
diff --git a/eventmq/utils/messages.py b/eventmq/utils/messages.py index 524cb8e..b664594 100644 --- a/eventmq/utils/messages.py +++ b/eventmq/utils/messages.py | |||
| @@ -89,7 +89,7 @@ def generate_msgid(prefix=None): | |||
| 89 | return id if not prefix else str(prefix) + id | 89 | return id if not prefix else str(prefix) + id |
| 90 | 90 | ||
| 91 | 91 | ||
| 92 | def send_emqp_message(socket, command, msgid=None, message=None): | 92 | def send_emqp_message(socket, command, message=None, msgid=None): |
| 93 | """ | 93 | """ |
| 94 | Formats and sends an eMQP message | 94 | Formats and sends an eMQP message |
| 95 | 95 | ||
| @@ -117,8 +117,8 @@ def send_emqp_message(socket, command, msgid=None, message=None): | |||
| 117 | return msgid | 117 | return msgid |
| 118 | 118 | ||
| 119 | 119 | ||
| 120 | def send_emqp_router_message(socket, recipient_id, command, msgid=None, | 120 | def send_emqp_router_message(socket, recipient_id, command, |
| 121 | message=None): | 121 | message=None, msgid=None): |
| 122 | """ | 122 | """ |
| 123 | Formats and sends an eMQP message taking into account the recipient frame | 123 | Formats and sends an eMQP message taking into account the recipient frame |
| 124 | used by a :attr:`zmq.ROUTER` device. | 124 | used by a :attr:`zmq.ROUTER` device. |