Skip to content

Commit

Permalink
User ApiUtils#emptyPayload
Browse files Browse the repository at this point in the history
  • Loading branch information
tsegismont committed May 19, 2015
1 parent 009afd7 commit 95fe622
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 12 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@

import static org.hawkular.metrics.api.jaxrs.filter.TenantFilter.TENANT_HEADER_NAME;
import static org.hawkular.metrics.api.jaxrs.util.ApiUtils.badRequest;
import static org.hawkular.metrics.api.jaxrs.util.ApiUtils.emptyPayload;
import static org.hawkular.metrics.api.jaxrs.util.ApiUtils.executeAsync;

import java.net.URI;
Expand All @@ -46,7 +47,6 @@
import javax.ws.rs.container.Suspended;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.Response;
import javax.ws.rs.core.Response.Status;
import javax.ws.rs.core.UriInfo;

import org.hawkular.metrics.api.jaxrs.ApiError;
Expand Down Expand Up @@ -105,8 +105,7 @@ public void createAvailabilityMetric(
@Context UriInfo uriInfo
) {
if (metric == null) {
Response response = Response.status(Status.BAD_REQUEST).entity(new ApiError("Payload is empty")).build();
asyncResponse.resume(response);
asyncResponse.resume(emptyPayload());
return;
}
metric.setTenantId(tenantId);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@

import static org.hawkular.metrics.api.jaxrs.filter.TenantFilter.TENANT_HEADER_NAME;
import static org.hawkular.metrics.api.jaxrs.util.ApiUtils.badRequest;
import static org.hawkular.metrics.api.jaxrs.util.ApiUtils.emptyPayload;
import static org.hawkular.metrics.api.jaxrs.util.ApiUtils.executeAsync;

import java.net.URI;
Expand All @@ -48,7 +49,6 @@
import javax.ws.rs.container.Suspended;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.Response;
import javax.ws.rs.core.Response.Status;
import javax.ws.rs.core.UriInfo;

import org.hawkular.metrics.api.jaxrs.ApiError;
Expand Down Expand Up @@ -112,8 +112,7 @@ public void createGaugeMetric(
@Context UriInfo uriInfo
) {
if (metric == null) {
Response response = Response.status(Status.BAD_REQUEST).entity(new ApiError("Payload is empty")).build();
asyncResponse.resume(response);
asyncResponse.resume(emptyPayload());
return;
}
metric.setTenantId(tenantId);
Expand Down Expand Up @@ -214,7 +213,7 @@ public void addDataForMetric(
List<GaugeData> data
) {
if (data.isEmpty()) {
asyncResponse.resume(badRequest(new ApiError("Payload is empty")));
asyncResponse.resume(emptyPayload());
} else {
Gauge metric = new Gauge(tenantId, new MetricId(id));
metric.getData().addAll(data);
Expand All @@ -237,7 +236,7 @@ public void addGaugeData(@Suspended final AsyncResponse asyncResponse,
@ApiParam(value = "List of metrics", required = true) List<Gauge> metrics) {

if (metrics.isEmpty()) {
asyncResponse.resume(badRequest(new ApiError("Payload is empty")));
asyncResponse.resume(emptyPayload());
} else {
metrics.forEach(m -> m.setTenantId(tenantId));
Observable<Void> observable = metricsService.addGaugeData(Observable.from(metrics));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@
import static javax.ws.rs.core.MediaType.APPLICATION_JSON;

import static org.hawkular.metrics.api.jaxrs.util.ApiUtils.collectionToResponse;
import static org.hawkular.metrics.api.jaxrs.util.ApiUtils.emptyPayload;
import static org.hawkular.metrics.api.jaxrs.util.ApiUtils.serverError;

import java.net.URI;
Expand All @@ -32,8 +33,6 @@
import javax.ws.rs.container.AsyncResponse;
import javax.ws.rs.container.Suspended;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.Response;
import javax.ws.rs.core.Response.Status;
import javax.ws.rs.core.UriInfo;

import org.hawkular.metrics.api.jaxrs.ApiError;
Expand Down Expand Up @@ -78,8 +77,7 @@ public void createTenant(
@Context UriInfo uriInfo
) {
if (params == null) {
Response response = Response.status(Status.BAD_REQUEST).entity(new ApiError("Payload is empty")).build();
asyncResponse.resume(response);
asyncResponse.resume(emptyPayload());
return;
}
URI location = uriInfo.getBaseUriBuilder().path("/tenants").build();
Expand Down

0 comments on commit 95fe622

Please sign in to comment.