diff --git a/UsersREMI~1.HERAppDataLocalTemptmp8h6pg12m b/UsersREMI~1.HERAppDataLocalTemptmp8h6pg12m
new file mode 100644
index 0000000..e69de29
diff --git a/app.cpp b/app.cpp
index 714f481..6c379c1 100644
--- a/app.cpp
+++ b/app.cpp
@@ -1,7 +1,9 @@
 #include "app.h"
 
 App::App() {
-
+    st.connectRequest("sdi.hevs.ch", 61614, "/", "sdi10", "809c02f36becb0868da98761fe3209f6");
+    st.sendRequest("/topic/sdi10.gem.command", "right");
+    st.subscribeRequest("/topic/sdi10.gem.field", 1);
 }
 
 void App::connectConfirmation(bool success, int version) {
@@ -13,7 +15,7 @@ void App::sendConfirmation(bool success) {
 }
 
 void App::subscribeConfirmation(bool success) {
-
+    st.sendRequest("/topic/sdi10.gem.command", "up");
 }
 
 void App::receiveIndication(int id, QString destination, QString body) {
diff --git a/app.h b/app.h
index 2a2759e..b1b81b3 100644
--- a/app.h
+++ b/app.h
@@ -3,6 +3,7 @@
 
 #include <QObject>
 #include "interface/iStompObserver.h"
+#include "stomp.h"
 
 class App : public QObject, public interface::iStompObserver {
 public:
@@ -17,6 +18,9 @@ private:
     void receiveIndication(int id, QString destination, QString body);
     void disconnectConfirmation();
     void disconnectIndication();
+
+private:
+    Stomp st;
 };
 
 #endif // APP_H
diff --git a/main.cpp b/main.cpp
index 85a4c25..228f127 100644
--- a/main.cpp
+++ b/main.cpp
@@ -4,20 +4,12 @@
 
 #include "stompframe.h"
 #include "stomp.h"
+#include "app.h"
 
 int main(int argc, char *argv[]) {
     QApplication application(argc, argv);
 
-    Stomp st;
-    st.connectRequest("sdi.hevs.ch", 61614, "/", "sdi10", "809c02f36becb0868da98761fe3209f6");
-
-    st.sendRequest("/topic/sdi10.gem.command", "right");
-
-    st.sendRequest("/topic/sdi10.gem.command", "up");
-
-    st.sendRequest("/topic/sdi10.gem.command", "left");
-
-    st.sendRequest("/topic/sdi10.gem.command", "down");
+    App app;
 
     return application.exec();
 }
diff --git a/stomp.cpp b/stomp.cpp
index 78f2510..3828592 100644
--- a/stomp.cpp
+++ b/stomp.cpp
@@ -92,7 +92,11 @@ void Stomp::sendRequest(QString destination, const QByteArray& body) {
 }
 
 void Stomp::subscribeRequest(QString destination, int id) {
-
+    QString sid = QString::number(id);
+    STOMPFrame(STOMPFrame::SUBSCRIBE, {
+        {"destination", destination},
+        {"id", sid}
+    }).send(socket_);
 }
 
 void Stomp::disconnectRequest() {