From f71862b92f3d76251036485c27cf3a6a899635ab Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= Date: Tue, 10 Jan 2012 20:53:20 +0100 Subject: Start implementing SameService. MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Start implementing the controller service for this project. "Same" refers to the shared global state – the state should be the Same in all the participants. Removes PingService. --- .../src/main/java/com/orbekk/same/SameService.java | 6 +++++ .../main/java/com/orbekk/same/SameServiceImpl.java | 31 ++++++++++++++++++++++ 2 files changed, 37 insertions(+) create mode 100644 jsonrpc/src/main/java/com/orbekk/same/SameService.java create mode 100644 jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java (limited to 'jsonrpc/src/main/java/com/orbekk/same') diff --git a/jsonrpc/src/main/java/com/orbekk/same/SameService.java b/jsonrpc/src/main/java/com/orbekk/same/SameService.java new file mode 100644 index 0000000..dccc1e9 --- /dev/null +++ b/jsonrpc/src/main/java/com/orbekk/same/SameService.java @@ -0,0 +1,6 @@ +package com.orbekk.same; + +public interface SameService { + void notifyNetwork(String networkName); + String participateNetwork(String networkName); +} diff --git a/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java b/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java new file mode 100644 index 0000000..56a0fa1 --- /dev/null +++ b/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java @@ -0,0 +1,31 @@ +package com.orbekk.same; + +import java.util.List; +import java.util.LinkedList; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +public class SameServiceImpl implements SameService { + private Logger logger = LoggerFactory.getLogger(getClass()); + private List participants = new LinkedList(); + private String networkName; + + public SameServiceImpl(String networkName) { + this.networkName = networkName; + } + + @Override + public void notifyNetwork(String networkName) { + logger.info("Notification from network " + networkName); + } + + @Override + public String participateNetwork(String networkName) { + logger.info("Got participation request."); + if (networkName != this.networkName) { + logger.info("Network name mismatch."); + } + return ""; + } +} -- cgit v1.2.3