aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/org/traccar/notificators/Notificator.java
diff options
context:
space:
mode:
authorAnton Tananaev <anton@traccar.org>2022-06-07 07:07:25 -0700
committerAnton Tananaev <anton@traccar.org>2022-06-07 07:07:25 -0700
commit65f9e253171dc6805127e5279b97fad05f8c4b9f (patch)
treefc3968d7c5c5c07118d4e153ece5af31371e90a5 /src/main/java/org/traccar/notificators/Notificator.java
parent8eecfdcf5c59f92158a6c339d1622e0e9d67968c (diff)
downloadtrackermap-server-65f9e253171dc6805127e5279b97fad05f8c4b9f.tar.gz
trackermap-server-65f9e253171dc6805127e5279b97fad05f8c4b9f.tar.bz2
trackermap-server-65f9e253171dc6805127e5279b97fad05f8c4b9f.zip
Remove async methods
Diffstat (limited to 'src/main/java/org/traccar/notificators/Notificator.java')
-rw-r--r--src/main/java/org/traccar/notificators/Notificator.java19
1 files changed, 2 insertions, 17 deletions
diff --git a/src/main/java/org/traccar/notificators/Notificator.java b/src/main/java/org/traccar/notificators/Notificator.java
index 3903f3008..052365c7a 100644
--- a/src/main/java/org/traccar/notificators/Notificator.java
+++ b/src/main/java/org/traccar/notificators/Notificator.java
@@ -16,28 +16,13 @@
*/
package org.traccar.notificators;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
import org.traccar.model.Event;
import org.traccar.model.Position;
import org.traccar.model.User;
import org.traccar.notification.MessageException;
-public abstract class Notificator {
+public interface Notificator {
- private static final Logger LOGGER = LoggerFactory.getLogger(Notificator.class);
-
- public void sendAsync(User user, Event event, Position position) {
- new Thread(() -> {
- try {
- sendSync(user, event, position);
- } catch (MessageException | InterruptedException error) {
- LOGGER.warn("Event send error", error);
- }
- }).start();
- }
-
- public abstract void sendSync(User user, Event event, Position position)
- throws MessageException, InterruptedException;
+ void send(User user, Event event, Position position) throws MessageException, InterruptedException;
}