Declare lack of support for shared subs and sub IDs.

pull/1072/head
Roger Light 7 years ago committed by Roger A. Light
parent a9d19d0911
commit 17d213b79a

@ -51,6 +51,18 @@ int send__connack(struct mosquitto_db *db, struct mosquitto *context, int ack, i
return rc; return rc;
} }
} }
/* FIXME - disable support until available */
rc = mosquitto_property_add_byte(&properties, MQTT_PROP_SHARED_SUB_AVAILABLE, 0);
if(rc){
mosquitto__free(packet);
return rc;
}
rc = mosquitto_property_add_byte(&properties, MQTT_PROP_SUBSCRIPTION_ID_AVAILABLE, 0);
if(rc){
mosquitto__free(packet);
return rc;
}
proplen = property__get_length_all(properties); proplen = property__get_length_all(properties);
varbytes = packet__varint_bytes(proplen); varbytes = packet__varint_bytes(proplen);
packet->remaining_length += proplen + varbytes; packet->remaining_length += proplen + varbytes;

@ -6,6 +6,8 @@ import struct
import sys import sys
import time import time
import mqtt5_props
def start_broker(filename, cmd=None, port=0, use_conf=False): def start_broker(filename, cmd=None, port=0, use_conf=False):
delay = 0.1 delay = 0.1
@ -359,7 +361,11 @@ def gen_connect(client_id, clean_session=True, keepalive=60, username=None, pass
def gen_connack(resv=0, rc=0, proto_ver=4): def gen_connack(resv=0, rc=0, proto_ver=4):
if proto_ver == 5: if proto_ver == 5:
packet = struct.pack('!BBBBB', 32, 3, resv, rc, 0); props = mqtt5_props.gen_byte_prop(mqtt5_props.PROP_SHARED_SUB_AVAILABLE, 0)
props += mqtt5_props.gen_byte_prop(mqtt5_props.PROP_SUBSCRIPTION_ID_AVAILABLE, 0)
props = mqtt5_props.prop_finalise(props)
packet = struct.pack('!BBBB', 32, 2+len(props), resv, rc) + props
else: else:
packet = struct.pack('!BBBB', 32, 2, resv, rc); packet = struct.pack('!BBBB', 32, 2, resv, rc);

Loading…
Cancel
Save