patch: update publishing for schedules topic replace

OpenSrcerer · Mar 21, 2024 · 18936f3 · 18936f3
1 parent 1bfc3a6
commit 18936f3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/kotlin/online/danielstefani/paddy/mqtt/RxMqttClient.kt b/src/main/kotlin/online/danielstefani/paddy/mqtt/RxMqttClient.kt
@@ -54,7 +54,7 @@ class RxMqttClient(
 
  fun publish(scheduleId: String): Flowable<Mqtt5PublishResult>? {
  val topic = mqttConfig.schedulerEvents()
- .replace("\$share/backend-cluster/", "")
+ .replace("\$share/scheduler-cluster/", "")
  .replace("+", scheduleId)
 
  return publish(topic, "", MqttQos.EXACTLY_ONCE)