testcontainers#291 change order

bsideup · Feb 21, 2017 · df7049e · df7049e
1 parent da2a82b
commit df7049e
Showing 1 changed file with 9 additions and 8 deletions.
diff --git a/.../src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java b/.../src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java
@@ -90,25 +90,26 @@ InetSocketAddress start() throws IOException {
                             executorService.submit(() -> {
                                 try (RandomAccessFile randomAccessFile = new RandomAccessFile(file, "rw")) {
                                     log.info("Created RandomAccessFile from " + file);
-                                    Future<Long> inputFuture = executorService.submit(() -> {
+
+                                    Future<Long> outputFuture = executorService.submit(() -> {
                                         try (
-                                                InputStream in = incomingSocket.getInputStream();
-                                                FileOutputStream out = new FileOutputStream(randomAccessFile.getFD())
+                                                FileInputStream in = new FileInputStream(randomAccessFile.getFD());
+                                                OutputStream out = incomingSocket.getOutputStream()
                                         ) {
-                                            log.info("Redirecting input");
+                                            log.info("Redirecting output");
                                             return ByteStreams.copy(in, out);
                                         } catch (Exception e) {
                                             log.warn("", e);
                                             return null;
                                         }
                                     });
 
-                                    Future<Long> outputFuture = executorService.submit(() -> {
+                                    Future<Long> inputFuture = executorService.submit(() -> {
                                         try (
-                                                FileInputStream in = new FileInputStream(randomAccessFile.getFD());
-                                                OutputStream out = incomingSocket.getOutputStream()
+                                                InputStream in = incomingSocket.getInputStream();
+                                                FileOutputStream out = new FileOutputStream(randomAccessFile.getFD())
                                         ) {
-                                            log.info("Redirecting output");
+                                            log.info("Redirecting input");
                                             return ByteStreams.copy(in, out);
                                         } catch (Exception e) {
                                             log.warn("", e);