import ch.qos.logback.classic.Level;
import ch.qos.logback.classic.LoggerContext;
-import com.google.common.base.Preconditions;
import com.google.common.base.Predicate;
import com.google.common.collect.Iterables;
import com.google.common.net.InetAddresses;
private static final int RECONNECT_STRATEGY_TIMEOUT = 2000;
public static void main(String[] args) throws InterruptedException, ExecutionException, UnknownHostException {
-
- if (args.length < 2) {
- LOG.error("Insufficient number of arguments {}.", args.length);
- return;
- }
-
InetAddress localAddress = InetAddress.getByName("127.0.0.1");
- InetAddress remoteAddress = null;
+ InetAddress remoteAddress = InetAddress.getByName("127.0.0.1");
int pccCount = 1;
int lsps = 1;
boolean pcError = false;
}
argIdx++;
}
- Preconditions.checkState(remoteAddress != null, "Missing mandatory remote-address parameter.");
createPCCs(lsps, pcError, pccCount, localAddress, remoteAddress);
}
private final InetAddress address;
public SimpleSessionListener(final int lspsCount, final boolean pcError, final InetAddress address) {
- Preconditions.checkArgument(lspsCount > 0);
+ Preconditions.checkArgument(lspsCount >= 0);
this.lspsCount = lspsCount;
this.pcError = pcError;
this.address = address;