I am trying to connect to Mqtt Broker (Ignition broker module) through corporate proxy, I am getting below error while executing client.connect(); call. Mqtt broker is running on my local. I also tried to connect mqtt broker running on a remote machine, but got same error as below. Quick help in this regard is highly aprreciated.
Error : com.hivemq.client.mqtt.exceptions.MqttDecodeException: Exception while decoding PUBACK: fixed header flags must be 0 but were 8
MqttProxyConfig mqttProxyConfig = MqttProxyConfig.builder()
.address(new InetSocketAddress($PROXY_HOST, 80)).protocol(proxyProtocol).build();
MqttClientTransportConfig config = MqttClientTransportConfig.builder()
.proxyConfig(mqttProxyConfig).serverHost("localhost").serverPort(1883) .build();
Mqtt3BlockingClient client = Mqtt3Client.builder()
.identifier(clientId)
.serverHost("localhost")
.serverPort(1883)
.transportConfig(config)
.simpleAuth().username(mqttBrokerUser).password(mqttBrokerConfigPassword.getBytes()).applySimpleAuth()
.buildBlocking();
client.connect();
client.toBlocking().publishWith().topic(topic).qos(MqttQos.AT_MOST_ONCE).payload(jsonPayload.getBytes()).send();