You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by ra...@apache.org on 2015/10/07 15:33:20 UTC
[3/5] stratos git commit: Fix formatting in StratosApiV41 class
http://git-wip-us.apache.org/repos/asf/stratos/blob/f74d428e/components/org.apache.stratos.rest.endpoint/src/main/java/org/apache/stratos/rest/endpoint/api/StratosApiV41.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.rest.endpoint/src/main/java/org/apache/stratos/rest/endpoint/api/StratosApiV41.java b/components/org.apache.stratos.rest.endpoint/src/main/java/org/apache/stratos/rest/endpoint/api/StratosApiV41.java
index 9639970..c48bf09 100644
--- a/components/org.apache.stratos.rest.endpoint/src/main/java/org/apache/stratos/rest/endpoint/api/StratosApiV41.java
+++ b/components/org.apache.stratos.rest.endpoint/src/main/java/org/apache/stratos/rest/endpoint/api/StratosApiV41.java
@@ -86,8 +86,7 @@ public class StratosApiV41 extends AbstractApi {
@GET
@Path("/init")
@AuthorizationAction("/permission/admin/login")
- public Response initialize()
- throws RestAPIException {
+ public Response initialize() throws RestAPIException {
ResponseMessageBean response = new ResponseMessageBean(ResponseMessageBean.SUCCESS,
"Successfully authenticated");
return Response.ok(response).build();
@@ -129,19 +128,18 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/deploymentPolicies/manage")
- public Response addDeploymentPolicy(
- DeploymentPolicyBean deploymentPolicyDefinitionBean) throws RestAPIException {
-
+ public Response addDeploymentPolicy(DeploymentPolicyBean deploymentPolicyDefinitionBean) throws RestAPIException {
String deploymentPolicyID = deploymentPolicyDefinitionBean.getId();
try {
StratosApiV41Utils.addDeploymentPolicy(deploymentPolicyDefinitionBean);
} catch (AutoscalerServiceInvalidDeploymentPolicyExceptionException e) {
String backendErrorMessage = e.getFaultMessage().getInvalidDeploymentPolicyException().getMessage();
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, backendErrorMessage)).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, backendErrorMessage)).build();
} catch (AutoscalerServiceDeploymentPolicyAlreadyExistsExceptionException e) {
- return Response.status(Response.Status.CONFLICT).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Deployment policy already exists")).build();
+ return Response.status(Response.Status.CONFLICT)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Deployment policy already exists"))
+ .build();
}
URI url = uriInfo.getAbsolutePathBuilder().path(deploymentPolicyID).build();
return Response.created(url).entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
@@ -160,12 +158,12 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/deploymentPolicies/view")
- public Response getDeploymentPolicy(
- @PathParam("deploymentPolicyId") String deploymentPolicyId) throws RestAPIException {
+ public Response getDeploymentPolicy(@PathParam("deploymentPolicyId") String deploymentPolicyId)
+ throws RestAPIException {
DeploymentPolicyBean deploymentPolicyBean = StratosApiV41Utils.getDeployementPolicy(deploymentPolicyId);
if (deploymentPolicyBean == null) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Deployment policy not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Deployment policy not found")).build();
}
return Response.ok(deploymentPolicyBean).build();
}
@@ -181,12 +179,11 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/deploymentPolicies/view")
- public Response getDeploymentPolicies()
- throws RestAPIException {
+ public Response getDeploymentPolicies() throws RestAPIException {
DeploymentPolicyBean[] deploymentPolicies = StratosApiV41Utils.getDeployementPolicies();
if (deploymentPolicies == null || deploymentPolicies.length == 0) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "No deployment policies found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "No deployment policies found")).build();
}
return Response.ok(deploymentPolicies).build();
@@ -204,9 +201,8 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/deploymentPolicies/manage")
- public Response updateDeploymentPolicy(
- DeploymentPolicyBean deploymentPolicyDefinitionBean) throws RestAPIException {
-
+ public Response updateDeploymentPolicy(DeploymentPolicyBean deploymentPolicyDefinitionBean)
+ throws RestAPIException {
String deploymentPolicyID = deploymentPolicyDefinitionBean.getId();
// TODO :: Deployment policy validation
@@ -216,15 +212,15 @@ public class StratosApiV41 extends AbstractApi {
} catch (AutoscalerServiceInvalidPolicyExceptionException e) {
String backendErrorMessage = e.getFaultMessage().getInvalidPolicyException().getMessage();
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, backendErrorMessage)).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, backendErrorMessage)).build();
} catch (AutoscalerServiceInvalidDeploymentPolicyExceptionException e) {
String backendErrorMessage = e.getFaultMessage().getInvalidDeploymentPolicyException().getMessage();
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, backendErrorMessage)).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, backendErrorMessage)).build();
} catch (AutoscalerServiceDeploymentPolicyNotExistsExceptionException e) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Deployment policy not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Deployment policy not found")).build();
}
URI url = uriInfo.getAbsolutePathBuilder().path(deploymentPolicyID).build();
return Response.ok(url).entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
@@ -244,16 +240,16 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/deploymentPolicies/manage")
- public Response removeDeploymentPolicy(
- @PathParam("deploymentPolicyId") String deploymentPolicyId) throws RestAPIException {
+ public Response removeDeploymentPolicy(@PathParam("deploymentPolicyId") String deploymentPolicyId)
+ throws RestAPIException {
try {
StratosApiV41Utils.removeDeploymentPolicy(deploymentPolicyId);
} catch (AutoscalerServiceDeploymentPolicyNotExistsExceptionException e) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Deployment policy not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Deployment policy not found")).build();
} catch (AutoscalerServiceUnremovablePolicyExceptionException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Deployment policy is in use")).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Deployment policy is in use")).build();
}
URI url = uriInfo.getAbsolutePathBuilder().path(deploymentPolicyId).build();
return Response.ok(url).entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
@@ -273,9 +269,7 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/cartridges/manage")
- public Response addCartridge(
- CartridgeBean cartridgeDefinitionBean) throws RestAPIException {
-
+ public Response addCartridge(CartridgeBean cartridgeDefinitionBean) throws RestAPIException {
String cartridgeType = cartridgeDefinitionBean.getType();
CartridgeBean cartridgeBean = null;
try {
@@ -308,9 +302,7 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/cartridges/manage")
- public Response updateCartridge(CartridgeBean cartridgeDefinitionBean)
- throws RestAPIException {
-
+ public Response updateCartridge(CartridgeBean cartridgeDefinitionBean) throws RestAPIException {
String cartridgeType = cartridgeDefinitionBean.getType();
StratosApiV41Utils.updateCartridge(cartridgeDefinitionBean);
URI url = uriInfo.getAbsolutePathBuilder().path(cartridgeType).build();
@@ -329,14 +321,12 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/cartridges/view")
- public Response getCartridges()
- throws RestAPIException {
-
+ public Response getCartridges() throws RestAPIException {
//We pass null to searching string and multi-tenant parameter since we do not need to do any filtering
List<CartridgeBean> cartridges = StratosApiV41Utils.getAvailableCartridges(null, null, getConfigContext());
if (cartridges == null || cartridges.isEmpty()) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "No cartridges found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "No cartridges found")).build();
}
CartridgeBean[] cartridgeArray = cartridges.toArray(new CartridgeBean[cartridges.size()]);
return Response.ok().entity(cartridgeArray).build();
@@ -354,15 +344,14 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/cartridges/view")
- public Response getCartridge(
- @PathParam("cartridgeType") String cartridgeType) throws RestAPIException {
+ public Response getCartridge(@PathParam("cartridgeType") String cartridgeType) throws RestAPIException {
CartridgeBean cartridge;
try {
cartridge = StratosApiV41Utils.getCartridge(cartridgeType);
return Response.ok().entity(cartridge).build();
} catch (RestAPIException e) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Cartridge not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Cartridge not found")).build();
}
}
@@ -379,14 +368,13 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/cartridges/view")
- public Response getCartridgesByFilter(
- @DefaultValue("") @PathParam("filter") String filter, @QueryParam("criteria") String criteria)
- throws RestAPIException {
+ public Response getCartridgesByFilter(@DefaultValue("") @PathParam("filter") String filter,
+ @QueryParam("criteria") String criteria) throws RestAPIException {
List<CartridgeBean> cartridges = StratosApiV41Utils.
getCartridgesByFilter(filter, criteria, getConfigContext());
if (cartridges == null || cartridges.isEmpty()) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "No cartridges found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "No cartridges found")).build();
}
CartridgeBean[] cartridgeArray = cartridges.toArray(new CartridgeBean[cartridges.size()]);
@@ -406,15 +394,14 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/cartridges/view")
- public Response getCartridgeByFilter(
- @PathParam("cartridgeType") String cartridgeType, @DefaultValue("") @PathParam("filter") String filter)
- throws RestAPIException {
+ public Response getCartridgeByFilter(@PathParam("cartridgeType") String cartridgeType,
+ @DefaultValue("") @PathParam("filter") String filter) throws RestAPIException {
CartridgeBean cartridge;
-
cartridge = StratosApiV41Utils.getCartridgeByFilter(filter, cartridgeType, getConfigContext());
if (cartridge == null) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "No cartridges found for this filter")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "No cartridges found for this filter"))
+ .build();
}
return Response.ok().entity(cartridge).build();
@@ -432,8 +419,7 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/cartridges/manage")
- public Response removeCartridge(
- @PathParam("cartridgeType") String cartridgeType) throws RestAPIException {
+ public Response removeCartridge(@PathParam("cartridgeType") String cartridgeType) throws RestAPIException {
try {
StratosApiV41Utils.removeCartridge(cartridgeType);
return Response.ok().entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
@@ -441,13 +427,13 @@ public class StratosApiV41 extends AbstractApi {
} catch (RemoteException e) {
throw new RestAPIException(e.getMessage());
} catch (CloudControllerServiceInvalidCartridgeTypeExceptionException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, e.getFaultMessage().getInvalidCartridgeTypeException().getMessage()))
- .build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ e.getFaultMessage().getInvalidCartridgeTypeException().getMessage())).build();
} catch (CloudControllerServiceCartridgeNotFoundExceptionException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR,
- e.getFaultMessage().getCartridgeNotFoundException().getMessage())).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ e.getFaultMessage().getCartridgeNotFoundException().getMessage())).build();
}
}
@@ -465,8 +451,7 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/cartridgeGroups/manage")
- public Response addCartridgeGroup(
- CartridgeGroupBean cartridgeGroupBean) throws RestAPIException {
+ public Response addCartridgeGroup(CartridgeGroupBean cartridgeGroupBean) throws RestAPIException {
try {
StratosApiV41Utils.addCartridgeGroup(cartridgeGroupBean);
URI url = uriInfo.getAbsolutePathBuilder().path(cartridgeGroupBean.getName()).build();
@@ -475,19 +460,19 @@ public class StratosApiV41 extends AbstractApi {
String.format("Cartridge Group added successfully: [cartridge-group] %s",
cartridgeGroupBean.getName()))).build();
} catch (InvalidCartridgeGroupDefinitionException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, e.getMessage())).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, e.getMessage())).build();
} catch (ServiceGroupDefinitionException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, e.getMessage())).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, e.getMessage())).build();
} catch (AutoscalerServiceInvalidServiceGroupExceptionException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR,
- e.getFaultMessage().getInvalidServiceGroupException().getMessage())).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ e.getFaultMessage().getInvalidServiceGroupException().getMessage())).build();
} catch (CloudControllerServiceCartridgeNotFoundExceptionException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR,
- e.getFaultMessage().getCartridgeNotFoundException().getMessage())).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ e.getFaultMessage().getCartridgeNotFoundException().getMessage())).build();
}
}
@@ -503,9 +488,7 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/cartridgeGroups/manage")
- public Response updateCartridgeGroup(
- CartridgeGroupBean cartridgeGroupBean) throws RestAPIException {
-
+ public Response updateCartridgeGroup(CartridgeGroupBean cartridgeGroupBean) throws RestAPIException {
try {
StratosApiV41Utils.updateServiceGroup(cartridgeGroupBean);
URI url = uriInfo.getAbsolutePathBuilder().path(cartridgeGroupBean.getName()).build();
@@ -515,15 +498,15 @@ public class StratosApiV41 extends AbstractApi {
cartridgeGroupBean.getName()))).build();
} catch (InvalidCartridgeGroupDefinitionException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Invalid cartridge group definition")).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Invalid cartridge group definition"))
+ .build();
} catch (RestAPIException e) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Cartridge group not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Cartridge group not found")).build();
}
}
-
/**
* Gets the cartridge group definition.
*
@@ -536,15 +519,13 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/cartridgeGroups/view")
- public Response getCartridgeGroup(
- @PathParam("name") String name) throws RestAPIException {
+ public Response getCartridgeGroup(@PathParam("name") String name) throws RestAPIException {
CartridgeGroupBean serviceGroupDefinition = StratosApiV41Utils.getServiceGroupDefinition(name);
-
if (serviceGroupDefinition != null) {
return Response.ok().entity(serviceGroupDefinition).build();
} else {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Cartridge group not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Cartridge group not found")).build();
}
}
@@ -559,15 +540,13 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/cartridgeGroups/view")
- public Response getCartridgeGroups()
- throws RestAPIException {
+ public Response getCartridgeGroups() throws RestAPIException {
CartridgeGroupBean[] serviceGroups = StratosApiV41Utils.getServiceGroupDefinitions();
-
if (serviceGroups != null) {
return Response.ok().entity(serviceGroups).build();
} else {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Cartridge group not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Cartridge group not found")).build();
}
}
@@ -583,17 +562,15 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/cartridgeGroups/manage")
- public Response removeServiceGroup(
- @PathParam("name") String name) throws RestAPIException {
+ public Response removeServiceGroup(@PathParam("name") String name) throws RestAPIException {
try {
StratosApiV41Utils.removeServiceGroup(name);
} catch (AutoscalerServiceCartridgeGroupNotFoundExceptionException e) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Cartridge group not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Cartridge group not found")).build();
}
return Response.ok().entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
- String.format("Cartridge Group deleted successfully: [cartridge-group] %s", name)))
- .build();
+ String.format("Cartridge Group deleted successfully: [cartridge-group] %s", name))).build();
}
// API methods for network partitions
@@ -610,22 +587,19 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/networkPartitions/manage")
- public Response addNetworkPartition(
- NetworkPartitionBean networkPartitionBean) throws RestAPIException {
+ public Response addNetworkPartition(NetworkPartitionBean networkPartitionBean) throws RestAPIException {
String networkPartitionId = networkPartitionBean.getId();
try {
StratosApiV41Utils.addNetworkPartition(networkPartitionBean);
} catch (CloudControllerServiceNetworkPartitionAlreadyExistsExceptionException e) {
String backendErrorMessage = e.getFaultMessage().getNetworkPartitionAlreadyExistsException().getMessage();
return Response.status(Response.Status.CONFLICT)
- .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, backendErrorMessage))
- .build();
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, backendErrorMessage)).build();
} catch (CloudControllerServiceInvalidNetworkPartitionExceptionException e) {
String backendErrorMessage = e.getFaultMessage().getInvalidNetworkPartitionException().getMessage();
return Response.status(Response.Status.BAD_REQUEST)
- .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, backendErrorMessage))
- .build();
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, backendErrorMessage)).build();
}
URI url = uriInfo.getAbsolutePathBuilder().path(networkPartitionId).build();
return Response.created(url).entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
@@ -644,12 +618,11 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/networkPartitions/view")
- public Response getNetworkPartitions()
- throws RestAPIException {
+ public Response getNetworkPartitions() throws RestAPIException {
NetworkPartitionBean[] networkPartitions = StratosApiV41Utils.getNetworkPartitions();
if (networkPartitions == null || networkPartitions.length == 0) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "No network partitions found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "No network partitions found")).build();
}
return Response.ok(networkPartitions).build();
}
@@ -665,12 +638,13 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/networkPartitions/view")
- public Response getNetworkPartition(
- @PathParam("networkPartitionId") String networkPartitionId) throws RestAPIException {
+ public Response getNetworkPartition(@PathParam("networkPartitionId") String networkPartitionId)
+ throws RestAPIException {
NetworkPartitionBean networkPartition = StratosApiV41Utils.getNetworkPartition(networkPartitionId);
if (networkPartition == null) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Network partition is not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Network partition is not found"))
+ .build();
}
return Response.ok(networkPartition).build();
@@ -688,14 +662,12 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/networkPartitions/manage")
- public Response updateNetworkPartition(
- NetworkPartitionBean networkPartition) throws RestAPIException {
-
+ public Response updateNetworkPartition(NetworkPartitionBean networkPartition) throws RestAPIException {
try {
StratosApiV41Utils.updateNetworkPartition(networkPartition);
} catch (CloudControllerServiceNetworkPartitionNotExistsExceptionException e) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Network partition not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Network partition not found")).build();
}
return Response.ok().entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
String.format("Network Partition updated successfully: [network-partition] %s",
@@ -712,18 +684,18 @@ public class StratosApiV41 extends AbstractApi {
@DELETE
@Path("/networkPartitions/{networkPartitionId}")
@AuthorizationAction("/permission/admin/stratos/networkPartitions/manage")
- public Response removeNetworkPartition(
- @PathParam("networkPartitionId") String networkPartitionId) throws RestAPIException {
-
+ public Response removeNetworkPartition(@PathParam("networkPartitionId") String networkPartitionId)
+ throws RestAPIException {
try {
StratosApiV41Utils.removeNetworkPartition(networkPartitionId);
} catch (CloudControllerServiceNetworkPartitionNotExistsExceptionException e) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Network partition is not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Network partition is not found"))
+ .build();
}
return Response.ok().entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
- String.format("Network partition deleted successfully: [network-partition] %s",
- networkPartitionId))).build();
+ String.format("Network partition deleted successfully: [network-partition] %s", networkPartitionId)))
+ .build();
}
// API methods for applications
@@ -742,27 +714,26 @@ public class StratosApiV41 extends AbstractApi {
@AuthorizationAction("/permission/admin/stratos/applications/manage")
public Response addApplication(ApplicationBean applicationDefinition) throws RestAPIException {
try {
- StratosApiV41Utils.addApplication(applicationDefinition, getConfigContext(),
- getUsername(), getTenantDomain());
-
+ StratosApiV41Utils
+ .addApplication(applicationDefinition, getConfigContext(), getUsername(), getTenantDomain());
URI url = uriInfo.getAbsolutePathBuilder().path(applicationDefinition.getApplicationId()).build();
return Response.created(url).entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
String.format("Application added successfully: [application] %s",
applicationDefinition.getApplicationId()))).build();
} catch (ApplicationAlreadyExistException e) {
- return Response.status(Response.Status.CONFLICT).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Application already exists")).build();
+ return Response.status(Response.Status.CONFLICT)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Application already exists")).build();
} catch (AutoscalerServiceCartridgeNotFoundExceptionException e) {
String backendErrorMessage = e.getFaultMessage().getCartridgeNotFoundException().
getMessage();
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, backendErrorMessage)).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, backendErrorMessage)).build();
} catch (AutoscalerServiceCartridgeGroupNotFoundExceptionException e) {
String backendErrorMessage = e.getFaultMessage().getCartridgeGroupNotFoundException().
getMessage();
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, backendErrorMessage)).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, backendErrorMessage)).build();
} catch (RestAPIException e) {
throw e;
}
@@ -781,10 +752,9 @@ public class StratosApiV41 extends AbstractApi {
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applications/manage")
public Response updateApplication(ApplicationBean applicationDefinition) throws RestAPIException {
-
try {
- StratosApiV41Utils.updateApplication(applicationDefinition, getConfigContext(),
- getUsername(), getTenantDomain());
+ StratosApiV41Utils
+ .updateApplication(applicationDefinition, getConfigContext(), getUsername(), getTenantDomain());
URI url = uriInfo.getAbsolutePathBuilder().path(applicationDefinition.getApplicationId()).build();
return Response.created(url).entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
String.format("Application updated successfully: [application] %s",
@@ -792,15 +762,14 @@ public class StratosApiV41 extends AbstractApi {
} catch (AutoscalerServiceCartridgeNotFoundExceptionException e) {
String backendErrorMessage = e.getFaultMessage().getCartridgeNotFoundException().
getMessage();
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, backendErrorMessage)).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, backendErrorMessage)).build();
} catch (AutoscalerServiceCartridgeGroupNotFoundExceptionException e) {
String backendErrorMessage = e.getFaultMessage().getCartridgeGroupNotFoundException().
getMessage();
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, backendErrorMessage)).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, backendErrorMessage)).build();
}
-
}
/**
@@ -817,10 +786,9 @@ public class StratosApiV41 extends AbstractApi {
public Response getApplications() throws RestAPIException {
List<ApplicationBean> applicationDefinitions = StratosApiV41Utils.getApplications();
if (applicationDefinitions == null || applicationDefinitions.isEmpty()) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "No applications found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "No applications found")).build();
}
-
ApplicationBean[] applicationDefinitionsArray = applicationDefinitions
.toArray(new ApplicationBean[applicationDefinitions.size()]);
return Response.ok(applicationDefinitionsArray).build();
@@ -838,12 +806,11 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applications/view")
- public Response getApplication(
- @PathParam("applicationId") String applicationId) throws RestAPIException {
+ public Response getApplication(@PathParam("applicationId") String applicationId) throws RestAPIException {
ApplicationBean applicationDefinition = StratosApiV41Utils.getApplication(applicationId);
if (applicationDefinition == null) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Application not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Application not found")).build();
}
return Response.ok(applicationDefinition).build();
}
@@ -861,20 +828,20 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applications/manage")
- public Response deployApplication(
- @PathParam("applicationId") String applicationId,
+ public Response deployApplication(@PathParam("applicationId") String applicationId,
@PathParam("applicationPolicyId") String applicationPolicyId) throws RestAPIException {
try {
StratosApiV41Utils.deployApplication(applicationId, applicationPolicyId);
return Response.accepted().entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
String.format("Application deployed successfully: [application] %s", applicationId))).build();
} catch (ApplicationAlreadyDeployedException e) {
- return Response.status(Response.Status.CONFLICT).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Application policy already deployed")).build();
+ return Response.status(Response.Status.CONFLICT)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Application policy already deployed"))
+ .build();
} catch (RestAPIException e) {
if (e.getMessage().contains("Application not found")) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, e.getMessage())).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, e.getMessage())).build();
} else {
throw e;
}
@@ -893,8 +860,7 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applicationPolicies/manage")
- public Response addApplicationPolicy(
- ApplicationPolicyBean applicationPolicy) throws RestAPIException {
+ public Response addApplicationPolicy(ApplicationPolicyBean applicationPolicy) throws RestAPIException {
try {
StratosApiV41Utils.addApplicationPolicy(applicationPolicy);
URI url = uriInfo.getAbsolutePathBuilder().path(applicationPolicy.getId()).build();
@@ -903,17 +869,16 @@ public class StratosApiV41 extends AbstractApi {
applicationPolicy.getId()))).build();
} catch (AutoscalerServiceInvalidApplicationPolicyExceptionException e) {
String backendErrorMessage = e.getFaultMessage().getInvalidApplicationPolicyException().getMessage();
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, backendErrorMessage)).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, backendErrorMessage)).build();
} catch (AutoscalerServiceApplicationPolicyAlreadyExistsExceptionException e) {
- return Response.status(Response.Status.CONFLICT).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Application policy already exists")).build();
+ return Response.status(Response.Status.CONFLICT)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Application policy already exists"))
+ .build();
} catch (RestAPIException e) {
throw e;
}
-
-
}
/**
@@ -928,14 +893,14 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applicationPolicies/view")
- public Response getApplicationPolicy(
- @PathParam("applicationPolicyId") String applicationPolicyId) throws RestAPIException {
+ public Response getApplicationPolicy(@PathParam("applicationPolicyId") String applicationPolicyId)
+ throws RestAPIException {
try {
ApplicationPolicyBean applicationPolicyBean = StratosApiV41Utils.getApplicationPolicy(applicationPolicyId);
if (applicationPolicyBean == null) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Application policy not found: [application-policy] " +
- applicationPolicyId)).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ "Application policy not found: [application-policy] " + applicationPolicyId)).build();
}
return Response.ok(applicationPolicyBean).build();
} catch (ApplicationPolicyIdIsEmptyException e) {
@@ -954,12 +919,12 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applicationPolicies/view")
- public Response getApplicationPolicies()
- throws RestAPIException {
+ public Response getApplicationPolicies() throws RestAPIException {
ApplicationPolicyBean[] applicationPolicies = StratosApiV41Utils.getApplicationPolicies();
if (applicationPolicies == null || applicationPolicies.length == 0) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "No application policies found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "No application policies found"))
+ .build();
}
return Response.ok().entity(applicationPolicies).build();
}
@@ -976,26 +941,25 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applicationPolicies/manage")
- public Response removeApplicationPolicy(
- @PathParam("applicationPolicyId") String applicationPolicyId) throws RestAPIException {
+ public Response removeApplicationPolicy(@PathParam("applicationPolicyId") String applicationPolicyId)
+ throws RestAPIException {
try {
StratosApiV41Utils.removeApplicationPolicy(applicationPolicyId);
return Response.ok().entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
String.format("Application policy deleted successfully: [application-policy] %s",
applicationPolicyId))).build();
} catch (ApplicationPolicyIdIsEmptyException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Application policy id is empty"))
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Application policy id is empty"))
.build();
} catch (AutoscalerServiceInvalidPolicyExceptionException e) {
String backendErrorMessage = e.getFaultMessage().getInvalidPolicyException().getMessage();
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, backendErrorMessage))
- .build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, backendErrorMessage)).build();
} catch (AutoscalerServiceUnremovablePolicyExceptionException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "This application policy cannot be removed, since it is used in an " +
- "application"))
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ "This application policy cannot be removed, since it is used in an " + "application"))
.build();
}
}
@@ -1012,20 +976,17 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applicationPolicies/manage")
- public Response updateApplicationPolicy(
- ApplicationPolicyBean applicationPolicy) throws RestAPIException {
-
+ public Response updateApplicationPolicy(ApplicationPolicyBean applicationPolicy) throws RestAPIException {
try {
StratosApiV41Utils.updateApplicationPolicy(applicationPolicy);
} catch (AutoscalerServiceInvalidApplicationPolicyExceptionException e) {
String backendErrorMessage = e.getFaultMessage().getInvalidApplicationPolicyException().getMessage();
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, backendErrorMessage))
- .build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, backendErrorMessage)).build();
} catch (AutoscalerServiceApplicatioinPolicyNotExistsExceptionException e) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, String.format("Application policy not found: [application-policy] %s",
- applicationPolicy.getId()))).build();
+ return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ String.format("Application policy not found: [application-policy] %s", applicationPolicy.getId())))
+ .build();
}
return Response.ok().entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
String.format("Application policy updated successfully: [application-policy] %s",
@@ -1043,17 +1004,15 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applications/view")
- public Response getApplicationNetworkPartitions(
- @PathParam("applicationId") String applicationId) throws RestAPIException {
+ public Response getApplicationNetworkPartitions(@PathParam("applicationId") String applicationId)
+ throws RestAPIException {
ApplicationNetworkPartitionIdListBean appNetworkPartitionsBean = StratosApiV41Utils
.getApplicationNetworkPartitions(applicationId);
- if (appNetworkPartitionsBean == null ||
- (appNetworkPartitionsBean.getNetworkPartitionIds().size() == 1 &&
- appNetworkPartitionsBean.getNetworkPartitionIds().get(0) == null)) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "No network partitions found in the application")).build();
+ if (appNetworkPartitionsBean == null || (appNetworkPartitionsBean.getNetworkPartitionIds().size() == 1
+ && appNetworkPartitionsBean.getNetworkPartitionIds().get(0) == null)) {
+ return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ "No network partitions found in the application")).build();
}
-
return Response.ok(appNetworkPartitionsBean).build();
}
@@ -1070,10 +1029,10 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applicationSignUps/manage")
- public Response addApplicationSignUp(
- @PathParam("applicationId") String applicationId, ApplicationSignUpBean applicationSignUpBean)
- throws RestAPIException {
- StratosApiV41Utils.addApplicationSignUp(applicationId, applicationSignUpBean, CarbonContext.getThreadLocalCarbonContext().getTenantId());
+ public Response addApplicationSignUp(@PathParam("applicationId") String applicationId,
+ ApplicationSignUpBean applicationSignUpBean) throws RestAPIException {
+ StratosApiV41Utils.addApplicationSignUp(applicationId, applicationSignUpBean,
+ CarbonContext.getThreadLocalCarbonContext().getTenantId());
URI url = uriInfo.getAbsolutePathBuilder().path(applicationId).build();
return Response.created(url).entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
String.format("Successfully signed up for: [application] %s", applicationId))).build();
@@ -1091,21 +1050,21 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applicationSignUps/view")
- public Response getApplicationSignUp(
- @PathParam("applicationId") String applicationId) throws RestAPIException,
- StratosManagerServiceApplicationSignUpExceptionException {
+ public Response getApplicationSignUp(@PathParam("applicationId") String applicationId)
+ throws RestAPIException, StratosManagerServiceApplicationSignUpExceptionException {
ApplicationSignUpBean applicationSignUpBean;
try {
applicationSignUpBean = StratosApiV41Utils.getApplicationSignUp(applicationId);
if (applicationSignUpBean == null) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "No application signups found for application: [application]" +
- applicationId)).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ "No application signups found for application: [application]" + applicationId)).build();
}
return Response.ok(applicationSignUpBean).build();
} catch (ApplicationSignUpRestAPIException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Invalid request to get application signups")).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ "Invalid request to get application signups")).build();
}
}
@@ -1121,9 +1080,9 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applicationSignUps/manage")
- public Response removeApplicationSignUp(
- @PathParam("applicationId") String applicationId) throws RestAPIException {
- StratosApiV41Utils.removeApplicationSignUp(applicationId, CarbonContext.getThreadLocalCarbonContext().getTenantId());
+ public Response removeApplicationSignUp(@PathParam("applicationId") String applicationId) throws RestAPIException {
+ StratosApiV41Utils
+ .removeApplicationSignUp(applicationId, CarbonContext.getThreadLocalCarbonContext().getTenantId());
return Response.ok().entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
String.format("Application sign up removed successfully: [application] %s", applicationId))).build();
}
@@ -1142,8 +1101,8 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applicationSignUps/manage")
- public Response addApplicationSignUpForTenant(
- @PathParam("applicationId") String applicationId, ApplicationSignUpBean applicationSignUpBean, @PathParam("tenantDomain") String tenantDomain)
+ public Response addApplicationSignUpForTenant(@PathParam("applicationId") String applicationId,
+ ApplicationSignUpBean applicationSignUpBean, @PathParam("tenantDomain") String tenantDomain)
throws RestAPIException {
int contextTenantId = CarbonContext.getThreadLocalCarbonContext().getTenantId();
if (contextTenantId == -1234) {
@@ -1153,13 +1112,11 @@ public class StratosApiV41 extends AbstractApi {
return Response.created(url).entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
String.format("Successfully signed up for: [application] %s", applicationId))).build();
} else {
- return Response.status(Response.Status.METHOD_NOT_ALLOWED).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "This method not allowed")).build();
+ return Response.status(Response.Status.METHOD_NOT_ALLOWED)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "This method not allowed")).build();
}
-
}
-
/**
* Removes the application sign up on behalf of tenant.
*
@@ -1173,17 +1130,18 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applicationSignUps/manage")
- public Response removeApplicationSignUpForTenant(
- @PathParam("applicationId") String applicationId, @PathParam("tenantDomain") String tenantDomain) throws RestAPIException {
+ public Response removeApplicationSignUpForTenant(@PathParam("applicationId") String applicationId,
+ @PathParam("tenantDomain") String tenantDomain) throws RestAPIException {
int contextTenantId = CarbonContext.getThreadLocalCarbonContext().getTenantId();
if (contextTenantId == -1234) {
TenantInfoBean tenantInfo = StratosApiV41Utils.getTenantByDomain(tenantDomain);
StratosApiV41Utils.removeApplicationSignUp(applicationId, tenantInfo.getTenantId());
return Response.ok().entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
- String.format("Application sign up removed successfully: [application] %s", applicationId))).build();
+ String.format("Application sign up removed successfully: [application] %s", applicationId)))
+ .build();
} else {
- return Response.status(Response.Status.METHOD_NOT_ALLOWED).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "This method not allowed")).build();
+ return Response.status(Response.Status.METHOD_NOT_ALLOWED)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "This method not allowed")).build();
}
}
@@ -1200,15 +1158,14 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/domainMappings/manage")
- public Response addDomainMappings(
- @PathParam("applicationId") String applicationId, ApplicationDomainMappingsBean domainMappingsBean)
- throws RestAPIException {
+ public Response addDomainMappings(@PathParam("applicationId") String applicationId,
+ ApplicationDomainMappingsBean domainMappingsBean) throws RestAPIException {
try {
StratosApiV41Utils.addApplicationDomainMappings(applicationId, domainMappingsBean);
} catch (StratosManagerServiceDomainMappingExceptionException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Incorrect request to add domain mapping for " +
- "application")).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ "Incorrect request to add domain mapping for " + "application")).build();
}
List<DomainMappingBean> mappings = domainMappingsBean.getDomainMappings();
List<String> domainMappingList = new ArrayList<String>();
@@ -1217,8 +1174,7 @@ public class StratosApiV41 extends AbstractApi {
}
URI url = uriInfo.getAbsolutePathBuilder().path(applicationId).build();
return Response.created(url).entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
- String.format("Domain mappings added successfully: [domain-mappings] %s", domainMappingList)))
- .build();
+ String.format("Domain mappings added successfully: [domain-mappings] %s", domainMappingList))).build();
}
/**
@@ -1234,15 +1190,14 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/domainMappings/manage")
- public Response removeDomainMappings(
- @PathParam("applicationId") String applicationId, @PathParam("domainName") String domainName)
- throws RestAPIException {
+ public Response removeDomainMappings(@PathParam("applicationId") String applicationId,
+ @PathParam("domainName") String domainName) throws RestAPIException {
try {
StratosApiV41Utils.removeApplicationDomainMapping(applicationId, domainName);
} catch (StratosManagerServiceDomainMappingExceptionException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Incorrect request to delete domain mapping of " +
- "application")).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ "Incorrect request to delete domain mapping of " + "application")).build();
}
return Response.ok().entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
String.format("Domain mapping deleted successfully: [domain-mappings] %s", domainName))).build();
@@ -1260,21 +1215,21 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/domainMappings/view")
- public Response getDomainMappings(
- @PathParam("applicationId") String applicationId) throws RestAPIException {
+ public Response getDomainMappings(@PathParam("applicationId") String applicationId) throws RestAPIException {
List<DomainMappingBean> domainMappingsBeanList = null;
try {
domainMappingsBeanList = StratosApiV41Utils.getApplicationDomainMappings(applicationId);
if (domainMappingsBeanList == null || domainMappingsBeanList.isEmpty()) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "No domain mappings found for the application: [application-id] " +
- applicationId)).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ "No domain mappings found for the application: [application-id] " + applicationId))
+ .build();
}
} catch (StratosManagerServiceDomainMappingExceptionException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Incorrect request to get domain mappings of application: " +
- "[application-id] " + applicationId))
- .build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ "Incorrect request to get domain mappings of application: " +
+ "[application-id] " + applicationId)).build();
}
DomainMappingBean[] domainMappingsBeans = domainMappingsBeanList
@@ -1295,37 +1250,35 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applications/manage")
- public Response undeployApplication(
- @PathParam("applicationId") String applicationId, @QueryParam("force") @DefaultValue("false") boolean force)
- throws RestAPIException {
-
+ public Response undeployApplication(@PathParam("applicationId") String applicationId,
+ @QueryParam("force") @DefaultValue("false") boolean force) throws RestAPIException {
ApplicationBean applicationDefinition = StratosApiV41Utils.getApplication(applicationId);
int tenantId = CarbonContext.getThreadLocalCarbonContext().getTenantId();
if (applicationDefinition == null) {
String message = String.format("Application does not exist [application-id] %s", applicationId);
log.error(message);
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, message)).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, message)).build();
}
if (applicationDefinition.isMultiTenant() && (tenantId != -1234)) {
- String message = String.format(
- "Multi-tenant applications can only be deployed by super tenant: [application-id] %s",
- applicationId);
+ String message = String
+ .format("Multi-tenant applications can only be deployed by super tenant: [application-id] %s",
+ applicationId);
log.error(message);
throw new RestAPIException(message);
}
if (applicationDefinition.getStatus().equalsIgnoreCase(StratosApiV41Utils.APPLICATION_STATUS_CREATED)) {
- String message = String.format("Could not undeploy since application is not in DEPLOYED status " +
- "[application-id] %s [current status] %S", applicationId, applicationDefinition.getStatus());
+ String message = String.format("Could not undeploy since application is not in DEPLOYED status "
+ + "[application-id] %s [current status] %S", applicationId, applicationDefinition.getStatus());
log.error(message);
- return Response.status(Response.Status.CONFLICT).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, message)).build();
+ return Response.status(Response.Status.CONFLICT)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, message)).build();
}
StratosApiV41Utils.undeployApplication(applicationId, force);
return Response.accepted().entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
- String.format("Application undeploy process started successfully: [application-id] %s",
- applicationId))).build();
+ String.format("Application undeploy process started successfully: [application-id] %s", applicationId)))
+ .build();
}
/**
@@ -1341,14 +1294,12 @@ public class StratosApiV41 extends AbstractApi {
@Path("/applications/{applicationId}/runtime")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applications/view")
- public Response getApplicationRuntime(
- @PathParam("applicationId") String applicationId) throws RestAPIException {
-
-
+ public Response getApplicationRuntime(@PathParam("applicationId") String applicationId) throws RestAPIException {
ApplicationInfoBean applicationRuntime = StratosApiV41Utils.getApplicationRuntime(applicationId);
if (applicationRuntime == null) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Application runtime not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Application runtime not found"))
+ .build();
} else {
return Response.ok().entity(applicationRuntime).build();
}
@@ -1367,18 +1318,17 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applications/manage")
- public Response removeApplication(
- @PathParam("applicationId") String applicationId) throws RestAPIException {
+ public Response removeApplication(@PathParam("applicationId") String applicationId) throws RestAPIException {
ApplicationBean applicationDefinition = StratosApiV41Utils.getApplication(applicationId);
if (applicationDefinition == null) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Application not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Application not found")).build();
}
if (!applicationDefinition.getStatus().equalsIgnoreCase(StratosApiV41Utils.APPLICATION_STATUS_CREATED)) {
return Response.status(Response.Status.CONFLICT).entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
- String.format("Could not delete since application is not in CREATED state :" +
- " [application] %s [current-status] %S", applicationId,
+ String.format("Could not delete since application is not in CREATED state :"
+ + " [application] %s [current-status] %S", applicationId,
applicationDefinition.getStatus()))).build();
}
@@ -1400,12 +1350,12 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/autoscalingPolicies/view")
- public Response getAutoscalingPolicies()
- throws RestAPIException {
+ public Response getAutoscalingPolicies() throws RestAPIException {
AutoscalePolicyBean[] autoScalePolicies = StratosApiV41Utils.getAutoScalePolicies();
if (autoScalePolicies == null || autoScalePolicies.length == 0) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "No autoscaling policies found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "No autoscaling policies found"))
+ .build();
}
return Response.ok().entity(autoScalePolicies).build();
}
@@ -1422,12 +1372,12 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/autoscalingPolicies/view")
- public Response getAutoscalingPolicy(
- @PathParam("autoscalePolicyId") String autoscalePolicyId) throws RestAPIException {
+ public Response getAutoscalingPolicy(@PathParam("autoscalePolicyId") String autoscalePolicyId)
+ throws RestAPIException {
AutoscalePolicyBean autoScalePolicy = StratosApiV41Utils.getAutoScalePolicy(autoscalePolicyId);
if (autoScalePolicy == null) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Autoscaling policy not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Autoscaling policy not found")).build();
}
return Response.ok().entity(autoScalePolicy).build();
}
@@ -1444,9 +1394,7 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/autoscalingPolicies/manage")
- public Response addAutoscalingPolicy(
- AutoscalePolicyBean autoscalePolicy) throws RestAPIException {
-
+ public Response addAutoscalingPolicy(AutoscalePolicyBean autoscalePolicy) throws RestAPIException {
try {
StratosApiV41Utils.addAutoscalingPolicy(autoscalePolicy);
URI url = uriInfo.getAbsolutePathBuilder().path(autoscalePolicy.getId()).build();
@@ -1454,11 +1402,13 @@ public class StratosApiV41 extends AbstractApi {
String.format("Autoscaling policy added successfully: [autoscale-policy] %s",
autoscalePolicy.getId()))).build();
} catch (AutoscalerServiceInvalidPolicyExceptionException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Provided Autoscaling policy is invalid")).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ "Provided Autoscaling policy is invalid")).build();
} catch (AutoscalerServiceAutoScalingPolicyAlreadyExistExceptionException e) {
- return Response.status(Response.Status.CONFLICT).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Autoscaling policy already exists")).build();
+ return Response.status(Response.Status.CONFLICT)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Autoscaling policy already exists"))
+ .build();
} catch (RestAPIException e) {
throw e;
}
@@ -1476,14 +1426,13 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/autoscalingPolicies/manage")
- public Response updateAutoscalingPolicy(
- AutoscalePolicyBean autoscalePolicy) throws RestAPIException {
-
+ public Response updateAutoscalingPolicy(AutoscalePolicyBean autoscalePolicy) throws RestAPIException {
try {
StratosApiV41Utils.updateAutoscalingPolicy(autoscalePolicy);
} catch (AutoscalerServiceInvalidPolicyExceptionException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Autoscaling policy is invalid")).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Autoscaling policy is invalid"))
+ .build();
}
return Response.ok().entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
String.format("Autoscaling policy updated successfully: [autoscale-policy] %s",
@@ -1502,24 +1451,22 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/autoscalingPolicies/manage")
- public Response removeAutoscalingPolicy(
- @PathParam("autoscalingPolicyId") String autoscalingPolicyId) throws RestAPIException {
-
+ public Response removeAutoscalingPolicy(@PathParam("autoscalingPolicyId") String autoscalingPolicyId)
+ throws RestAPIException {
try {
StratosApiV41Utils.removeAutoscalingPolicy(autoscalingPolicyId);
} catch (AutoscalerServiceUnremovablePolicyExceptionException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Autoscaling policy is in use")).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Autoscaling policy is in use")).build();
} catch (AutoscalerServicePolicyDoesNotExistExceptionException e) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Autoscaling policy not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Autoscaling policy not found")).build();
}
return Response.ok().entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
- String.format("Autoscaling policy deleted successfully: [autoscale-policy] %s",
- autoscalingPolicyId))).build();
+ String.format("Autoscaling policy deleted successfully: [autoscale-policy] %s", autoscalingPolicyId)))
+ .build();
}
-
/**
* Get cluster for a given cluster id
*
@@ -1532,13 +1479,12 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@Consumes("application/json")
@AuthorizationAction("/permission/admin/stratos/applications/view")
- public Response getCluster(
- @PathParam("clusterId") String clusterId) throws RestAPIException {
+ public Response getCluster(@PathParam("clusterId") String clusterId) throws RestAPIException {
try {
ClusterBean clusterBean = StratosApiV41Utils.getClusterInfo(clusterId);
if (clusterBean == null) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Cluster not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Cluster not found")).build();
} else {
return Response.ok().entity(clusterBean).build();
}
@@ -1547,7 +1493,6 @@ public class StratosApiV41 extends AbstractApi {
}
}
-
// API methods for tenants
/**
@@ -1563,26 +1508,22 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@AuthorizationAction("/permission/protected")
@SuperTenantService(true)
- public Response addTenant(
- org.apache.stratos.common.beans.TenantInfoBean tenantInfoBean) throws RestAPIException {
-
+ public Response addTenant(org.apache.stratos.common.beans.TenantInfoBean tenantInfoBean) throws RestAPIException {
try {
StratosApiV41Utils.addTenant(tenantInfoBean);
URI url = uriInfo.getAbsolutePathBuilder().path(tenantInfoBean.getTenantDomain()).build();
- return Response.created(url).entity(
- new ResponseMessageBean(ResponseMessageBean.SUCCESS, String.format(
- "Tenant added successfully: [tenant] %s", tenantInfoBean.getTenantDomain()))).build();
+ return Response.created(url).entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
+ String.format("Tenant added successfully: [tenant] %s", tenantInfoBean.getTenantDomain()))).build();
} catch (InvalidEmailException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, String.format("Invalid email: [email] %s",
- tenantInfoBean.getEmail()))).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ String.format("Invalid email: [email] %s", tenantInfoBean.getEmail()))).build();
} catch (InvalidDomainException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, String.format("Invalid domain: [domain] %s",
- tenantInfoBean.getTenantDomain()))).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ String.format("Invalid domain: [domain] %s", tenantInfoBean.getTenantDomain()))).build();
}
-
}
/**
@@ -1597,31 +1538,29 @@ public class StratosApiV41 extends AbstractApi {
@Consumes("application/json")
@AuthorizationAction("/permission/protected")
@SuperTenantService(true)
- public Response updateTenant(
- org.apache.stratos.common.beans.TenantInfoBean tenantInfoBean) throws RestAPIException {
-
+ public Response updateTenant(org.apache.stratos.common.beans.TenantInfoBean tenantInfoBean)
+ throws RestAPIException {
try {
StratosApiV41Utils.updateExistingTenant(tenantInfoBean);
return Response.ok().entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
- String.format("Tenant updated successfully: [tenant] %s",
- tenantInfoBean.getTenantDomain()))).build();
+ String.format("Tenant updated successfully: [tenant] %s", tenantInfoBean.getTenantDomain())))
+ .build();
} catch (TenantNotFoundException ex) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Tenant not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Tenant not found")).build();
} catch (InvalidEmailException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, String.format("Invalid email [email] %s",
- tenantInfoBean.getEmail()))).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ String.format("Invalid email [email] %s", tenantInfoBean.getEmail()))).build();
} catch (InvalidDomainException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, String.format("Invalid Domain [Domain] %s",
- tenantInfoBean.getTenantDomain()))).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
+ String.format("Invalid Domain [Domain] %s", tenantInfoBean.getTenantDomain()))).build();
} catch (Exception e) {
String msg = "Error in updating tenant " + tenantInfoBean.getTenantDomain();
log.error(msg, e);
throw new RestAPIException(msg);
}
-
}
/**
@@ -1637,14 +1576,13 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@AuthorizationAction("/permission/protected")
@SuperTenantService(true)
- public Response getTenantForDomain(
- @PathParam("tenantDomain") String tenantDomain) throws RestAPIException {
-
+ public Response getTenantForDomain(@PathParam("tenantDomain") String tenantDomain) throws RestAPIException {
try {
TenantInfoBean tenantInfo = StratosApiV41Utils.getTenantByDomain(tenantDomain);
if (tenantInfo == null) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Tenant information not found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Tenant information not found"))
+ .build();
}
return Response.ok().entity(tenantInfo).build();
} catch (Exception e) {
@@ -1667,12 +1605,10 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@AuthorizationAction("/permission/protected")
@SuperTenantService(true)
- public Response removeTenant(
- @PathParam("tenantDomain") String tenantDomain) throws RestAPIException {
-
+ public Response removeTenant(@PathParam("tenantDomain") String tenantDomain) throws RestAPIException {
return Response.status(Response.Status.NOT_ACCEPTABLE)
- .entity(new ResponseMessageBean(ResponseMessageBean.ERROR,
- "Please use the tenant deactivate method")).build();
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Please use the tenant deactivate method"))
+ .build();
}
/**
@@ -1686,17 +1622,16 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@AuthorizationAction("/permission/protected")
@SuperTenantService(true)
- public Response getTenants()
- throws RestAPIException {
+ public Response getTenants() throws RestAPIException {
try {
List<org.apache.stratos.common.beans.TenantInfoBean> tenantList = StratosApiV41Utils.getAllTenants();
if (tenantList == null || tenantList.isEmpty()) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "No tenants found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "No tenants found")).build();
}
-
- return Response.ok().entity(tenantList.toArray(
- new org.apache.stratos.common.beans.TenantInfoBean[tenantList.size()])).build();
+ return Response.ok()
+ .entity(tenantList.toArray(new org.apache.stratos.common.beans.TenantInfoBean[tenantList.size()]))
+ .build();
} catch (Exception e) {
String msg = "Error in retrieving tenants";
log.error(msg, e);
@@ -1704,7 +1639,6 @@ public class StratosApiV41 extends AbstractApi {
}
}
-
/**
* Gets the partial search tenants.
*
@@ -1718,19 +1652,17 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@AuthorizationAction("/permission/protected")
@SuperTenantService(true)
- public Response getPartialSearchTenants(
- @PathParam("tenantDomain") String tenantDomain) throws RestAPIException {
-
+ public Response getPartialSearchTenants(@PathParam("tenantDomain") String tenantDomain) throws RestAPIException {
try {
- List<org.apache.stratos.common.beans.TenantInfoBean> tenantList =
- StratosApiV41Utils.searchPartialTenantsDomains(tenantDomain);
+ List<org.apache.stratos.common.beans.TenantInfoBean> tenantList = StratosApiV41Utils
+ .searchPartialTenantsDomains(tenantDomain);
if (tenantList == null || tenantList.isEmpty()) {
- return Response.status(Response.Status.NOT_FOUND).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "No tenants found")).build();
+ return Response.status(Response.Status.NOT_FOUND)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "No tenants found")).build();
}
-
- return Response.ok().entity(tenantList.toArray(
- new org.apache.stratos.common.beans.TenantInfoBean[tenantList.size()])).build();
+ return Response.ok()
+ .entity(tenantList.toArray(new org.apache.stratos.common.beans.TenantInfoBean[tenantList.size()]))
+ .build();
} catch (Exception e) {
String msg = "Error in getting information for tenant " + tenantDomain;
log.error(msg, e);
@@ -1738,7 +1670,6 @@ public class StratosApiV41 extends AbstractApi {
}
}
-
/**
* Activate tenant.
*
@@ -1752,14 +1683,12 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@AuthorizationAction("/permission/protected")
@SuperTenantService(true)
- public Response activateTenant(
- @PathParam("tenantDomain") String tenantDomain) throws RestAPIException {
-
+ public Response activateTenant(@PathParam("tenantDomain") String tenantDomain) throws RestAPIException {
try {
StratosApiV41Utils.activateTenant(tenantDomain);
} catch (InvalidDomainException e) {
- return Response.status(Response.Status.BAD_REQUEST).entity(new ResponseMessageBean(
- ResponseMessageBean.ERROR, "Invalid domain")).build();
+ return Response.status(Response.Status.BAD_REQUEST)
+ .entity(new ResponseMessageBean(ResponseMessageBean.ERROR, "Invalid domain")).build();
}
return Response.ok().entity(new ResponseMessageBean(ResponseMessageBean.SUCCESS,
@@ -1779,16 +1708,13 @@ public class StratosApiV41 extends AbstractApi {
@Produces("application/json")
@AuthorizationAction("/permission/protected")
@SuperTenantService(true)
- public Response deactivateTenant
<TRUNCATED>