camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject [08/11] CAMEL-7834 Fixed the CS error of camel-docker
Date Wed, 22 Oct 2014 09:45:20 GMT
http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/main/java/org/apache/camel/component/docker/producer/DockerProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/main/java/org/apache/camel/component/docker/producer/DockerProducer.java b/components/camel-docker/src/main/java/org/apache/camel/component/docker/producer/DockerProducer.java
index e0d2c07..e63c073 100644
--- a/components/camel-docker/src/main/java/org/apache/camel/component/docker/producer/DockerProducer.java
+++ b/components/camel-docker/src/main/java/org/apache/camel/component/docker/producer/DockerProducer.java
@@ -16,6 +16,9 @@
  */
 package org.apache.camel.component.docker.producer;
 
+import java.io.File;
+import java.io.InputStream;
+
 import com.github.dockerjava.api.DockerClient;
 import com.github.dockerjava.api.command.AttachContainerCmd;
 import com.github.dockerjava.api.command.AuthCmd;
@@ -60,9 +63,6 @@ import com.github.dockerjava.api.model.RestartPolicy;
 import com.github.dockerjava.api.model.Volume;
 import com.github.dockerjava.api.model.Volumes;
 
-import java.io.File;
-import java.io.InputStream;
-
 import org.apache.camel.Exchange;
 import org.apache.camel.Message;
 import org.apache.camel.component.docker.DockerClientFactory;
