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