summaryrefslogtreecommitdiffstats
path: root/src/main/java/org/onap/dcaegen2/services/pmmapper/datarouter/DeliveryHandler.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/org/onap/dcaegen2/services/pmmapper/datarouter/DeliveryHandler.java')
-rw-r--r--src/main/java/org/onap/dcaegen2/services/pmmapper/datarouter/DeliveryHandler.java29
1 files changed, 8 insertions, 21 deletions
diff --git a/src/main/java/org/onap/dcaegen2/services/pmmapper/datarouter/DeliveryHandler.java b/src/main/java/org/onap/dcaegen2/services/pmmapper/datarouter/DeliveryHandler.java
index ba218cb..1ba67ec 100644
--- a/src/main/java/org/onap/dcaegen2/services/pmmapper/datarouter/DeliveryHandler.java
+++ b/src/main/java/org/onap/dcaegen2/services/pmmapper/datarouter/DeliveryHandler.java
@@ -20,6 +20,8 @@
package org.onap.dcaegen2.services.pmmapper.datarouter;
+import static io.undertow.util.Methods.PUT_STRING;
+
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.google.gson.JsonParseException;
@@ -30,11 +32,10 @@ import lombok.NonNull;
import org.onap.dcaegen2.services.pmmapper.exceptions.NoMetadataException;
import org.onap.dcaegen2.services.pmmapper.model.EventMetadata;
import org.onap.dcaegen2.services.pmmapper.model.Event;
-import io.undertow.server.HttpHandler;
import io.undertow.server.HttpServerExchange;
import io.undertow.util.StatusCodes;
-import org.onap.dcaegen2.services.pmmapper.model.ServerHandler;
+import org.onap.dcaegen2.services.pmmapper.model.ServerResource;
import org.onap.dcaegen2.services.pmmapper.utils.HttpServerExchangeAdapter;
import org.onap.dcaegen2.services.pmmapper.utils.RequiredFieldDeserializer;
import org.onap.logging.ref.slf4j.ONAPLogAdapter;
@@ -48,7 +49,7 @@ import java.util.Optional;
* Provides an undertow HttpHandler to be used as an endpoint for data router to send events to.
*/
@Data
-public class DeliveryHandler implements HttpHandler, ServerHandler {
+public class DeliveryHandler extends ServerResource {
public static final String METADATA_HEADER = "X-DMAAP-DR-META";
public static final String PUB_ID_HEADER = "X-DMAAP-DR-PUBLISH-ID";
@@ -57,8 +58,8 @@ public class DeliveryHandler implements HttpHandler, ServerHandler {
private static final String BAD_METADATA_MESSAGE = "Malformed Metadata.";
private static final String NO_METADATA_MESSAGE = "Missing Metadata.";
- private static final String METHOD = "put";
- private static final String ENDPOINT_TEMPLATE = "/delivery/{filename}";
+ private static final String HTTP_METHOD = PUT_STRING;
+ private static final String DELIVERY_ENDPOINT = "/delivery/{filename}";
private Gson metadataBuilder;
@@ -69,6 +70,7 @@ public class DeliveryHandler implements HttpHandler, ServerHandler {
* @param eventReceiver receiver for any inbound events.
*/
public DeliveryHandler(EventReceiver eventReceiver) {
+ super(HTTP_METHOD, DELIVERY_ENDPOINT);
this.eventReceiver = eventReceiver;
this.metadataBuilder = new GsonBuilder()
.registerTypeAdapter(EventMetadata.class, new RequiredFieldDeserializer<EventMetadata>())
@@ -92,7 +94,7 @@ public class DeliveryHandler implements HttpHandler, ServerHandler {
*/
@Override
public void handleRequest(HttpServerExchange httpServerExchange) {
- try{
+ try {
logger.entering(new HttpServerExchangeAdapter(httpServerExchange));
try {
Map<String,String> mdc = MDC.getCopyOfContextMap();
@@ -119,19 +121,4 @@ public class DeliveryHandler implements HttpHandler, ServerHandler {
logger.exiting();
}
}
-
- @Override
- public String getMethod() {
- return METHOD;
- }
-
- @Override
- public String getTemplate() {
- return ENDPOINT_TEMPLATE;
- }
-
- @Override
- public HttpHandler getHandler() {
- return this;
- }
}