Show More
@@ -658,12 +658,12 b' class Kernel(Configurable):' | |||||
658 | #--------------------------------------------------------------------------- |
|
658 | #--------------------------------------------------------------------------- | |
659 |
|
659 | |||
660 | def abort_request(self, stream, ident, parent): |
|
660 | def abort_request(self, stream, ident, parent): | |
661 |
"""abort a specifi |
|
661 | """abort a specific msg by id""" | |
662 | msg_ids = parent['content'].get('msg_ids', None) |
|
662 | msg_ids = parent['content'].get('msg_ids', None) | |
663 | if isinstance(msg_ids, string_types): |
|
663 | if isinstance(msg_ids, string_types): | |
664 | msg_ids = [msg_ids] |
|
664 | msg_ids = [msg_ids] | |
665 | if not msg_ids: |
|
665 | if not msg_ids: | |
666 | self.abort_queues() |
|
666 | self._abort_queues() | |
667 | for mid in msg_ids: |
|
667 | for mid in msg_ids: | |
668 | self.aborted.add(str(mid)) |
|
668 | self.aborted.add(str(mid)) | |
669 |
|
669 |
General Comments 0
You need to be logged in to leave comments.
Login now