paho.mqtt.java
paho.mqtt.java copied to clipboard
Published
20 hours ago •
eclipse
eclipse
Paho (Java) does not specify topic when re-publishing a message due to missing ACK
trafficstars
- [x] Bug exists Release Version 1.2.5 ( Master Branch)
- [ ] Bug exists in MQTTv3 Client on Snapshot Version 1.2.6-SNAPSHOT (Develop Branch)
- [ ] Bug exists in MQTTv5 Client on Snapshot Version 1.2.6-SNAPSHOT (Develop Branch)
Hi! I am using Paho (Java) 1.2.5 as an MQTT client to communicate with Mosquitto 2.0.14 on Ubuntu 20.04.4. I am experiencing an issue when Paho has to re-publish a message due to the lack of an ACK from the broker after having been disconnected. More specifically, when I send a specific MQTT message with QoS 1/2 to the topic related to the DynSec plugin of Mosquitto, the broker disconnects the client without sending an ACK for the message (please refer to this issue for further information on why this happens).
The (potential) issue I would like to report does not involve the fact that Mosquitto disconnects the client without sending an ACK (obviously), but instead it is related to how Paho (Java) handles this situation. In detail, in my scenario:
- Paho connects to Mosquitto with the
cleanStartflag tofalse(to retain the session) andautomaticReconnecttotrue; - Paho publishes a message to the DynSec topic with QoS 1/2, receiving a disconnect packet instead of an ACK (again, this is probably an issue/intended behaviour of Mosquitto, as discussed in the other issue);
- Paho automatically reconnects to Mosquitto;
- Paho tries to re-publish the message (since it did not receive the ACK). However, the message causes Mosquitto to reply with a disconnect packet with reason code 130 (i.e., protocol error).
At this point, it seems that either Paho (Java) or Mosquitto is doing something wrong. However, by investigating the packets flow with Wireshark, I noticed that the re-published message in step 4 by Paho does not include the topic name (i.e., the topic length is 0). Most probably, this is why Mosquitto replies with reason code 130.
I highlight that this problem does not happen with Paho (Python), as the re-published message contains the topic name (as shown in the other issue). Therefore, it seems to be an issue of Paho (Java).
You can find in this .zip file the configuration of Mosquitto and DynSec, the dump of Wireshark packets and a mock Kotlin code of the MQTT client to reproduce the behaviour. For your convenience, I report also below the log of the Mosquitto broker, the mosquitto.conf file content, the dynamic-security.json file content and the Kotlin code.
Thanks in advance! Stefano
The Mosquitto broker log:
- 1647012876: mosquitto version 2.0.14 starting
- 1647012876: Config loaded from /mosquitto/config/mosquitto2.conf.
- 1647012876: Loading plugin: ./usr/lib/mosquitto_dynamic_security.so
- 1647012876: Opening ipv4 listen socket on port 1883.
- 1647012876: Opening ipv6 listen socket on port 1883.
- 1647012876: mosquitto version 2.0.14 running
- 1647012887: New connection from 10.1.0.1:56788 on port 1883.
- 1647012887: New client connected from 10.1.0.1:56788 as randomClientID (p5, c0, k120, u'admin').
- 1647012887: No will message specified.
- 1647012887: Sending CONNACK to randomClientID (0, 0)
- 1647012888: Received PUBLISH from randomClientID (d0, q1, r0, m1, '$CONTROL/dynamic-security/v1', ... (178 bytes))
- 1647012888: dynsec: randomClientID/admin | createRole | rolename=roleName1
- 1647012888: Sending PUBACK to randomClientID (m1, rc0)
- 1647012889: Received PUBLISH from randomClientID (d0, q1, r0, m2, '$CONTROL/dynamic-security/v1', ... (222 bytes))
- 1647012889: Client randomClientID been disconnected by administrative action.
- 1647012889: dynsec: (null)/admin | addClientRole | username=admin | rolename=roleName1 | priority=-1
- 1647012889: Sending PUBACK to null (m2, rc0)
- 1647012889: Client <unknown> disconnected due to out of memory.
- 1647012890: New connection from 10.1.0.1:56790 on port 1883.
- 1647012891: New client connected from 10.1.0.1:56790 as randomClientID (p5, c0, k120, u'admin').
- 1647012891: No will message specified.
- 1647012891: Sending CONNACK to randomClientID (0, 0)
- 1647012891: Client randomClientID disconnected due to protocol error.
The mosquitto.conf file content:
log_type all
per_listener_settings false
# HTTP
listener 1883
plugin ./usr/lib/mosquitto_dynamic_security.so
plugin_opt_config_file /mosquitto/config/dynamic-security.json
persistent_client_expiration 1d
The dynamic-security.json file content:
{
"clients": [{
"username": "admin",
"textName": "Dynsec admin user",
"password": "o5Ves8UtkxWh+ELZ5O8L3BCRe1tHJBE+capQBZfoXpNo6ohyaPxjpPz2wX3VvuJbKZxVDyrGogqGKO++fdayMg==",
"salt": "Rl3CKxTVy8M+63sA",
"iterations": 101,
"roles": [{
"rolename": "admin"
}]
}],
"roles": [{
"rolename": "admin",
"acls": [{
"acltype": "publishClientSend",
"topic": "$CONTROL/#",
"allow": true
}, {
"acltype": "publishClientReceive",
"topic": "$CONTROL/#",
"allow": true
}, {
"acltype": "subscribePattern",
"topic": "$CONTROL/#",
"allow": true
}, {
"acltype": "publishClientReceive",
"topic": "$SYS/#",
"allow": true
}, {
"acltype": "subscribePattern",
"topic": "$SYS/#",
"allow": true
}, {
"acltype": "publishClientSend",
"topic": "#",
"allow": true
}, {
"acltype": "publishClientReceive",
"topic": "#",
"allow": true
}, {
"acltype": "subscribePattern",
"topic": "#",
"allow": true
}, {
"acltype": "unsubscribePattern",
"topic": "#",
"allow": true
}]
}],
"defaultACLAccess": {
"publishClientSend": false,
"publishClientReceive": true,
"subscribe": false,
"unsubscribe": true
}
}
The Java code:
package eu.fbk.st.cryptoac.implementation.dm
import kotlinx.coroutines.delay
import kotlinx.coroutines.runBlocking
import org.eclipse.paho.mqttv5.client.*
import org.eclipse.paho.mqttv5.client.persist.MemoryPersistence
import org.eclipse.paho.mqttv5.common.MqttException
import org.eclipse.paho.mqttv5.common.MqttMessage
import org.eclipse.paho.mqttv5.common.packet.MqttProperties
fun main() {
TestClass().simulateScenario()
}
class TestClass : MqttCallback {
fun simulateScenario() {
/**
* The "dynamic-security.json" file creates a
* user with name "admin" and password "password"
*/
val connOpts = MqttConnectionOptions()
connOpts.isCleanStart = false
connOpts.keepAliveInterval = 120
connOpts.isAutomaticReconnect = true
connOpts.userName = "admin"
connOpts.password = "password".toByteArray()
val client = MqttClient(
"tcp://10.1.0.8:1883",
"randomClientID",
MemoryPersistence()
)
client.connect(connOpts)
client.setCallback(this)
runBlocking { delay(1000) }
/** 1. Create a new role, everything is fine */
val createRole = """
{ "commands": [
{
"command": "createRole",
"rolename": "roleName1"
}
]}
"""
val createRoleMessage = MqttMessage(createRole.toByteArray())
createRoleMessage.qos = 1
client.publish(
"\$CONTROL/dynamic-security/v1",
createRoleMessage
)
runBlocking { delay(1000) }
/** 2. Assign the user admin to the new role => Disconnect 152 */
val assignClientToRole = """
{ "commands": [
{
"command": "addClientRole",
"username": "admin",
"rolename": "roleName1"
}
]}
"""
val assignMessage = MqttMessage(assignClientToRole.toByteArray())
assignMessage.qos = 1
try {
client.publish(
"\$CONTROL/dynamic-security/v1",
assignMessage
)
} catch (e: MqttException) {
if (e.message?.contains("Disconnect RC: 152") == true) {
println("We were disconnected by Administrative action (see below stack trace)")
e.printStackTrace()
println(
"Now the client automatically reconnects and tries to re-publish the second \n" +
"message, as the broker directly sent a disconnect request and not the ACK. \n" +
"However, the client sends a message that triggers a 'Disconnect RC: 130' \n" +
"response from the broker (probably due to the missing topic in the message)"
)
runBlocking { delay(1000) }
} else {
throw e
}
}
}
override fun messageArrived(topic: String, message: MqttMessage) {
println("TEST: MQTT message arrived, topic $topic, payload ${message.payload}")
}
override fun disconnected(disconnectResponse: MqttDisconnectResponse?) {
println("MQTT client was disconnected: ${disconnectResponse.toString()}")
}
override fun authPacketArrived(reasonCode: Int, properties: MqttProperties?) {
println("TEST: authPacketArrived")
}
override fun connectComplete(reconnect: Boolean, serverURI: String?) {
println("TEST: connectComplete")
}
override fun deliveryComplete(token: IMqttToken?) {
println("TEST: deliveryComplete")
}
override fun mqttErrorOccurred(exception: MqttException?) {
println("TEST: mqttErrorOccurred")
}
}
I am also experiencing the same issue with the latest version 1.2.5, mosquitto:2.0.20. The phenomenon is: connection gets disconnected repeatedly.
Log information:
1732469255: New client connected from 172.20.0.1:44968 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469255: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469256: New connection from 172.20.0.1:44972 on port 1884.
1732469257: New client connected from 172.20.0.1:44972 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469257: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469258: New connection from 172.20.0.1:44976 on port 1884.
1732469258: New client connected from 172.20.0.1:44976 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469258: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469259: New connection from 172.20.0.1:44984 on port 1884.
1732469259: New client connected from 172.20.0.1:44984 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469259: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469260: New connection from 172.20.0.1:44988 on port 1884.
1732469261: New client connected from 172.20.0.1:44988 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469261: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469262: New connection from 172.20.0.1:44994 on port 1884.
1732469262: New client connected from 172.20.0.1:44994 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469262: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469263: New connection from 172.20.0.1:44998 on port 1884.
1732469263: New client connected from 172.20.0.1:44998 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469263: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469264: New connection from 172.20.0.1:45002 on port 1884.
1732469265: New client connected from 172.20.0.1:45002 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469265: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469266: New connection from 172.20.0.1:45008 on port 1884.
1732469266: New client connected from 172.20.0.1:45008 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469266: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469267: New connection from 172.20.0.1:45012 on port 1884.
1732469267: New client connected from 172.20.0.1:45012 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469267: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469268: New connection from 172.20.0.1:45016 on port 1884.
1732469269: New client connected from 172.20.0.1:45016 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469269: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469270: New connection from 172.20.0.1:45020 on port 1884.
1732469270: New client connected from 172.20.0.1:45020 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469270: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469271: New connection from 172.20.0.1:45024 on port 1884.
1732469271: New client connected from 172.20.0.1:45024 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469271: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469272: New connection from 172.20.0.1:45030 on port 1884.
1732469273: New client connected from 172.20.0.1:45030 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469273: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469274: New connection from 172.20.0.1:45034 on port 1884.
1732469274: New client connected from 172.20.0.1:45034 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469274: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469275: New connection from 172.20.0.1:45038 on port 1884.
1732469275: New client connected from 172.20.0.1:45038 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469275: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469276: New connection from 172.20.0.1:45042 on port 1884.
1732469277: New client connected from 172.20.0.1:45042 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469277: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469278: New connection from 172.20.0.1:45046 on port 1884.
1732469278: New client connected from 172.20.0.1:45046 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469278: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469279: New connection from 172.20.0.1:45050 on port 1884.
1732469279: New client connected from 172.20.0.1:45050 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469279: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469280: New connection from 172.20.0.1:45076 on port 1884.
1732469281: New client connected from 172.20.0.1:45076 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469281: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469282: New connection from 172.20.0.1:45080 on port 1884.
1732469282: New client connected from 172.20.0.1:45080 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469282: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469283: New connection from 172.20.0.1:45084 on port 1884.
1732469283: New client connected from 172.20.0.1:45084 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469283: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469284: New connection from 172.20.0.1:45090 on port 1884.
1732469285: New client connected from 172.20.0.1:45090 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469285: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469286: New connection from 172.20.0.1:45094 on port 1884.
1732469286: New client connected from 172.20.0.1:45094 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469286: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469287: New connection from 172.20.0.1:45098 on port 1884.
1732469287: New client connected from 172.20.0.1:45098 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469287: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469288: New connection from 172.20.0.1:45102 on port 1884.
1732469289: New client connected from 172.20.0.1:45102 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469289: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469290: New connection from 172.20.0.1:45106 on port 1884.
1732469290: New client connected from 172.20.0.1:45106 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469290: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469291: New connection from 172.20.0.1:45110 on port 1884.
1732469291: New client connected from 172.20.0.1:45110 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469291: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469292: New connection from 172.20.0.1:45114 on port 1884.
1732469293: New client connected from 172.20.0.1:45114 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469293: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469294: New connection from 172.20.0.1:45118 on port 1884.
1732469294: New client connected from 172.20.0.1:45118 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469294: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469295: New connection from 172.20.0.1:45122 on port 1884.
1732469295: New client connected from 172.20.0.1:45122 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469295: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469296: New connection from 172.20.0.1:45126 on port 1884.
1732469297: New client connected from 172.20.0.1:45126 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469297: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469298: New connection from 172.20.0.1:45130 on port 1884.
1732469298: New client connected from 172.20.0.1:45130 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469298: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469299: New connection from 172.20.0.1:45134 on port 1884.
1732469299: New client connected from 172.20.0.1:45134 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469299: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469300: New connection from 172.20.0.1:45138 on port 1884.
1732469301: New client connected from 172.20.0.1:45138 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469301: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469302: New connection from 172.20.0.1:45142 on port 1884.
1732469302: New client connected from 172.20.0.1:45142 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469302: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469303: New connection from 172.20.0.1:45146 on port 1884.
1732469303: New client connected from 172.20.0.1:45146 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469303: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469304: New connection from 172.20.0.1:45150 on port 1884.
1732469308: New client connected from 172.20.0.1:45150 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469308: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469309: New connection from 172.20.0.1:45154 on port 1884.
1732469310: New client connected from 172.20.0.1:45154 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469310: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469311: New connection from 172.20.0.1:45158 on port 1884.
1732469311: New client connected from 172.20.0.1:45158 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469311: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469312: New connection from 172.20.0.1:45164 on port 1884.
1732469312: New client connected from 172.20.0.1:45164 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469312: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469313: New connection from 172.20.0.1:45168 on port 1884.
1732469314: New client connected from 172.20.0.1:45168 as omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 (p5, c0, k30, u'admin').
1732469314: Client omcp_publisher_omcp_hjkq_1105133203_VOC_HJKQ_KQVZ_ZS_SHJ_hjt2121075348927 disconnected due to protocol error.
1732469315: New connection from 172.20.0.1:45172 on port 1884.
