From 85453d881ff4980d3809c44a34218a08cfb1c243 Mon Sep 17 00:00:00 2001
From: Joel Cavat <jcavat@gmail.com>
Date: Mon, 17 Dec 2018 16:00:43 +0100
Subject: [PATCH] Change Server name to Broker
---
pom.xml | 4 +--
.../java/ch/hepia/communication/Server.java | 34 -------------------
2 files changed, 2 insertions(+), 36 deletions(-)
delete mode 100644 src/main/java/ch/hepia/communication/Server.java
diff --git a/pom.xml b/pom.xml
index 7f9ef48..120f57f 100644
--- a/pom.xml
+++ b/pom.xml
@@ -39,12 +39,12 @@
<version>1.6.0</version>
<executions>
<execution>
- <id>server</id>
+ <id>broker</id>
<goals>
<goal>java</goal>
</goals>
<configuration>
- <mainClass>ch.hepia.communication.Server</mainClass>
+ <mainClass>ch.hepia.communication.Broker</mainClass>
</configuration>
</execution>
<execution>
diff --git a/src/main/java/ch/hepia/communication/Server.java b/src/main/java/ch/hepia/communication/Server.java
deleted file mode 100644
index 16a93c0..0000000
--- a/src/main/java/ch/hepia/communication/Server.java
+++ /dev/null
@@ -1,34 +0,0 @@
-package ch.hepia.communication;
-
-import javax.jms.Connection;
-
-import org.apache.activemq.ActiveMQConnectionFactory;
-import org.apache.activemq.broker.BrokerService;
-
-public class Server {
-
- public Server(String ipBroker) {
- try {
- final String brokerUrl = "tcp://" + ipBroker + ":61616";
- final BrokerService broker = new BrokerService();
-
- broker.setPersistent(false);
- broker.setUseJmx(false);
- broker.addConnector(brokerUrl);
- broker.start();
-
- final ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerUrl);
- final Connection connection = connectionFactory.createConnection();
- connection.start();
-
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
-
- public static void main(String[] args) {
- System.out.println(args[0]);
-
- new Server( args.length == 1 ? args[0] : "localhost");
- }
-}
--
GitLab