def with_message_id()

in pulsar/__init__.py [0:0]

• 8 lines of code
• 3 McCabe index (conditional complexity)

    def with_message_id(self, msg_id):
        if not isinstance(msg_id, _pulsar.MessageId):
            if isinstance(msg_id, MessageId):
                msg_id = msg_id._msg_id
            else:
                raise TypeError("unknown message id type")
        self._msg_batch.with_message_id(msg_id)
        return self