search

hozn / coilmq

Lightweight Python STOMP message broker.
Apache License 2.0
49 stars 18 forks source link

Error is ACK processing in version 1.1 protocol #34

Open imandr opened 2 years ago

imandr commented 2 years ago

In protocol version 1.1, this line https://github.com/hozn/coilmq/blob/9b75a1d708d38f16108b6cbecfba7a6f93a8dbb2/coilmq/protocol/__init__.py#L236 requires message_id attribute of the Frame object, but Frame class in util/frames.py does not have it.

Add this fragment:

    @property
    def message_id(self):
        return self.headers.get('message-id')