Fehlerkorrekturen
This commit is contained in:
1 parent
c1ffecbe44
commit
4eef0fa119
9 files changed
+47
-17
No files matched your search
@@ -283,7 +283,11 @@ class MqttCore {
|
||||
}
|
||||
}
|
||||
|
||||
MessageService().publish<JobReceivedMessage>(Constants.messageTopicJobReceived, arguments: JobReceivedMessage(job: newJob));
|
||||
try {
|
||||
MessageService().publish<JobReceivedMessage>(Constants.messageTopicJobReceived, arguments: JobReceivedMessage(job: newJob));
|
||||
} catch (ex) {
|
||||
Util.logException("publish messageTopicJobReceived failed!");
|
||||
}
|
||||
|
||||
_acknowlegdeJob(newJob);
|
||||
}
|
||||
|
||||
Reference in new issue
Block a user