Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Already on GitHub? Sign in to your account

Decode NotImplementedError when using rabbitmq-mqtt plug in #28

Closed
ghost opened this Issue Jan 24, 2013 · 1 comment

Comments

Projects
None yet
1 participant
@ghost

ghost commented Jan 24, 2013

When using the RabbitMQ-MQTT plugin (any version from what I can tell), this error is returned when queue receives a message via the callback:

amq-protocol-1.1.0/lib/amq/protocol/table.rb:88:in `decode': NotImplementedError (NotImplementedError)

After some investigation, it's clear that the rabbitmq-mqtt plug in is including an encoded byte value, specifically, in the header:

{"x-mqtt-publish-qos"=>[0]}

The "0" is an encoded byte. There is no decode method for signed 8bit value.

Owner

michaelklishin commented Feb 9, 2013

Should be fixed by #28

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment