Added pause/unpause commands

Marcus Linke · Marcus Linke · commit ee778e2a07d7 · 2014-07-14T21:38:05.000+02:00
diff --git a/src/main/java/com/github/dockerjava/client/command/PauseContainerCmd.java b/src/main/java/com/github/dockerjava/client/command/PauseContainerCmd.java
@@ -0,0 +1,66 @@
+package com.github.dockerjava.client.command;
+
+import javax.ws.rs.core.MediaType;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.github.dockerjava.client.DockerException;
+import com.google.common.base.Preconditions;
+import com.sun.jersey.api.client.ClientResponse;
+import com.sun.jersey.api.client.UniformInterfaceException;
+import com.sun.jersey.api.client.WebResource;
+
+/**
+ * Pause a container.
+ * 
+ * @param containerId - Id of the container
+ * 
+ */
+public class PauseContainerCmd extends AbstrDockerCmd<PauseContainerCmd, Integer> {
+
+	private static final Logger LOGGER = LoggerFactory.getLogger(PauseContainerCmd.class);
+
+	private String containerId;
+	
+	public PauseContainerCmd(String containerId) {
+		withContainerId(containerId);
+	}
+	
+	public PauseContainerCmd withContainerId(String containerId) {
+		Preconditions.checkNotNull(containerId, "containerId was not specified");
+		this.containerId = containerId;
+		return this;
+	}
+	
+	@Override
+    public String toString() {
+        return new StringBuilder("pause ")
+            .append(containerId)
+            .toString();
+    }   
+
+	protected Integer impl() throws DockerException {
+		WebResource webResource = baseResource.path(String.format("/containers/%s/pause", containerId));
+
+		ClientResponse response = null;
+		
+		try {
+			LOGGER.trace("POST: {}", webResource);
+			response = webResource.accept(MediaType.APPLICATION_JSON).type(MediaType.APPLICATION_JSON).post(ClientResponse.class);
+		} catch (UniformInterfaceException exception) {
+			if (exception.getResponse().getStatus() == 404) {
+				LOGGER.warn("No such container {}", containerId);
+			} else if (exception.getResponse().getStatus() == 204) {
+				//no error
+				LOGGER.trace("Successfully paused container {}", containerId);
+			} else if (exception.getResponse().getStatus() == 500) {
+				throw new DockerException("Server error", exception);
+			} else {
+				throw new DockerException(exception);
+			}
+		}
+		
+		return response.getStatus();
+	}
+}
diff --git a/src/main/java/com/github/dockerjava/client/command/UnpauseContainerCmd.java b/src/main/java/com/github/dockerjava/client/command/UnpauseContainerCmd.java
@@ -0,0 +1,66 @@
+package com.github.dockerjava.client.command;
+
+import javax.ws.rs.core.MediaType;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.github.dockerjava.client.DockerException;
+import com.google.common.base.Preconditions;
+import com.sun.jersey.api.client.ClientResponse;
+import com.sun.jersey.api.client.UniformInterfaceException;
+import com.sun.jersey.api.client.WebResource;
+
+/**
+ * Unpause a container.
+ * 
+ * @param containerId - Id of the container
+ * 
+ */
+public class UnpauseContainerCmd extends AbstrDockerCmd<UnpauseContainerCmd, Integer> {
+
+	private static final Logger LOGGER = LoggerFactory.getLogger(UnpauseContainerCmd.class);
+
+	private String containerId;
+	
+	public UnpauseContainerCmd(String containerId) {
+		withContainerId(containerId);
+	}
+	
+	public UnpauseContainerCmd withContainerId(String containerId) {
+		Preconditions.checkNotNull(containerId, "containerId was not specified");
+		this.containerId = containerId;
+		return this;
+	}
+	
+	@Override
+    public String toString() {
+        return new StringBuilder("pause ")
+            .append(containerId)
+            .toString();
+    }   
+
+	protected Integer impl() throws DockerException {
+		WebResource webResource = baseResource.path(String.format("/containers/%s/unpause", containerId));
+
+		ClientResponse response = null;
+		
+		try {
+			LOGGER.trace("POST: {}", webResource);
+			response = webResource.accept(MediaType.APPLICATION_JSON).type(MediaType.APPLICATION_JSON).post(ClientResponse.class);
+		} catch (UniformInterfaceException exception) {
+			if (exception.getResponse().getStatus() == 404) {
+				LOGGER.warn("No such container {}", containerId);
+			} else if (exception.getResponse().getStatus() == 204) {
+				//no error
+				LOGGER.trace("Successfully paused container {}", containerId);
+			} else if (exception.getResponse().getStatus() == 500) {
+				throw new DockerException("Server error", exception);
+			} else {
+				throw new DockerException(exception);
+			}
+		}
+		
+		return response.getStatus();
+	}
+}
