+ @Test(expected = ExecutionException.class)
+ public void defaultFcpClientThrowsExceptionIfItCanNotConnect()
+ throws IOException, ExecutionException, InterruptedException {
+ Logger.getAnonymousLogger().getParent().setLevel(Level.FINEST);
+ Logger.getAnonymousLogger().getParent().getHandlers()[0].setLevel(Level.FINEST);
+ Future<FcpKeyPair> keyPairFuture = fcpClient.generateKeypair().execute();
+ fcpServer.connect().get();
+ fcpServer.collectUntil(is("EndMessage"));
+ fcpServer.writeLine(
+ "CloseConnectionDuplicateClientName",
+ "EndMessage"
+ );
+ keyPairFuture.get();
+ }
+