diff --git a/pom.xml b/pom.xml index 37a8d7dda001326a166969cdb661345018b05c6d..d333ee68bd8d8c0239460ae249c0b277ae1fa874 100644 --- a/pom.xml +++ b/pom.xml @@ -51,7 +51,6 @@ <maven.clean.version>3.1.0</maven.clean.version> <nimbus.jwt.version>8.17</nimbus.jwt.version> <asm.version>8.0</asm.version> - <jeromq.version>0.5.2</jeromq.version> <maven.model.version>3.2.5</maven.model.version> <apache.httpcore.version>4.4.12</apache.httpcore.version> <apache.httpclient.version>4.5.10</apache.httpclient.version> diff --git a/updater/pom.xml b/updater/pom.xml index a4ec92a6eeef1ac631a6422cf13371f9f6ad037c..f057112b0bc75d8abb2a4c1294b7d2851b793e24 100644 --- a/updater/pom.xml +++ b/updater/pom.xml @@ -43,22 +43,6 @@ <artifactId>plexus-utils</artifactId> <version>3.1.0</version> </dependency> - <dependency> - <groupId>org.zeromq</groupId> - <artifactId>jeromq</artifactId> - <version>${jeromq.version}</version> - </dependency> - <dependency> - <groupId>org.zeromq</groupId> - <artifactId>jeromq</artifactId> - <version>0.5.2</version> - </dependency> - <dependency> - <groupId>net.jami</groupId> - <artifactId>jams-common</artifactId> - <version>0.5A</version> - <scope>compile</scope> - </dependency> <dependency> <groupId>net.jami</groupId> <artifactId>jams-common</artifactId> diff --git a/updater/src/main/java/net/jami/jams/updater/MessageReceiver.java b/updater/src/main/java/net/jami/jams/updater/MessageReceiver.java deleted file mode 100644 index e25571d4ba778dd462b716f7229d1d0d945f039b..0000000000000000000000000000000000000000 --- a/updater/src/main/java/net/jami/jams/updater/MessageReceiver.java +++ /dev/null @@ -1,29 +0,0 @@ -package net.jami.jams.updater; - -import org.zeromq.ZMQ; - -import java.util.concurrent.atomic.AtomicBoolean; - -public class MessageReceiver extends Thread { - - private ZMQ.Socket socket; - private AtomicBoolean atomicBoolean; - - public MessageReceiver(ZMQ.Socket socket, AtomicBoolean atomicBoolean) { - this.socket = socket; - this.atomicBoolean = atomicBoolean; - } - - @Override - public void run() { - while(true){ - try{ - String message = socket.recvStr(); - if(message.equals("DO-UPDATE")) atomicBoolean.set(true); - } - catch (Exception e){ - System.out.println("Some exception occurred!"); - } - } - } -}