import org.amdatu.remote.discovery.Discovery;
import org.amdatu.remote.discovery.DiscoveryImpl;
public class ServiceProvider {
private Discovery discovery;
public void start() {
discovery = new DiscoveryImpl();
discovery.registerService("myService", 8080);
}
public void stop() {
discovery.unregisterService("myService");
discovery.close();
}
}
import org.amdatu.remote.discovery.Discovery;
import org.amdatu.remote.discovery.DiscoveryImpl;
public class ServiceConsumer {
private Discovery discovery;
public void start() {
discovery = new DiscoveryImpl();
discovery.addDiscoveryListener(new DiscoveryListener() {
@Override
public void serviceAdded(String serviceName, String ipAddress, int port) {
System.out.println("Service added: " + serviceName + " at " + ipAddress + ":" + port);
}
@Override
public void serviceRemoved(String serviceName, String ipAddress, int port) {
System.out.println("Service removed: " + serviceName + " at " + ipAddress + ":" + port);
}
});
discovery.start();
}
public void stop() {
discovery.stop();
discovery.close();
}
}
