X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/184354ffb71ea643b62c01c8406402ea4f492ac1..860ec6f5dcda56b55e0e756e862c8c55865ccd19:/src/main/java/org/asamk/signal/DbusReceiveMessageHandler.java

diff --git a/src/main/java/org/asamk/signal/DbusReceiveMessageHandler.java b/src/main/java/org/asamk/signal/DbusReceiveMessageHandler.java
new file mode 100644
index 00000000..2ea51e2e
--- /dev/null
+++ b/src/main/java/org/asamk/signal/DbusReceiveMessageHandler.java
@@ -0,0 +1,25 @@
+package org.asamk.signal;
+
+import org.asamk.signal.manager.Manager;
+import org.freedesktop.dbus.DBusConnection;
+import org.whispersystems.signalservice.api.messages.SignalServiceContent;
+import org.whispersystems.signalservice.api.messages.SignalServiceEnvelope;
+
+class DbusReceiveMessageHandler extends ReceiveMessageHandler {
+
+    private final DBusConnection conn;
+    private final String objectPath;
+
+    DbusReceiveMessageHandler(Manager m, DBusConnection conn, final String objectPath) {
+        super(m);
+        this.conn = conn;
+        this.objectPath = objectPath;
+    }
+
+    @Override
+    public void handleMessage(SignalServiceEnvelope envelope, SignalServiceContent content, Throwable exception) {
+        super.handleMessage(envelope, content, exception);
+
+        JsonDbusReceiveMessageHandler.sendReceivedMessageToDbus(envelope, content, conn, objectPath, m);
+    }
+}