diff options
| author | Anton Tananaev <anton@traccar.org> | 2022-11-13 11:48:43 -0800 |
|---|---|---|
| committer | Anton Tananaev <anton@traccar.org> | 2022-11-13 11:48:43 -0800 |
| commit | 5877cb1b3f1fa7331c4310b9754a3ec442586497 (patch) | |
| tree | 6cc3e7193412aa152c1b593bf0ad7e4119687a1e /src/main/java/org/traccar/database | |
| parent | ff793b2e2872f8ba076e748fab41d944f92b64d4 (diff) | |
| download | trackermap-server-5877cb1b3f1fa7331c4310b9754a3ec442586497.tar.gz trackermap-server-5877cb1b3f1fa7331c4310b9754a3ec442586497.tar.bz2 trackermap-server-5877cb1b3f1fa7331c4310b9754a3ec442586497.zip | |
Refactor position forwarding
Diffstat (limited to 'src/main/java/org/traccar/database')
| -rw-r--r-- | src/main/java/org/traccar/database/NotificationManager.java | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/main/java/org/traccar/database/NotificationManager.java b/src/main/java/org/traccar/database/NotificationManager.java index 7c82454b2..1eec7e097 100644 --- a/src/main/java/org/traccar/database/NotificationManager.java +++ b/src/main/java/org/traccar/database/NotificationManager.java @@ -129,7 +129,11 @@ public class NotificationManager { if (event.getMaintenanceId() != 0) { eventData.setMaintenance(cacheManager.getObject(Maintenance.class, event.getMaintenanceId())); } - eventForwarder.forward(eventData); + eventForwarder.forward(eventData, (success, throwable) -> { + if (!success) { + LOGGER.warn("Event forwarding failed", throwable); + } + }); } } |