@@ -97,106 +97,106 @@ public class DockerProducer extends DefaultProducer {
         
         DockerOperation operation = configuration.getOperation();
         
-        switch(operation) {
-        
-            case AUTH:
-                dockerCmd = executeAuthRequest(client,message);
-                break;
-            case INFO:
-                dockerCmd = executeInfoRequest(client,message);
-                break;
-            case LIST_IMAGES:
-                dockerCmd = executeListImagesRequest(client,message);
-                break;
-            case PING:
-                dockerCmd = executePingRequest(client,message);
-                break;
-            case VERSION:
-                dockerCmd = executeVersionRequest(client,message);
-                break;
-            case PULL_IMAGE:
-                dockerCmd = executePullImageRequest(client,message);
-                break;
-            case PUSH_IMAGE:
-                dockerCmd = executePushImageRequest(client,message);
-                break;
-            case CREATE_IMAGE:
-                dockerCmd = executeCreateImageRequest(client,message);
-                break;
-            case SEARCH_IMAGES:
-                dockerCmd = executeSearchImageRequest(client,message);
-                break;
-            case REMOVE_IMAGE:
-                dockerCmd = executeRemoveImageRequest(client,message);
-                break;
-            case INSPECT_IMAGE:
-                dockerCmd = executeInspectImageRequest(client,message);
-                break;
-            case LIST_CONTAINERS:
-                dockerCmd = executeListContainersRequest(client,message);
-                break;
-            case REMOVE_CONTAINER:
-                dockerCmd = executeRemoveContainerRequest(client,message);
-                break;
-            case INSPECT_CONTAINER:
-                dockerCmd = executeInspectContainerRequest(client,message);
-                break;
-            case WAIT_CONTAINER:
-                dockerCmd = executeWaitContainerRequest(client,message);
-                break;
-            case ATTACH_CONTAINER:
-                dockerCmd = executeAttachContainerRequest(client,message);
-                break;   
-            case LOG_CONTAINER:
-                dockerCmd = executeLogContainerRequest(client,message);
-                break;
-            case CONTAINER_COPY_FILE:
-                dockerCmd = executeCopyFileContainerRequest(client,message);
-                break; 
-            case DIFF_CONTAINER:
-                dockerCmd = executeDiffContainerRequest(client,message);
-                break; 
-            case STOP_CONTAINER:
-                dockerCmd = executeStopContainerRequest(client,message);
-                break; 
-            case KILL_CONTAINER:
-                dockerCmd = executeKillContainerRequest(client,message);
-                break; 
-            case RESTART_CONTAINER:
-                dockerCmd = executeRestartContainerRequest(client,message);
-                break; 
-            case TOP_CONTAINER:
-                dockerCmd = executeTopContainerRequest(client,message);
-                break; 
-            case TAG_IMAGE:
-                dockerCmd = executeTagImageRequest(client,message);
-                break;
-            case PAUSE_CONTAINER:
-                dockerCmd = executePauseContainerRequest(client,message);
-                break;
-            case UNPAUSE_CONTAINER:
-                dockerCmd = executeUnpauseContainerRequest(client,message);
-                break;
-            case BUILD_IMAGE:
-                dockerCmd = executeBuildImageRequest(client,message);
-                break;
-            case COMMIT_CONTAINER:
-                dockerCmd = executeCommitContainerRequest(client,message);
-                break;
-            case CREATE_CONTAINER:
-                dockerCmd = executeCreateContainerRequest(client,message);
-                break;
-            case START_CONTAINER:
-                dockerCmd = executeStartContainerRequest(client,message);
-                break;
-            default:
-               throw new DockerException("Invalid operation: " + operation);
+        switch (operation) {
+
+        case AUTH:
+            dockerCmd = executeAuthRequest(client, message);
+            break;
+        case INFO:
+            dockerCmd = executeInfoRequest(client, message);
+            break;
+        case LIST_IMAGES:
+            dockerCmd = executeListImagesRequest(client, message);
+            break;
+        case PING:
+            dockerCmd = executePingRequest(client, message);
+            break;
+        case VERSION:
+            dockerCmd = executeVersionRequest(client, message);
+            break;
+        case PULL_IMAGE:
+            dockerCmd = executePullImageRequest(client, message);
+            break;
+        case PUSH_IMAGE:
+            dockerCmd = executePushImageRequest(client, message);
+            break;
+        case CREATE_IMAGE:
+            dockerCmd = executeCreateImageRequest(client, message);
+            break;
+        case SEARCH_IMAGES:
+            dockerCmd = executeSearchImageRequest(client, message);
+            break;
+        case REMOVE_IMAGE:
+            dockerCmd = executeRemoveImageRequest(client, message);
+            break;
+        case INSPECT_IMAGE:
+            dockerCmd = executeInspectImageRequest(client, message);
+            break;
+        case LIST_CONTAINERS:
+            dockerCmd = executeListContainersRequest(client, message);
+            break;
+        case REMOVE_CONTAINER:
+            dockerCmd = executeRemoveContainerRequest(client, message);
+            break;
+        case INSPECT_CONTAINER:
+            dockerCmd = executeInspectContainerRequest(client, message);
+            break;
+        case WAIT_CONTAINER:
+            dockerCmd = executeWaitContainerRequest(client, message);
+            break;
+        case ATTACH_CONTAINER:
+            dockerCmd = executeAttachContainerRequest(client, message);
+            break;
+        case LOG_CONTAINER:
+            dockerCmd = executeLogContainerRequest(client, message);
+            break;
+        case CONTAINER_COPY_FILE:
+            dockerCmd = executeCopyFileContainerRequest(client, message);
+            break;
+        case DIFF_CONTAINER:
+            dockerCmd = executeDiffContainerRequest(client, message);
+            break;
+        case STOP_CONTAINER:
+            dockerCmd = executeStopContainerRequest(client, message);
+            break;
+        case KILL_CONTAINER:
+            dockerCmd = executeKillContainerRequest(client, message);
+            break;
+        case RESTART_CONTAINER:
+            dockerCmd = executeRestartContainerRequest(client, message);
+            break;
+        case TOP_CONTAINER:
+            dockerCmd = executeTopContainerRequest(client, message);
+            break;
+        case TAG_IMAGE:
+            dockerCmd = executeTagImageRequest(client, message);
+            break;
+        case PAUSE_CONTAINER:
+            dockerCmd = executePauseContainerRequest(client, message);
+            break;
+        case UNPAUSE_CONTAINER:
+            dockerCmd = executeUnpauseContainerRequest(client, message);
+            break;
+        case BUILD_IMAGE:
+            dockerCmd = executeBuildImageRequest(client, message);
+            break;
+        case COMMIT_CONTAINER:
+            dockerCmd = executeCommitContainerRequest(client, message);
+            break;
+        case CREATE_CONTAINER:
+            dockerCmd = executeCreateContainerRequest(client, message);
+            break;
+        case START_CONTAINER:
+            dockerCmd = executeStartContainerRequest(client, message);
+            break;
+        default:
+            throw new DockerException("Invalid operation: " + operation);
         }
         
         Object result = dockerCmd.exec();
         
         // If request included a response, set as body
-        if(result != null) {
+        if (result != null) {
             exchange.getIn().setBody(result);
         }
     
@@ -296,15 +296,15 @@ public class DockerProducer extends DefaultProducer {
         
         ListImagesCmd listImagesCmd = client.listImagesCmd();
         
-        String filter = DockerHelper.getProperty(DockerConstants.DOCKER_FILTER,configuration, message, String.class);
+        String filter = DockerHelper.getProperty(DockerConstants.DOCKER_FILTER, configuration, message, String.class);
         
-        if(filter != null) {
+        if (filter != null) {
             listImagesCmd.withFilter(filter);
         }
         
-        Boolean showAll = DockerHelper.getProperty(DockerConstants.DOCKER_SHOW_ALL,configuration, message, Boolean.class);
+        Boolean showAll = DockerHelper.getProperty(DockerConstants.DOCKER_SHOW_ALL, configuration, message, Boolean.class);
         
-        if(showAll != null && showAll) {
+        if (showAll != null && showAll) {
             listImagesCmd.withShowAll(showAll);
         }
 
@@ -350,37 +350,35 @@ public class DockerProducer extends DefaultProducer {
         
         BuildImageCmd buildImageCmd;
         
-        if(body != null && body instanceof InputStream) {
+        if (body != null && body instanceof InputStream) {
             buildImageCmd = client.buildImageCmd((InputStream) body);
-        }
-        else if (body != null && body instanceof File) {
+        } else if (body != null && body instanceof File) {
             buildImageCmd = client.buildImageCmd((File) body);
-        }
-        else {
+        } else {
             throw new DockerException("Unable to location source Image");
         }
     
-        Boolean noCache = DockerHelper.getProperty(DockerConstants.DOCKER_NO_CACHE,configuration, message, Boolean.class);
+        Boolean noCache = DockerHelper.getProperty(DockerConstants.DOCKER_NO_CACHE, configuration, message, Boolean.class);
 
-        if(noCache != null && noCache) {
+        if (noCache != null && noCache) {
             buildImageCmd.withNoCache();
         }
         
-        Boolean quiet = DockerHelper.getProperty(DockerConstants.DOCKER_QUIET,configuration, message, Boolean.class);
+        Boolean quiet = DockerHelper.getProperty(DockerConstants.DOCKER_QUIET, configuration, message, Boolean.class);
 
-        if(quiet != null && quiet) {
+        if (quiet != null && quiet) {
             buildImageCmd.withQuiet();
         }
         
-        Boolean remove = DockerHelper.getProperty(DockerConstants.DOCKER_REMOVE,configuration, message, Boolean.class);
+        Boolean remove = DockerHelper.getProperty(DockerConstants.DOCKER_REMOVE, configuration, message, Boolean.class);
 
-        if(remove != null && remove) {
+        if (remove != null && remove) {
             buildImageCmd.withRemove();
         }
         
-        String tag = DockerHelper.getProperty(DockerConstants.DOCKER_TAG,configuration, message, String.class);
+        String tag = DockerHelper.getProperty(DockerConstants.DOCKER_TAG, configuration, message, String.class);
 
-        if(tag != null) {
+        if (tag != null) {
             buildImageCmd.withTag(tag);
         }
         
@@ -406,12 +404,12 @@ public class DockerProducer extends DefaultProducer {
         PullImageCmd pullImageCmd = client.pullImageCmd(repository);
         
         String registry = DockerHelper.getProperty(DockerConstants.DOCKER_REGISTRY, configuration, message, String.class);
-        if(registry != null) {
+        if (registry != null) {
             pullImageCmd.withRegistry(registry);
         }
         
         String tag = DockerHelper.getProperty(DockerConstants.DOCKER_TAG, configuration, message, String.class);
-        if(tag != null) {
+        if (tag != null) {
             pullImageCmd.withTag(tag);
         }
         
@@ -437,7 +435,7 @@ public class DockerProducer extends DefaultProducer {
    
         AuthConfig authConfig = getAuthConfig(client);
     
-        if(authConfig != null) {
+        if (authConfig != null) {
             pushImageCmd.withAuthConfig(authConfig);
         }
         
@@ -485,13 +483,13 @@ public class DockerProducer extends DefaultProducer {
         
         Boolean force = DockerHelper.getProperty(DockerConstants.DOCKER_FORCE, configuration, message, Boolean.class);
         
-        if(force != null && force) {
+        if (force != null && force) {
             removeImagesCmd.withForce();
         }
         
         Boolean prune = DockerHelper.getProperty(DockerConstants.DOCKER_NO_PRUNE, configuration, message, Boolean.class);
         
-        if(prune != null && prune) {
+        if (prune != null && prune) {
             removeImagesCmd.withNoPrune();
         }
         
@@ -511,17 +509,17 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker Tag Image Request");
         
-        String imageId = DockerHelper.getProperty(DockerConstants.DOCKER_IMAGE_ID,configuration, message, String.class);
+        String imageId = DockerHelper.getProperty(DockerConstants.DOCKER_IMAGE_ID, configuration, message, String.class);
         
-        String repository = DockerHelper.getProperty(DockerConstants.DOCKER_REPOSITORY,configuration, message, String.class);
+        String repository = DockerHelper.getProperty(DockerConstants.DOCKER_REPOSITORY, configuration, message, String.class);
    
-        String tag = DockerHelper.getProperty(DockerConstants.DOCKER_TAG,configuration, message, String.class);
+        String tag = DockerHelper.getProperty(DockerConstants.DOCKER_TAG, configuration, message, String.class);
        
         TagImageCmd tagImageCmd = client.tagImageCmd(imageId, repository, tag);
 
-        Boolean force = DockerHelper.getProperty(DockerConstants.DOCKER_FORCE,configuration, message, Boolean.class);
+        Boolean force = DockerHelper.getProperty(DockerConstants.DOCKER_FORCE, configuration, message, Boolean.class);
         
-        if(force != null && force) {
+        if (force != null && force) {
             tagImageCmd.withForce();
         }
              
@@ -542,7 +540,7 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker Inspect Image Request");
 
-        String imageId = DockerHelper.getProperty(DockerConstants.DOCKER_IMAGE_ID,configuration, message, String.class);
+        String imageId = DockerHelper.getProperty(DockerConstants.DOCKER_IMAGE_ID, configuration, message, String.class);
         
         InspectImageCmd inspectImageCmd = client.inspectImageCmd(imageId);
         
@@ -570,27 +568,27 @@ public class DockerProducer extends DefaultProducer {
         ListContainersCmd listContainersCmd = client.listContainersCmd();
  
         Boolean showSize = DockerHelper.getProperty(DockerConstants.DOCKER_SHOW_SIZE, configuration, message, Boolean.class);
-        if(showSize != null && showSize) {
+        if (showSize != null && showSize) {
             listContainersCmd.withShowSize(showSize);
         }
         
         Boolean showAll = DockerHelper.getProperty(DockerConstants.DOCKER_SHOW_ALL, configuration, message, Boolean.class);
-        if(showAll != null && showAll) {
+        if (showAll != null && showAll) {
             listContainersCmd.withShowAll(showAll);
         }
        
         String before = DockerHelper.getProperty(DockerConstants.DOCKER_BEFORE, configuration, message, String.class);
-        if(before != null) {
+        if (before != null) {
             listContainersCmd.withBefore(before);
         }
         
         Integer limit = DockerHelper.getProperty(DockerConstants.DOCKER_LIMIT, configuration, message, Integer.class);
-        if(limit != null) {
+        if (limit != null) {
             listContainersCmd.withLimit(limit);
         }
         
         String since = DockerHelper.getProperty(DockerConstants.DOCKER_SINCE, configuration, message, String.class);
-        if(since != null) {
+        if (since != null) {
             listContainersCmd.withSince(since);
         }
 
@@ -610,139 +608,139 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker List Container Request");
         
-        String imageId = DockerHelper.getProperty(DockerConstants.DOCKER_IMAGE_ID,configuration, message, String.class);
+        String imageId = DockerHelper.getProperty(DockerConstants.DOCKER_IMAGE_ID, configuration, message, String.class);
         
         CreateContainerCmd createContainerCmd = client.createContainerCmd(imageId);
         
-        String name = DockerHelper.getProperty(DockerConstants.DOCKER_NAME,configuration, message, String.class);
+        String name = DockerHelper.getProperty(DockerConstants.DOCKER_NAME, configuration, message, String.class);
 
-        if(name != null) {
+        if (name != null) {
             createContainerCmd.withName(name);
         }
 
         ExposedPort[] exposedPorts = DockerHelper.getArrayProperty(DockerConstants.DOCKER_EXPOSED_PORTS, message, ExposedPort.class);
 
-        if(exposedPorts != null) {
+        if (exposedPorts != null) {
             createContainerCmd.withExposedPorts(exposedPorts);
         }
         
-        String workingDir = DockerHelper.getProperty(DockerConstants.DOCKER_WORKING_DIR,configuration, message, String.class);
+        String workingDir = DockerHelper.getProperty(DockerConstants.DOCKER_WORKING_DIR, configuration, message, String.class);
 
-        if(workingDir != null) {
+        if (workingDir != null) {
             createContainerCmd.withWorkingDir(workingDir);
         }  
         
-        Boolean disabledNetwork = DockerHelper.getProperty(DockerConstants.DOCKER_DISABLE_NETWORK,configuration, message, Boolean.class);
+        Boolean disabledNetwork = DockerHelper.getProperty(DockerConstants.DOCKER_DISABLE_NETWORK, configuration, message, Boolean.class);
 
-        if(disabledNetwork != null && disabledNetwork) {
+        if (disabledNetwork != null && disabledNetwork) {
             createContainerCmd.withDisableNetwork(disabledNetwork);
         }
         
-        String hostName = DockerHelper.getProperty(DockerConstants.DOCKER_HOSTNAME,configuration, message, String.class);
+        String hostName = DockerHelper.getProperty(DockerConstants.DOCKER_HOSTNAME, configuration, message, String.class);
 
-        if(hostName != null) {
+        if (hostName != null) {
             createContainerCmd.withHostName(hostName);
         }  
         
         String[] portSpecs = DockerHelper.parseDelimitedStringHeader(DockerConstants.DOCKER_PORT_SPECS, message);
 
-        if(portSpecs != null) {
+        if (portSpecs != null) {
             createContainerCmd.withPortSpecs(portSpecs);
         }
         
-        String user = DockerHelper.getProperty(DockerConstants.DOCKER_USER,configuration, message, String.class);
+        String user = DockerHelper.getProperty(DockerConstants.DOCKER_USER, configuration, message, String.class);
 
-        if(hostName != null) {
+        if (hostName != null) {
             createContainerCmd.withUser(user);
         }  
         
-        Boolean tty = DockerHelper.getProperty(DockerConstants.DOCKER_TTY,configuration, message, Boolean.class);
+        Boolean tty = DockerHelper.getProperty(DockerConstants.DOCKER_TTY, configuration, message, Boolean.class);
 
-        if(tty != null && tty) {
+        if (tty != null && tty) {
             createContainerCmd.withTty(tty);
         }
         
-        Boolean stdInOpen = DockerHelper.getProperty(DockerConstants.DOCKER_STD_IN_OPEN,configuration, message, Boolean.class);
+        Boolean stdInOpen = DockerHelper.getProperty(DockerConstants.DOCKER_STD_IN_OPEN, configuration, message, Boolean.class);
 
-        if(stdInOpen != null && stdInOpen) {
+        if (stdInOpen != null && stdInOpen) {
             createContainerCmd.withStdinOpen(stdInOpen);
         }
         
-        Boolean stdInOnce = DockerHelper.getProperty(DockerConstants.DOCKER_STD_IN_ONCE,configuration, message, Boolean.class);
+        Boolean stdInOnce = DockerHelper.getProperty(DockerConstants.DOCKER_STD_IN_ONCE, configuration, message, Boolean.class);
 
-        if(stdInOnce != null && stdInOnce) {
+        if (stdInOnce != null && stdInOnce) {
             createContainerCmd.withStdInOnce(stdInOnce);
         }
         
-        Long memoryLimit = DockerHelper.getProperty(DockerConstants.DOCKER_MEMORY_LIMIT,configuration, message, Long.class);
+        Long memoryLimit = DockerHelper.getProperty(DockerConstants.DOCKER_MEMORY_LIMIT, configuration, message, Long.class);
 
-        if(memoryLimit != null) {
+        if (memoryLimit != null) {
             createContainerCmd.withMemoryLimit(memoryLimit);
         }
 
-        Long memorySwap = DockerHelper.getProperty(DockerConstants.DOCKER_MEMORY_SWAP,configuration, message, Long.class);
+        Long memorySwap = DockerHelper.getProperty(DockerConstants.DOCKER_MEMORY_SWAP, configuration, message, Long.class);
 
-        if(memorySwap != null) {
+        if (memorySwap != null) {
             createContainerCmd.withMemorySwap(memorySwap);
         }
         
-        Integer cpuShares = DockerHelper.getProperty(DockerConstants.DOCKER_CPU_SHARES,configuration, message, Integer.class);
+        Integer cpuShares = DockerHelper.getProperty(DockerConstants.DOCKER_CPU_SHARES, configuration, message, Integer.class);
 
-        if(cpuShares != null) {
+        if (cpuShares != null) {
             createContainerCmd.withCpuShares(cpuShares);
         }
         
-        Boolean attachStdIn = DockerHelper.getProperty(DockerConstants.DOCKER_ATTACH_STD_IN,configuration, message, Boolean.class);
+        Boolean attachStdIn = DockerHelper.getProperty(DockerConstants.DOCKER_ATTACH_STD_IN, configuration, message, Boolean.class);
 
-        if(attachStdIn != null && attachStdIn) {
+        if (attachStdIn != null && attachStdIn) {
             createContainerCmd.withAttachStdin(attachStdIn);
         }
   
-        Boolean attachStdOut = DockerHelper.getProperty(DockerConstants.DOCKER_ATTACH_STD_OUT,configuration, message, Boolean.class);
+        Boolean attachStdOut = DockerHelper.getProperty(DockerConstants.DOCKER_ATTACH_STD_OUT, configuration, message, Boolean.class);
 
-        if(attachStdOut != null && attachStdOut) {
+        if (attachStdOut != null && attachStdOut) {
             createContainerCmd.withAttachStdout(attachStdOut);
         }
         
-        Boolean attachStdErr = DockerHelper.getProperty(DockerConstants.DOCKER_ATTACH_STD_ERR,configuration, message, Boolean.class);
+        Boolean attachStdErr = DockerHelper.getProperty(DockerConstants.DOCKER_ATTACH_STD_ERR, configuration, message, Boolean.class);
 
-        if(attachStdErr != null && attachStdErr) {
+        if (attachStdErr != null && attachStdErr) {
             createContainerCmd.withAttachStderr(attachStdErr);
         }
         
         String[] env = DockerHelper.parseDelimitedStringHeader(DockerConstants.DOCKER_ENV, message);
 
-        if(env != null) {
+        if (env != null) {
             createContainerCmd.withEnv(env);
         }
         
         String[] cmd = DockerHelper.parseDelimitedStringHeader(DockerConstants.DOCKER_CMD, message);
 
-        if(cmd != null) {
+        if (cmd != null) {
             createContainerCmd.withCmd(env);
         }
         
         String[] dns = DockerHelper.parseDelimitedStringHeader(DockerConstants.DOCKER_DNS, message);
 
-        if(dns != null) {
+        if (dns != null) {
             createContainerCmd.withDns(dns);
         }
         
-        String image = DockerHelper.getProperty(DockerConstants.DOCKER_IMAGE,configuration, message, String.class);
+        String image = DockerHelper.getProperty(DockerConstants.DOCKER_IMAGE, configuration, message, String.class);
 
-        if(image != null) {
+        if (image != null) {
             createContainerCmd.withImage(image);
         }
         
         Volume[] volume = DockerHelper.getArrayProperty(DockerConstants.DOCKER_VOLUMES, message, Volume.class);
 
-        if(volume != null) {
+        if (volume != null) {
             createContainerCmd.withVolumes(volume);
         }
         
         String[] volumesFrom = DockerHelper.parseDelimitedStringHeader(DockerConstants.DOCKER_VOLUMES_FROM, message);
 
-        if(volumesFrom != null) {
+        if (volumesFrom != null) {
             createContainerCmd.withVolumesFrom(volumesFrom);
         }
         
@@ -762,91 +760,91 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker Start Container Request");
         
-        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID,configuration, message, String.class);
+        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID, configuration, message, String.class);
         
         StartContainerCmd startContainerCmd = client.startContainerCmd(containerId);
         
         Bind[] binds = DockerHelper.getArrayProperty(DockerConstants.DOCKER_BINDS, message, Bind.class);
 
-        if(binds != null) {
+        if (binds != null) {
             startContainerCmd.withBinds(binds);
         }
         
         Link[] links = DockerHelper.getArrayProperty(DockerConstants.DOCKER_LINKS, message, Link.class);
 
-        if(links != null) {
+        if (links != null) {
             startContainerCmd.withLinks(links);
         }
         
         LxcConf[] lxcConf = DockerHelper.getArrayProperty(DockerConstants.DOCKER_LXC_CONF, message, LxcConf.class);
 
-        if(lxcConf != null) {
+        if (lxcConf != null) {
             startContainerCmd.withLxcConf(lxcConf);
         }
         
-        Ports ports = DockerHelper.getProperty(DockerConstants.DOCKER_PORT_BINDINGS,configuration, message, Ports.class);
+        Ports ports = DockerHelper.getProperty(DockerConstants.DOCKER_PORT_BINDINGS, configuration, message, Ports.class);
 
-        if(ports != null) {
+        if (ports != null) {
             startContainerCmd.withPortBindings(ports);
         }
         
-        Boolean privileged = DockerHelper.getProperty(DockerConstants.DOCKER_PRIVILEGED,configuration, message, Boolean.class);
+        Boolean privileged = DockerHelper.getProperty(DockerConstants.DOCKER_PRIVILEGED, configuration, message, Boolean.class);
 
-        if(privileged != null && privileged) {
+        if (privileged != null && privileged) {
             startContainerCmd.withPrivileged(privileged);
         }
         
-        Boolean publishAllPorts = DockerHelper.getProperty(DockerConstants.DOCKER_PUBLISH_ALL_PORTS,configuration, message, Boolean.class);
+        Boolean publishAllPorts = DockerHelper.getProperty(DockerConstants.DOCKER_PUBLISH_ALL_PORTS, configuration, message, Boolean.class);
 
-        if(publishAllPorts != null && publishAllPorts) {
+        if (publishAllPorts != null && publishAllPorts) {
             startContainerCmd.withPublishAllPorts(publishAllPorts);
         }
         
         String[] dns = DockerHelper.parseDelimitedStringHeader(DockerConstants.DOCKER_DNS, message);
 
-        if(dns != null) {
+        if (dns != null) {
             startContainerCmd.withDns(dns);
         }
         
         String[] dnsSearch = DockerHelper.parseDelimitedStringHeader(DockerConstants.DOCKER_DNS_SEARCH, message);
 
-        if(dnsSearch != null) {
+        if (dnsSearch != null) {
             startContainerCmd.withDnsSearch(dnsSearch);
         }
         
-        String volumesFrom = DockerHelper.getProperty(DockerConstants.DOCKER_VOLUMES_FROM,configuration, message, String.class);
+        String volumesFrom = DockerHelper.getProperty(DockerConstants.DOCKER_VOLUMES_FROM, configuration, message, String.class);
 
-        if(volumesFrom != null) {
+        if (volumesFrom != null) {
             startContainerCmd.withVolumesFrom(volumesFrom);
         }
 
-        String networkMode = DockerHelper.getProperty(DockerConstants.DOCKER_NETWORK_MODE,configuration, message, String.class);
+        String networkMode = DockerHelper.getProperty(DockerConstants.DOCKER_NETWORK_MODE, configuration, message, String.class);
 
-        if(networkMode != null) {
+        if (networkMode != null) {
             startContainerCmd.withNetworkMode(networkMode);
         }
 
         Device[] devices = DockerHelper.getArrayProperty(DockerConstants.DOCKER_DEVICES, message, Device.class);
 
-        if(devices != null) {
+        if (devices != null) {
             startContainerCmd.withDevices(devices);
         }
         
-        RestartPolicy restartPolicy = DockerHelper.getProperty(DockerConstants.DOCKER_RESTART_POLICY,configuration, message, RestartPolicy.class);
+        RestartPolicy restartPolicy = DockerHelper.getProperty(DockerConstants.DOCKER_RESTART_POLICY, configuration, message, RestartPolicy.class);
 
-        if(restartPolicy != null) {
+        if (restartPolicy != null) {
             startContainerCmd.withRestartPolicy(restartPolicy);
         }
         
         String[] capAdd = DockerHelper.parseDelimitedStringHeader(DockerConstants.DOCKER_CAP_ADD, message);
 
-        if(capAdd != null) {
+        if (capAdd != null) {
             startContainerCmd.withCapAdd(capAdd);
         }
         
         String[] capDrop = DockerHelper.parseDelimitedStringHeader(DockerConstants.DOCKER_CAP_DROP, message);
 
-        if(capDrop != null) {
+        if (capDrop != null) {
             startContainerCmd.withCapDrop(capDrop);
         }
         
@@ -866,7 +864,7 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker Inspect Container Request");
         
-        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID,configuration, message, String.class);
+        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID, configuration, message, String.class);
         
         InspectContainerCmd inspectContainerCmd = client.inspectContainerCmd(containerId);
         
@@ -886,7 +884,7 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker Wait Container Request");
         
-        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID,configuration, message, String.class);
+        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID, configuration, message, String.class);
         
         WaitContainerCmd waitContainerCmd = client.waitContainerCmd(containerId);
         
@@ -906,43 +904,43 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker Log Container Request");
         
-        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID,configuration, message, String.class);
+        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID, configuration, message, String.class);
 
         LogContainerCmd logContainerCmd = client.logContainerCmd(containerId);
 
-        Boolean stdOut = DockerHelper.getProperty(DockerConstants.DOCKER_STD_OUT,configuration, message, Boolean.class);
+        Boolean stdOut = DockerHelper.getProperty(DockerConstants.DOCKER_STD_OUT, configuration, message, Boolean.class);
         
-        if(stdOut != null && stdOut) {
+        if (stdOut != null && stdOut) {
             logContainerCmd.withStdOut(stdOut);
         }
         
-        Boolean stdErr = DockerHelper.getProperty(DockerConstants.DOCKER_STD_ERR,configuration, message, Boolean.class);
+        Boolean stdErr = DockerHelper.getProperty(DockerConstants.DOCKER_STD_ERR, configuration, message, Boolean.class);
         
-        if(stdErr != null && stdErr) {
+        if (stdErr != null && stdErr) {
             logContainerCmd.withStdErr(stdErr);
         }
         
-        Boolean timestamps = DockerHelper.getProperty(DockerConstants.DOCKER_TIMESTAMPS,configuration, message, Boolean.class);
+        Boolean timestamps = DockerHelper.getProperty(DockerConstants.DOCKER_TIMESTAMPS, configuration, message, Boolean.class);
         
-        if(timestamps != null && timestamps) {
+        if (timestamps != null && timestamps) {
             logContainerCmd.withTimestamps(timestamps);
         }       
         
-        Boolean followStream = DockerHelper.getProperty(DockerConstants.DOCKER_FOLLOW_STREAM,configuration, message, Boolean.class);
+        Boolean followStream = DockerHelper.getProperty(DockerConstants.DOCKER_FOLLOW_STREAM, configuration, message, Boolean.class);
         
-        if(followStream != null && followStream) {
+        if (followStream != null && followStream) {
             logContainerCmd.withFollowStream(followStream);
         }    
         
-        Boolean tailAll = DockerHelper.getProperty(DockerConstants.DOCKER_TAIL_ALL,configuration, message, Boolean.class);
+        Boolean tailAll = DockerHelper.getProperty(DockerConstants.DOCKER_TAIL_ALL, configuration, message, Boolean.class);
         
-        if(tailAll != null && tailAll) {
+        if (tailAll != null && tailAll) {
             logContainerCmd.withTailAll();
         }
         
-        Integer tail = DockerHelper.getProperty(DockerConstants.DOCKER_TAIL,configuration, message, Integer.class);
+        Integer tail = DockerHelper.getProperty(DockerConstants.DOCKER_TAIL, configuration, message, Integer.class);
         
-        if(tailAll != null) {
+        if (tailAll != null) {
             logContainerCmd.withTail(tail);
         }
         
@@ -963,37 +961,37 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker Attach Container Request");
         
-        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID,configuration, message, String.class);
+        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID, configuration, message, String.class);
 
         AttachContainerCmd attachContainerCmd = client.attachContainerCmd(containerId);
 
-        Boolean stdOut = DockerHelper.getProperty(DockerConstants.DOCKER_STD_OUT,configuration, message, Boolean.class);
+        Boolean stdOut = DockerHelper.getProperty(DockerConstants.DOCKER_STD_OUT, configuration, message, Boolean.class);
         
-        if(stdOut != null && stdOut) {
+        if (stdOut != null && stdOut) {
             attachContainerCmd.withStdOut(stdOut);
         }
         
-        Boolean stdErr = DockerHelper.getProperty(DockerConstants.DOCKER_STD_ERR,configuration, message, Boolean.class);
+        Boolean stdErr = DockerHelper.getProperty(DockerConstants.DOCKER_STD_ERR, configuration, message, Boolean.class);
         
-        if(stdErr != null && stdErr) {
+        if (stdErr != null && stdErr) {
             attachContainerCmd.withStdErr(stdErr);
         }
         
-        Boolean logs = DockerHelper.getProperty(DockerConstants.DOCKER_LOGS,configuration, message, Boolean.class);
+        Boolean logs = DockerHelper.getProperty(DockerConstants.DOCKER_LOGS, configuration, message, Boolean.class);
         
-        if(logs != null && logs) {
+        if (logs != null && logs) {
             attachContainerCmd.withLogs(logs);
         }
         
-        Boolean timestamps = DockerHelper.getProperty(DockerConstants.DOCKER_TIMESTAMPS,configuration, message, Boolean.class);
+        Boolean timestamps = DockerHelper.getProperty(DockerConstants.DOCKER_TIMESTAMPS, configuration, message, Boolean.class);
         
-        if(timestamps != null && timestamps) {
+        if (timestamps != null && timestamps) {
             attachContainerCmd.withTimestamps(timestamps);
         }       
         
-        Boolean followStream = DockerHelper.getProperty(DockerConstants.DOCKER_FOLLOW_STREAM,configuration, message, Boolean.class);
+        Boolean followStream = DockerHelper.getProperty(DockerConstants.DOCKER_FOLLOW_STREAM, configuration, message, Boolean.class);
         
-        if(followStream != null && followStream) {
+        if (followStream != null && followStream) {
             attachContainerCmd.withFollowStream(followStream);
         }    
         
@@ -1014,13 +1012,13 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker Kill Container Request");
         
-        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID,configuration, message, String.class);
+        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID, configuration, message, String.class);
         
         StopContainerCmd stopContainerCmd = client.stopContainerCmd(containerId);
 
-        Integer timeout = DockerHelper.getProperty(DockerConstants.DOCKER_TIMEOUT,configuration, message, Integer.class);
+        Integer timeout = DockerHelper.getProperty(DockerConstants.DOCKER_TIMEOUT, configuration, message, Integer.class);
         
-        if(timeout != null) {
+        if (timeout != null) {
             stopContainerCmd.withTimeout(timeout);
         }
              
@@ -1041,13 +1039,13 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker Restart Container Request");
    
-        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID,configuration, message, String.class);
+        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID, configuration, message, String.class);
         
         RestartContainerCmd restartContainerCmd = client.restartContainerCmd(containerId);
 
-        Integer timeout = DockerHelper.getProperty(DockerConstants.DOCKER_TIMEOUT,configuration, message, Integer.class);
+        Integer timeout = DockerHelper.getProperty(DockerConstants.DOCKER_TIMEOUT, configuration, message, Integer.class);
         
-        if(timeout != null) {
+        if (timeout != null) {
             restartContainerCmd.withtTimeout(timeout);
         }
              
@@ -1068,7 +1066,7 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker Diff Container Request");
         
-        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID,configuration, message, String.class);
+        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID, configuration, message, String.class);
 
         ContainerDiffCmd diffContainerCmd = client.containerDiffCmd(containerId);
         
@@ -1088,13 +1086,13 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker Kill Container Request");
         
-        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID,configuration, message, String.class);
+        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID, configuration, message, String.class);
         
         KillContainerCmd killContainerCmd = client.killContainerCmd(containerId);
 
-        String signal = DockerHelper.getProperty(DockerConstants.DOCKER_SIGNAL,configuration, message, String.class);
+        String signal = DockerHelper.getProperty(DockerConstants.DOCKER_SIGNAL, configuration, message, String.class);
         
-        if(signal != null) {
+        if (signal != null) {
             killContainerCmd.withSignal(signal);
         }
              
@@ -1114,13 +1112,13 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker Top Container Request");
         
-        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID,configuration, message, String.class);
+        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID, configuration, message, String.class);
         
         TopContainerCmd topContainerCmd = client.topContainerCmd(containerId);
 
-        String psArgs = DockerHelper.getProperty(DockerConstants.DOCKER_PS_ARGS,configuration, message, String.class);
+        String psArgs = DockerHelper.getProperty(DockerConstants.DOCKER_PS_ARGS, configuration, message, String.class);
         
-        if(psArgs != null) {
+        if (psArgs != null) {
             topContainerCmd.withPsArgs(psArgs);
         }
              
@@ -1141,7 +1139,7 @@ public class DockerProducer extends DefaultProducer {
             
         LOGGER.debug("Executing Docker Pause Container Request");
         
-        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID,configuration, message, String.class);
+        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID, configuration, message, String.class);
         
         PauseContainerCmd pauseContainerCmd = client.pauseContainerCmd(containerId);
         
@@ -1161,7 +1159,7 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker Unpause Container Request");
         
-        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID,configuration, message, String.class);
+        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID, configuration, message, String.class);
         
         UnpauseContainerCmd unpauseContainerCmd = client.unpauseContainerCmd(containerId);
         
@@ -1182,139 +1180,139 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker Commit Container Request");
         
-        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID,configuration, message, String.class);
+        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID, configuration, message, String.class);
         
         CommitCmd commitCmd = client.commitCmd(containerId);
  
-        String repository = DockerHelper.getProperty(DockerConstants.DOCKER_REPOSITORY,configuration, message, String.class);
+        String repository = DockerHelper.getProperty(DockerConstants.DOCKER_REPOSITORY, configuration, message, String.class);
 
-        if(repository != null) {
+        if (repository != null) {
             commitCmd.withRepository(repository);
         }
         
-        String msg = DockerHelper.getProperty(DockerConstants.DOCKER_MESSAGE,configuration, message, String.class);
+        String msg = DockerHelper.getProperty(DockerConstants.DOCKER_MESSAGE, configuration, message, String.class);
 
-        if(message != null) {
+        if (message != null) {
             commitCmd.withMessage(msg);
         }
         
-        String tag = DockerHelper.getProperty(DockerConstants.DOCKER_TAG,configuration, message, String.class);
+        String tag = DockerHelper.getProperty(DockerConstants.DOCKER_TAG, configuration, message, String.class);
 
-        if(tag != null) {
+        if (tag != null) {
             commitCmd.withTag(tag);
         }
         
-        String author = DockerHelper.getProperty(DockerConstants.DOCKER_TAG,configuration, message, String.class);
+        String author = DockerHelper.getProperty(DockerConstants.DOCKER_TAG, configuration, message, String.class);
 
-        if(author != null) {
+        if (author != null) {
             commitCmd.withAuthor(tag);
         }       
 
-        Boolean attachStdIn = DockerHelper.getProperty(DockerConstants.DOCKER_ATTACH_STD_IN,configuration, message, Boolean.class);
+        Boolean attachStdIn = DockerHelper.getProperty(DockerConstants.DOCKER_ATTACH_STD_IN, configuration, message, Boolean.class);
 
-        if(attachStdIn != null && attachStdIn) {
+        if (attachStdIn != null && attachStdIn) {
             commitCmd.withAttachStdin();
         }   
         
-        Boolean attachStdOut = DockerHelper.getProperty(DockerConstants.DOCKER_ATTACH_STD_OUT,configuration, message, Boolean.class);
+        Boolean attachStdOut = DockerHelper.getProperty(DockerConstants.DOCKER_ATTACH_STD_OUT, configuration, message, Boolean.class);
 
-        if(attachStdOut != null && attachStdOut) {
+        if (attachStdOut != null && attachStdOut) {
             commitCmd.withAttachStdout();
         }   
 
-        Boolean attachStdErr = DockerHelper.getProperty(DockerConstants.DOCKER_ATTACH_STD_ERR,configuration, message, Boolean.class);
+        Boolean attachStdErr = DockerHelper.getProperty(DockerConstants.DOCKER_ATTACH_STD_ERR, configuration, message, Boolean.class);
 
-        if(attachStdErr != null && attachStdErr) {
+        if (attachStdErr != null && attachStdErr) {
             commitCmd.withAttachStderr();
         }   
                
         String[] cmds = DockerHelper.parseDelimitedStringHeader(DockerConstants.DOCKER_CMD, message);
 
-        if(cmds != null) {
+        if (cmds != null) {
             commitCmd.withCmd(cmds);
         }
         
-        Boolean disableNetwork = DockerHelper.getProperty(DockerConstants.DOCKER_DISABLE_NETWORK,configuration, message, Boolean.class);
+        Boolean disableNetwork = DockerHelper.getProperty(DockerConstants.DOCKER_DISABLE_NETWORK, configuration, message, Boolean.class);
 
-        if(disableNetwork != null && disableNetwork) {
+        if (disableNetwork != null && disableNetwork) {
             commitCmd.withDisableNetwork(disableNetwork);
         }   
         
-        Boolean pause = DockerHelper.getProperty(DockerConstants.DOCKER_PAUSE,configuration, message, Boolean.class);
+        Boolean pause = DockerHelper.getProperty(DockerConstants.DOCKER_PAUSE, configuration, message, Boolean.class);
 
-        if(pause != null && pause) {
+        if (pause != null && pause) {
             commitCmd.withPause(pause);
         }          
         
         String[] envs = DockerHelper.parseDelimitedStringHeader(DockerConstants.DOCKER_ENV, message);
 
-        if(envs != null) {
+        if (envs != null) {
             commitCmd.withEnv(envs);
         }
  
-        ExposedPorts exposedPorts = DockerHelper.getProperty(DockerConstants.DOCKER_EXPOSED_PORTS,configuration, message, ExposedPorts.class);
+        ExposedPorts exposedPorts = DockerHelper.getProperty(DockerConstants.DOCKER_EXPOSED_PORTS, configuration, message, ExposedPorts.class);
 
-        if(exposedPorts != null) {
+        if (exposedPorts != null) {
             commitCmd.withExposedPorts(exposedPorts);
         }  
         
-        String hostname = DockerHelper.getProperty(DockerConstants.DOCKER_HOSTNAME,configuration, message, String.class);
+        String hostname = DockerHelper.getProperty(DockerConstants.DOCKER_HOSTNAME, configuration, message, String.class);
 
-        if(hostname != null) {
+        if (hostname != null) {
             commitCmd.withHostname(hostname);
         }
         
-        Integer memory = DockerHelper.getProperty(DockerConstants.DOCKER_MEMORY,configuration, message, Integer.class);
+        Integer memory = DockerHelper.getProperty(DockerConstants.DOCKER_MEMORY, configuration, message, Integer.class);
 
-        if(memory != null) {
+        if (memory != null) {
             commitCmd.withMemory(memory);
         }
 
-        Integer memorySwap = DockerHelper.getProperty(DockerConstants.DOCKER_MEMORY_SWAP,configuration, message, Integer.class);
+        Integer memorySwap = DockerHelper.getProperty(DockerConstants.DOCKER_MEMORY_SWAP, configuration, message, Integer.class);
 
-        if(memorySwap != null) {
+        if (memorySwap != null) {
             commitCmd.withMemorySwap(memorySwap);
         }
         
-        Boolean openStdIn = DockerHelper.getProperty(DockerConstants.DOCKER_OPEN_STD_IN,configuration, message, Boolean.class);
+        Boolean openStdIn = DockerHelper.getProperty(DockerConstants.DOCKER_OPEN_STD_IN, configuration, message, Boolean.class);
 
-        if(openStdIn != null && openStdIn) {
+        if (openStdIn != null && openStdIn) {
             commitCmd.withOpenStdin(openStdIn);
         }  
         
         String[] portSpecs = DockerHelper.parseDelimitedStringHeader(DockerConstants.DOCKER_PORT_SPECS, message);
 
-        if(portSpecs != null) {
+        if (portSpecs != null) {
             commitCmd.withPortSpecs(portSpecs);
         }
         
-        Boolean stdInOnce = DockerHelper.getProperty(DockerConstants.DOCKER_STD_IN_ONCE,configuration, message, Boolean.class);
+        Boolean stdInOnce = DockerHelper.getProperty(DockerConstants.DOCKER_STD_IN_ONCE, configuration, message, Boolean.class);
 
-        if(stdInOnce != null && stdInOnce) {
+        if (stdInOnce != null && stdInOnce) {
             commitCmd.withStdinOnce(stdInOnce);
         }  
         
-        Boolean tty = DockerHelper.getProperty(DockerConstants.DOCKER_TTY,configuration, message, Boolean.class);
+        Boolean tty = DockerHelper.getProperty(DockerConstants.DOCKER_TTY, configuration, message, Boolean.class);
 
-        if(tty != null && tty) {
+        if (tty != null && tty) {
             commitCmd.withTty(tty);
         }
         
-        String user = DockerHelper.getProperty(DockerConstants.DOCKER_USER,configuration, message, String.class);
+        String user = DockerHelper.getProperty(DockerConstants.DOCKER_USER, configuration, message, String.class);
 
-        if(user != null) {
+        if (user != null) {
             commitCmd.withUser(user);
         }
         
-        Volumes volumes = DockerHelper.getProperty(DockerConstants.DOCKER_VOLUMES,configuration, message, Volumes.class);
+        Volumes volumes = DockerHelper.getProperty(DockerConstants.DOCKER_VOLUMES, configuration, message, Volumes.class);
 
-        if(volumes != null) {
+        if (volumes != null) {
             commitCmd.withVolumes(volumes);
         }
         
-        String workingDir = DockerHelper.getProperty(DockerConstants.DOCKER_HOSTNAME,configuration, message, String.class);
+        String workingDir = DockerHelper.getProperty(DockerConstants.DOCKER_HOSTNAME, configuration, message, String.class);
 
-        if(workingDir != null) {
+        if (workingDir != null) {
             commitCmd.withWorkingDir(workingDir);
         }
         
@@ -1335,14 +1333,14 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker Copy File/Folder Container Request");
         
-        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID,configuration, message, String.class);
-        String resource = DockerHelper.getProperty(DockerConstants.DOCKER_RESOURCE,configuration, message, String.class);
+        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID, configuration, message, String.class);
+        String resource = DockerHelper.getProperty(DockerConstants.DOCKER_RESOURCE, configuration, message, String.class);
 
         CopyFileFromContainerCmd copyFileContainerCmd = client.copyFileFromContainerCmd(containerId, resource);
 
-        String hostPath = DockerHelper.getProperty(DockerConstants.DOCKER_HOST_PATH,configuration, message, String.class);
+        String hostPath = DockerHelper.getProperty(DockerConstants.DOCKER_HOST_PATH, configuration, message, String.class);
         
-        if(hostPath != null) {
+        if (hostPath != null) {
             copyFileContainerCmd.withHostPath(hostPath);
         }
              
@@ -1362,19 +1360,19 @@ public class DockerProducer extends DefaultProducer {
         
         LOGGER.debug("Executing Docker Remove Container Request");
         
-        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID,configuration, message, String.class);
+        String containerId = DockerHelper.getProperty(DockerConstants.DOCKER_CONTAINER_ID, configuration, message, String.class);
 
         RemoveContainerCmd removeContainerCmd = client.removeContainerCmd(containerId);
 
-        Boolean force = DockerHelper.getProperty(DockerConstants.DOCKER_FORCE,configuration, message, Boolean.class);
+        Boolean force = DockerHelper.getProperty(DockerConstants.DOCKER_FORCE, configuration, message, Boolean.class);
         
-        if(force != null && force) {
+        if (force != null && force) {
             removeContainerCmd.withForce(force);
         }
         
-        Boolean removeVolumes = DockerHelper.getProperty(DockerConstants.DOCKER_REMOVE_VOLUMES,configuration, message, Boolean.class);
+        Boolean removeVolumes = DockerHelper.getProperty(DockerConstants.DOCKER_REMOVE_VOLUMES, configuration, message, Boolean.class);
         
-        if(removeVolumes != null && removeVolumes) {
+        if (removeVolumes != null && removeVolumes) {
             removeContainerCmd.withRemoveVolumes(removeVolumes);
         }
         
@@ -1401,8 +1399,9 @@ public class DockerProducer extends DefaultProducer {
         
         try {
             authConfig = client.authConfig();
+        } catch (Exception e) {
+            // Do nothing here
         }
-        catch(Exception e) {}
         
         return authConfig;     
         

http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/test/java/org/apache/camel/component/docker/DockerClientProfileTest.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/test/java/org/apache/camel/component/docker/DockerClientProfileTest.java b/components/camel-docker/src/test/java/org/apache/camel/component/docker/DockerClientProfileTest.java
index b82ba84..0b63d50 100644
--- a/components/camel-docker/src/test/java/org/apache/camel/component/docker/DockerClientProfileTest.java
+++ b/components/camel-docker/src/test/java/org/apache/camel/component/docker/DockerClientProfileTest.java
@@ -16,9 +16,8 @@
  */
 package org.apache.camel.component.docker;
 
-import static org.junit.Assert.assertEquals;
 import org.junit.Test;
-
+import static org.junit.Assert.assertEquals;
 /**
  * Validates the {@link DockerClientProfile}
  */

http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/test/java/org/apache/camel/component/docker/DockerConfigurationTest.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/test/java/org/apache/camel/component/docker/DockerConfigurationTest.java b/components/camel-docker/src/test/java/org/apache/camel/component/docker/DockerConfigurationTest.java
index d0fbf9e..af596ae 100644
--- a/components/camel-docker/src/test/java/org/apache/camel/component/docker/DockerConfigurationTest.java
+++ b/components/camel-docker/src/test/java/org/apache/camel/component/docker/DockerConfigurationTest.java
@@ -16,7 +16,6 @@
  */
 package org.apache.camel.component.docker;
 
-import static org.junit.Assert.assertEquals;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -26,6 +25,8 @@ import org.apache.camel.impl.DefaultMessage;
 import org.junit.Before;
 import org.junit.Test;
 
+import static org.junit.Assert.assertEquals;
+
 public class DockerConfigurationTest {
     
     private DockerConfiguration configuration;
@@ -51,7 +52,7 @@ public class DockerConfigurationTest {
     public void testPropertyfromEndpointProperties() {
         String host = "camelhost";
         
-        Map<String,Object> parameters = new HashMap<String,Object>();
+        Map<String, Object> parameters = new HashMap<String, Object>();
         parameters.put(DockerHelper.transformFromHeaderName(DockerConstants.DOCKER_HOST), host);
         configuration.setParameters(parameters);
         

http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/test/java/org/apache/camel/component/docker/DockerHelperTest.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/test/java/org/apache/camel/component/docker/DockerHelperTest.java b/components/camel-docker/src/test/java/org/apache/camel/component/docker/DockerHelperTest.java
index 3eaf66f..b3a4f34 100644
--- a/components/camel-docker/src/test/java/org/apache/camel/component/docker/DockerHelperTest.java
+++ b/components/camel-docker/src/test/java/org/apache/camel/component/docker/DockerHelperTest.java
@@ -16,8 +16,8 @@
  */
 package org.apache.camel.component.docker;
 
-import static org.junit.Assert.assertEquals;
 import org.junit.Test;
+import static org.junit.Assert.assertEquals;
 
 public class DockerHelperTest {
     

http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/test/java/org/apache/camel/component/docker/RemoveImageCmdUriTest.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/test/java/org/apache/camel/component/docker/RemoveImageCmdUriTest.java b/components/camel-docker/src/test/java/org/apache/camel/component/docker/RemoveImageCmdUriTest.java
index 8cb9278..a85eb22 100644
--- a/components/camel-docker/src/test/java/org/apache/camel/component/docker/RemoveImageCmdUriTest.java
+++ b/components/camel-docker/src/test/java/org/apache/camel/component/docker/RemoveImageCmdUriTest.java
@@ -16,10 +16,10 @@
  */
 package org.apache.camel.component.docker;
 
-import com.github.dockerjava.api.command.RemoveImageCmd;
-
 import java.util.Map;
 
+import com.github.dockerjava.api.command.RemoveImageCmd;
+
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.docker.headers.BaseDockerHeaderTest;
 import org.junit.Test;
@@ -44,7 +44,7 @@ public class RemoveImageCmdUriTest extends BaseDockerHeaderTest<RemoveImageCmd>
             
             @Override
             public void configure() throws Exception {
-                from("direct:in").to("docker://"+getOperation().toString()+"?imageId="+imageId+"&noPrune="+noPrune+"&force="+force);
+                from("direct:in").to("docker://" + getOperation().toString() + "?imageId=" + imageId + "&noPrune=" + noPrune + "&force=" + force);
                 
             }
         };
@@ -56,13 +56,13 @@ public class RemoveImageCmdUriTest extends BaseDockerHeaderTest<RemoveImageCmd>
         
 
         
-        Map<String,Object> headers = getDefaultParameters();
+        Map<String, Object> headers = getDefaultParameters();
         
-        template.sendBodyAndHeaders("direct:in", "",headers);
+        template.sendBodyAndHeaders("direct:in", "", headers);
         
-        Mockito.verify(dockerClient,Mockito.times(1)).removeImageCmd(imageId);
-        Mockito.verify(mockObject,Mockito.times(0)).withNoPrune();
-        Mockito.verify(mockObject,Mockito.times(1)).withForce();
+        Mockito.verify(dockerClient, Mockito.times(1)).removeImageCmd(imageId);
+        Mockito.verify(mockObject, Mockito.times(0)).withNoPrune();
+        Mockito.verify(mockObject, Mockito.times(1)).withForce();
 
         
         

http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/AttachContainerCmdHeaderTest.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/AttachContainerCmdHeaderTest.java b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/AttachContainerCmdHeaderTest.java
index d24655f..a0c17a8 100644
--- a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/AttachContainerCmdHeaderTest.java
+++ b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/AttachContainerCmdHeaderTest.java
@@ -16,10 +16,10 @@
  */
 package org.apache.camel.component.docker.headers;
 
-import com.github.dockerjava.api.command.AttachContainerCmd;
-
 import java.util.Map;
 
+import com.github.dockerjava.api.command.AttachContainerCmd;
+
 import org.apache.camel.component.docker.DockerConstants;
 import org.apache.camel.component.docker.DockerOperation;
 import org.junit.Test;
@@ -44,7 +44,7 @@ public class AttachContainerCmdHeaderTest extends BaseDockerHeaderTest<AttachCon
         boolean logs = true;
         boolean timestamps = true;
         
-        Map<String,Object> headers = getDefaultParameters();
+        Map<String, Object> headers = getDefaultParameters();
         headers.put(DockerConstants.DOCKER_CONTAINER_ID, containerId);
         headers.put(DockerConstants.DOCKER_FOLLOW_STREAM, followStream);
         headers.put(DockerConstants.DOCKER_STD_OUT, stdOut);
@@ -54,14 +54,14 @@ public class AttachContainerCmdHeaderTest extends BaseDockerHeaderTest<AttachCon
 
 
         
-        template.sendBodyAndHeaders("direct:in", "",headers);
+        template.sendBodyAndHeaders("direct:in", "", headers);
                 
-        Mockito.verify(dockerClient,Mockito.times(1)).attachContainerCmd(containerId);
-        Mockito.verify(mockObject,Mockito.times(1)).withFollowStream(Mockito.eq(followStream));
-        Mockito.verify(mockObject,Mockito.times(1)).withLogs(Mockito.eq(logs));
-        Mockito.verify(mockObject,Mockito.times(1)).withStdErr(Mockito.eq(stdErr));
-        Mockito.verify(mockObject,Mockito.times(1)).withStdOut(Mockito.eq(stdOut));
-        Mockito.verify(mockObject,Mockito.times(1)).withTimestamps(Mockito.eq(timestamps));
+        Mockito.verify(dockerClient, Mockito.times(1)).attachContainerCmd(containerId);
+        Mockito.verify(mockObject, Mockito.times(1)).withFollowStream(Mockito.eq(followStream));
+        Mockito.verify(mockObject, Mockito.times(1)).withLogs(Mockito.eq(logs));
+        Mockito.verify(mockObject, Mockito.times(1)).withStdErr(Mockito.eq(stdErr));
+        Mockito.verify(mockObject, Mockito.times(1)).withStdOut(Mockito.eq(stdOut));
+        Mockito.verify(mockObject, Mockito.times(1)).withTimestamps(Mockito.eq(timestamps));
         
     }
 

http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/AuthCmdHeaderTest.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/AuthCmdHeaderTest.java b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/AuthCmdHeaderTest.java
index 47ad367..aba925c 100644
--- a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/AuthCmdHeaderTest.java
+++ b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/AuthCmdHeaderTest.java
@@ -16,10 +16,10 @@
  */
 package org.apache.camel.component.docker.headers;
 
-import com.github.dockerjava.api.command.AuthCmd;
-
 import java.util.Map;
 
+import com.github.dockerjava.api.command.AuthCmd;
+
 import org.apache.camel.component.docker.DockerClientProfile;
 import org.apache.camel.component.docker.DockerConstants;
 import org.apache.camel.component.docker.DockerOperation;
@@ -47,41 +47,39 @@ public class AuthCmdHeaderTest extends BaseDockerHeaderTest<AuthCmd> {
         String email = "jdoe@example.com";
         String serverAddress = "http://docker.io/v1";
         
-        Map<String,Object> headers = getDefaultParameters();
+        Map<String, Object> headers = getDefaultParameters();
         headers.put(DockerConstants.DOCKER_USERNAME, userName);
         headers.put(DockerConstants.DOCKER_PASSWORD, password);
         headers.put(DockerConstants.DOCKER_EMAIL, email);
         headers.put(DockerConstants.DOCKER_SERVER_ADDRESS, serverAddress);
         
-        template.sendBodyAndHeaders("direct:in", "",headers);
+        template.sendBodyAndHeaders("direct:in", "", headers);
         
-        Mockito.verify(dockerClient,Mockito.times(1)).authCmd();
+        Mockito.verify(dockerClient, Mockito.times(1)).authCmd();
         
     }
     
     @Override
     public DockerClientProfile getClientProfile() {
-       DockerClientProfile clientProfile = super.getClientProfile();
-       clientProfile.setEmail(email);
-       clientProfile.setPassword(password);
-       clientProfile.setUsername(userName);
-       clientProfile.setServerAddress(serverAddress);
-       
-       return clientProfile;
-       
-    }
+        DockerClientProfile clientProfile = super.getClientProfile();
+        clientProfile.setEmail(email);
+        clientProfile.setPassword(password);
+        clientProfile.setUsername(userName);
+        clientProfile.setServerAddress(serverAddress);
 
+        return clientProfile;
 
+    }
 
     @Override
     protected void setupMocks() {
-       Mockito.when(dockerClient.authCmd()).thenReturn(mockObject);
-        
+        Mockito.when(dockerClient.authCmd()).thenReturn(mockObject);
+
     }
 
     @Override
     protected DockerOperation getOperation() {
-       return DockerOperation.AUTH;
+        return DockerOperation.AUTH;
     }
 
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/BaseDockerHeaderTest.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/BaseDockerHeaderTest.java b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/BaseDockerHeaderTest.java
index e0f419d..ef547a7 100644
--- a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/BaseDockerHeaderTest.java
+++ b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/BaseDockerHeaderTest.java
@@ -16,11 +16,11 @@
  */
 package org.apache.camel.component.docker.headers;
 
-import com.github.dockerjava.api.DockerClient;
-
 import java.util.HashMap;
 import java.util.Map;
 
+import com.github.dockerjava.api.DockerClient;
+
 import org.apache.camel.CamelContext;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.docker.DockerClientProfile;
@@ -51,7 +51,7 @@ public abstract class BaseDockerHeaderTest<T> extends CamelTestSupport {
             
             @Override
             public void configure() throws Exception {
-                from("direct:in").to("docker://"+getOperation().toString());
+                from("direct:in").to("docker://" + getOperation().toString());
                 
             }
         };
@@ -97,8 +97,8 @@ public abstract class BaseDockerHeaderTest<T> extends CamelTestSupport {
         return mockObject;
     }
     
-    protected Map<String,Object> getDefaultParameters() {
-        Map<String,Object> parameters = new HashMap<String,Object>();
+    protected Map<String, Object> getDefaultParameters() {
+        Map<String, Object> parameters = new HashMap<String, Object>();
         parameters.put(DockerConstants.DOCKER_HOST, getHost());
         parameters.put(DockerConstants.DOCKER_PORT, getPort());
         parameters.put(DockerConstants.DOCKER_EMAIL, getEmail());

http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/BuildImageCmdHeaderTest.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/BuildImageCmdHeaderTest.java b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/BuildImageCmdHeaderTest.java
index d13d901..5f152ad 100644
--- a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/BuildImageCmdHeaderTest.java
+++ b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/BuildImageCmdHeaderTest.java
@@ -16,12 +16,12 @@
  */
 package org.apache.camel.component.docker.headers;
 
-import com.github.dockerjava.api.command.BuildImageCmd;
-
 import java.io.File;
 import java.io.InputStream;
 import java.util.Map;
 
+import com.github.dockerjava.api.command.BuildImageCmd;
+
 import org.apache.camel.component.docker.DockerConstants;
 import org.apache.camel.component.docker.DockerOperation;
 import org.junit.Test;
@@ -51,26 +51,26 @@ public class BuildImageCmdHeaderTest extends BaseDockerHeaderTest<BuildImageCmd>
     @Test
     public void buildImageFromInputStreamHeaderTest() {
         
-        template.sendBodyAndHeaders("direct:in", inputStream,getHeaders());
+        template.sendBodyAndHeaders("direct:in", inputStream, getHeaders());
         
-        Mockito.verify(dockerClient,Mockito.times(1)).buildImageCmd(Mockito.any(InputStream.class));
-        Mockito.verify(mockObject,Mockito.times(1)).withQuiet();
-        Mockito.verify(mockObject,Mockito.times(1)).withNoCache();
-        Mockito.verify(mockObject,Mockito.times(1)).withRemove();
-        Mockito.verify(mockObject,Mockito.times(1)).withTag(tag);
+        Mockito.verify(dockerClient, Mockito.times(1)).buildImageCmd(Mockito.any(InputStream.class));
+        Mockito.verify(mockObject, Mockito.times(1)).withQuiet();
+        Mockito.verify(mockObject, Mockito.times(1)).withNoCache();
+        Mockito.verify(mockObject, Mockito.times(1)).withRemove();
+        Mockito.verify(mockObject, Mockito.times(1)).withTag(tag);
         
     }
     
     @Test
     public void buildImageFromFileHeaderTest() {
         
-        template.sendBodyAndHeaders("direct:in", file,getHeaders());
+        template.sendBodyAndHeaders("direct:in", file, getHeaders());
         
-        Mockito.verify(dockerClient,Mockito.times(1)).buildImageCmd(Mockito.any(File.class));
-        Mockito.verify(mockObject,Mockito.times(1)).withQuiet();
-        Mockito.verify(mockObject,Mockito.times(1)).withNoCache();
-        Mockito.verify(mockObject,Mockito.times(1)).withRemove();
-        Mockito.verify(mockObject,Mockito.times(1)).withTag(tag);
+        Mockito.verify(dockerClient, Mockito.times(1)).buildImageCmd(Mockito.any(File.class));
+        Mockito.verify(mockObject, Mockito.times(1)).withQuiet();
+        Mockito.verify(mockObject, Mockito.times(1)).withNoCache();
+        Mockito.verify(mockObject, Mockito.times(1)).withRemove();
+        Mockito.verify(mockObject, Mockito.times(1)).withTag(tag);
         
     }
     
@@ -86,8 +86,8 @@ public class BuildImageCmdHeaderTest extends BaseDockerHeaderTest<BuildImageCmd>
         return DockerOperation.BUILD_IMAGE;
     }
     
-    private Map<String,Object> getHeaders() {
-        Map<String,Object> headers = getDefaultParameters();
+    private Map<String, Object> getHeaders() {
+        Map<String, Object> headers = getDefaultParameters();
         headers.put(DockerConstants.DOCKER_REPOSITORY, repository);
         headers.put(DockerConstants.DOCKER_QUIET, quiet);
         headers.put(DockerConstants.DOCKER_NO_CACHE, noCache);

http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/CopyFileContainerCmdHeaderTest.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/CopyFileContainerCmdHeaderTest.java b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/CopyFileContainerCmdHeaderTest.java
index 5add369..897e76b 100644
--- a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/CopyFileContainerCmdHeaderTest.java
+++ b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/CopyFileContainerCmdHeaderTest.java
@@ -16,10 +16,10 @@
  */
 package org.apache.camel.component.docker.headers;
 
-import com.github.dockerjava.api.command.CopyFileFromContainerCmd;
-
 import java.util.Map;
 
+import com.github.dockerjava.api.command.CopyFileFromContainerCmd;
+
 import org.apache.camel.component.docker.DockerConstants;
 import org.apache.camel.component.docker.DockerOperation;
 import org.junit.Test;
@@ -41,16 +41,16 @@ public class CopyFileContainerCmdHeaderTest extends BaseDockerHeaderTest<CopyFil
         String resource = "/test";
         String hostPath = "/test/test2";
         
-        Map<String,Object> headers = getDefaultParameters();
+        Map<String, Object> headers = getDefaultParameters();
         headers.put(DockerConstants.DOCKER_CONTAINER_ID, containerId);
         headers.put(DockerConstants.DOCKER_RESOURCE, resource);
         headers.put(DockerConstants.DOCKER_HOST_PATH, hostPath);
 
 
-        template.sendBodyAndHeaders("direct:in", "",headers);
+        template.sendBodyAndHeaders("direct:in", "", headers);
                 
-        Mockito.verify(dockerClient,Mockito.times(1)).copyFileFromContainerCmd(containerId, resource);
-        Mockito.verify(mockObject,Mockito.times(1)).withHostPath(Mockito.eq(hostPath));
+        Mockito.verify(dockerClient, Mockito.times(1)).copyFileFromContainerCmd(containerId, resource);
+        Mockito.verify(mockObject, Mockito.times(1)).withHostPath(Mockito.eq(hostPath));
         
     }
 

http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/CreateContainerCmdHeaderTest.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/CreateContainerCmdHeaderTest.java b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/CreateContainerCmdHeaderTest.java
index cca14a3..1428466 100644
--- a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/CreateContainerCmdHeaderTest.java
+++ b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/CreateContainerCmdHeaderTest.java
@@ -16,11 +16,11 @@
  */
 package org.apache.camel.component.docker.headers;
 
+import java.util.Map;
+
 import com.github.dockerjava.api.command.CreateContainerCmd;
 import com.github.dockerjava.api.model.ExposedPort;
 
-import java.util.Map;
-
 import org.apache.camel.component.docker.DockerConstants;
 import org.apache.camel.component.docker.DockerOperation;
 import org.junit.Test;
@@ -43,15 +43,15 @@ public class CreateContainerCmdHeaderTest extends BaseDockerHeaderTest<CreateCon
         ExposedPort tcp22 = ExposedPort.tcp(22);
 
         
-        Map<String,Object> headers = getDefaultParameters();
+        Map<String, Object> headers = getDefaultParameters();
         headers.put(DockerConstants.DOCKER_IMAGE_ID, imageId);
         headers.put(DockerConstants.DOCKER_EXPOSED_PORTS, tcp22);
 
         
-        template.sendBodyAndHeaders("direct:in", "",headers);
+        template.sendBodyAndHeaders("direct:in", "", headers);
         
-        Mockito.verify(dockerClient,Mockito.times(1)).createContainerCmd(imageId);
-        Mockito.verify(mockObject,Mockito.times(1)).withExposedPorts(Mockito.any(ExposedPort.class));
+        Mockito.verify(dockerClient, Mockito.times(1)).createContainerCmd(imageId);
+        Mockito.verify(mockObject, Mockito.times(1)).withExposedPorts(Mockito.any(ExposedPort.class));
         
     }
 

http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/CreateImageCmdHeaderTest.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/CreateImageCmdHeaderTest.java b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/CreateImageCmdHeaderTest.java
index 4b904b3..1b60360 100644
--- a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/CreateImageCmdHeaderTest.java
+++ b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/CreateImageCmdHeaderTest.java
@@ -16,11 +16,11 @@
  */
 package org.apache.camel.component.docker.headers;
 
-import com.github.dockerjava.api.command.CreateImageCmd;
-
 import java.io.InputStream;
 import java.util.Map;
 
+import com.github.dockerjava.api.command.CreateImageCmd;
+
 import org.apache.camel.component.docker.DockerConstants;
 import org.apache.camel.component.docker.DockerOperation;
 import org.junit.Test;
@@ -40,12 +40,12 @@ public class CreateImageCmdHeaderTest extends BaseDockerHeaderTest<CreateImageCm
         
         String repository = "docker/empty";
         
-        Map<String,Object> headers = getDefaultParameters();
+        Map<String, Object> headers = getDefaultParameters();
         headers.put(DockerConstants.DOCKER_REPOSITORY, repository);
         
-        template.sendBodyAndHeaders("direct:in", "",headers);
+        template.sendBodyAndHeaders("direct:in", "", headers);
         
-        Mockito.verify(dockerClient,Mockito.times(1)).createImageCmd(Mockito.eq(repository), Mockito.any(InputStream.class));
+        Mockito.verify(dockerClient, Mockito.times(1)).createImageCmd(Mockito.eq(repository), Mockito.any(InputStream.class));
         
 
         

http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/DiffContainerCmdHeaderTest.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/DiffContainerCmdHeaderTest.java b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/DiffContainerCmdHeaderTest.java
index b81719c..865601e 100644
--- a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/DiffContainerCmdHeaderTest.java
+++ b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/DiffContainerCmdHeaderTest.java
@@ -16,10 +16,10 @@
  */
 package org.apache.camel.component.docker.headers;
 
-import com.github.dockerjava.api.command.ContainerDiffCmd;
-
 import java.util.Map;
 
+import com.github.dockerjava.api.command.ContainerDiffCmd;
+
 import org.apache.camel.component.docker.DockerConstants;
 import org.apache.camel.component.docker.DockerOperation;
 import org.junit.Test;
@@ -39,12 +39,12 @@ public class DiffContainerCmdHeaderTest extends BaseDockerHeaderTest<ContainerDi
                 
         String containerId = "9c09acd48a25";
         
-        Map<String,Object> headers = getDefaultParameters();
+        Map<String, Object> headers = getDefaultParameters();
         headers.put(DockerConstants.DOCKER_CONTAINER_ID, containerId);
         
-        template.sendBodyAndHeaders("direct:in", "",headers);
+        template.sendBodyAndHeaders("direct:in", "", headers);
         
-        Mockito.verify(dockerClient,Mockito.times(1)).containerDiffCmd(containerId);
+        Mockito.verify(dockerClient, Mockito.times(1)).containerDiffCmd(containerId);
         
     }
 

http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/InfoCmdHeaderTest.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/InfoCmdHeaderTest.java b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/InfoCmdHeaderTest.java
index 5931a66..0940e87 100644
--- a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/InfoCmdHeaderTest.java
+++ b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/InfoCmdHeaderTest.java
@@ -16,10 +16,10 @@
  */
 package org.apache.camel.component.docker.headers;
 
-import com.github.dockerjava.api.command.InfoCmd;
-
 import java.util.Map;
 
+import com.github.dockerjava.api.command.InfoCmd;
+
 import org.apache.camel.component.docker.DockerOperation;
 import org.junit.Test;
 import org.mockito.Mock;
@@ -36,11 +36,11 @@ public class InfoCmdHeaderTest extends BaseDockerHeaderTest<InfoCmd> {
     @Test
     public void listImageHeaderTest() {
                 
-        Map<String,Object> headers = getDefaultParameters();
+        Map<String, Object> headers = getDefaultParameters();
         
-        template.sendBodyAndHeaders("direct:in", "",headers);
+        template.sendBodyAndHeaders("direct:in", "", headers);
         
-        Mockito.verify(dockerClient,Mockito.times(1)).infoCmd();
+        Mockito.verify(dockerClient, Mockito.times(1)).infoCmd();
         
     }
 

http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/InspectContainerCmdHeaderTest.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/InspectContainerCmdHeaderTest.java b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/InspectContainerCmdHeaderTest.java
index 8bf156e..a990945 100644
--- a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/InspectContainerCmdHeaderTest.java
+++ b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/InspectContainerCmdHeaderTest.java
@@ -16,10 +16,10 @@
  */
 package org.apache.camel.component.docker.headers;
 
-import com.github.dockerjava.api.command.InspectContainerCmd;
-
 import java.util.Map;
 
+import com.github.dockerjava.api.command.InspectContainerCmd;
+
 import org.apache.camel.component.docker.DockerConstants;
 import org.apache.camel.component.docker.DockerOperation;
 import org.junit.Test;
@@ -39,13 +39,13 @@ public class InspectContainerCmdHeaderTest extends BaseDockerHeaderTest<InspectC
         
         String containerId = "9c09acd48a25";
         
-        Map<String,Object> headers = getDefaultParameters();
+        Map<String, Object> headers = getDefaultParameters();
         headers.put(DockerConstants.DOCKER_CONTAINER_ID, containerId);
 
         
-        template.sendBodyAndHeaders("direct:in", "",headers);
+        template.sendBodyAndHeaders("direct:in", "", headers);
                 
-        Mockito.verify(dockerClient,Mockito.times(1)).inspectContainerCmd(containerId);
+        Mockito.verify(dockerClient, Mockito.times(1)).inspectContainerCmd(containerId);
 
     }
 

http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/InspectImageCmdHeaderTest.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/InspectImageCmdHeaderTest.java b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/InspectImageCmdHeaderTest.java
index 1d04acb..8f82276 100644
--- a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/InspectImageCmdHeaderTest.java
+++ b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/InspectImageCmdHeaderTest.java
@@ -16,10 +16,10 @@
  */
 package org.apache.camel.component.docker.headers;
 
-import com.github.dockerjava.api.command.InspectImageCmd;
-
 import java.util.Map;
 
+import com.github.dockerjava.api.command.InspectImageCmd;
+
 import org.apache.camel.component.docker.DockerConstants;
 import org.apache.camel.component.docker.DockerOperation;
 import org.junit.Test;
@@ -39,13 +39,13 @@ public class InspectImageCmdHeaderTest extends BaseDockerHeaderTest<InspectImage
         
         String imageId = "be29975e0098";
         
-        Map<String,Object> headers = getDefaultParameters();
+        Map<String, Object> headers = getDefaultParameters();
         headers.put(DockerConstants.DOCKER_IMAGE_ID, imageId);
 
         
-        template.sendBodyAndHeaders("direct:in", "",headers);
+        template.sendBodyAndHeaders("direct:in", "", headers);
         
-        Mockito.verify(dockerClient,Mockito.times(1)).inspectImageCmd(Mockito.eq(imageId));
+        Mockito.verify(dockerClient, Mockito.times(1)).inspectImageCmd(Mockito.eq(imageId));
         
     }
 
@@ -58,7 +58,7 @@ public class InspectImageCmdHeaderTest extends BaseDockerHeaderTest<InspectImage
 
     @Override
     protected DockerOperation getOperation() {
-       return DockerOperation.INSPECT_IMAGE;
+        return DockerOperation.INSPECT_IMAGE;
     }
 
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/30b4dd35/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/KillContainerCmdHeaderTest.java
----------------------------------------------------------------------
diff --git a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/KillContainerCmdHeaderTest.java b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/KillContainerCmdHeaderTest.java
index 391220f..33ab42f 100644
--- a/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/KillContainerCmdHeaderTest.java
+++ b/components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/KillContainerCmdHeaderTest.java
@@ -16,10 +16,10 @@
  */
 package org.apache.camel.component.docker.headers;
 
-import com.github.dockerjava.api.command.KillContainerCmd;
-
 import java.util.Map;
 
+import com.github.dockerjava.api.command.KillContainerCmd;
+
 import org.apache.camel.component.docker.DockerConstants;
 import org.apache.camel.component.docker.DockerOperation;
 import org.junit.Test;
@@ -40,15 +40,15 @@ public class KillContainerCmdHeaderTest extends BaseDockerHeaderTest<KillContain
         String containerId = "9c09acd48a25";
         String signal = "signal";
         
-        Map<String,Object> headers = getDefaultParameters();
+        Map<String, Object> headers = getDefaultParameters();
         headers.put(DockerConstants.DOCKER_CONTAINER_ID, containerId);
         headers.put(DockerConstants.DOCKER_SIGNAL, signal);
 
         
-        template.sendBodyAndHeaders("direct:in", "",headers);
+        template.sendBodyAndHeaders("direct:in", "", headers);
                 
-        Mockito.verify(dockerClient,Mockito.times(1)).killContainerCmd(containerId);
-        Mockito.verify(mockObject,Mockito.times(1)).withSignal(Mockito.eq(signal));
+        Mockito.verify(dockerClient, Mockito.times(1)).killContainerCmd(containerId);
+        Mockito.verify(mockObject, Mockito.times(1)).withSignal(Mockito.eq(signal));
         
     }
 


Mime
View raw message