We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e09fd5c commit ba09b47Copy full SHA for ba09b47
cloudevents-sdk-paho-mqtt/src/mqtt_consumer_record.rs
@@ -131,17 +131,6 @@ impl MessageDeserializer for ConsumerMessageDeserializer {
131
132
pub fn record_to_event(msg: &Message) -> Result<Event> {
133
MessageDeserializer::into_event(ConsumerMessageDeserializer::new(msg)?)
134
- /* match version {
135
- headers::MqttVersion::V5 => {
136
- BinaryDeserializer::into_event(ConsumerMessageDeserializer::new(msg)?)
137
- }
138
- headers::MqttVersion::V3_1 => {
139
- StructuredDeserializer::into_event(ConsumerMessageDeserializer::new(msg)?)
140
141
- headers::MqttVersion::V3_1_1 => {
142
143
144
- }*/
145
}
146
147
pub trait MessageExt {
0 commit comments