This commit is contained in:
Christian Basler 2017-03-31 17:07:57 +02:00
parent 5849e68d20
commit 016b4f80ba

View File

@ -65,6 +65,11 @@ public class Main {
.port(48444); .port(48444);
if (options.localPort != null) { if (options.localPort != null) {
ctxBuilder.nodeRegistry(new NodeRegistry() { ctxBuilder.nodeRegistry(new NodeRegistry() {
@Override
public void clear() {
// NO OP
}
@Override @Override
public List<NetworkAddress> getKnownAddresses(int limit, long... streams) { public List<NetworkAddress> getKnownAddresses(int limit, long... streams) {
return Arrays.stream(streams) return Arrays.stream(streams)