src/main/java/org/onap/dmaap/DMaaPCambriaExceptionMapper.java

   1 /*******************************************************************************
   2  *  ============LICENSE_START=======================================================
   3  *  org.onap.dmaap
   4  *  ================================================================================
   5  *  Copyright © 2017 AT&T Intellectual Property. All rights reserved.
   6  *  ================================================================================
   7  *  Licensed under the Apache License, Version 2.0 (the "License");
   8  *  you may not use this file except in compliance with the License.
   9  *  You may obtain a copy of the License at
  10  *        http://www.apache.org/licenses/LICENSE-2.0
  11 *
  12  *  Unless required by applicable law or agreed to in writing, software
  13  *  distributed under the License is distributed on an "AS IS" BASIS,
  14  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  *  See the License for the specific language governing permissions and
  16  *  limitations under the License.
  17  *  ============LICENSE_END=========================================================
  18  *
  19  *  ECOMP is a trademark and service mark of AT&T Intellectual Property.
  20  *
  21  *******************************************************************************/
  22  package org.onap.dmaap;
  23
  24
  25 import com.att.eelf.configuration.EELFLogger;
  26 import com.att.eelf.configuration.EELFManager;
  27 import javax.inject.Singleton;
  28 import javax.servlet.http.HttpServletRequest;
  29 import javax.servlet.http.HttpServletResponse;
  30 import javax.ws.rs.core.Context;
  31 import javax.ws.rs.core.Response;
  32 import javax.ws.rs.ext.ExceptionMapper;
  33 import javax.ws.rs.ext.Provider;
  34 import org.onap.dmaap.dmf.mr.CambriaApiException;
  35 import org.onap.dmaap.dmf.mr.exception.DMaaPErrorMessages;
  36 import org.onap.dmaap.dmf.mr.exception.ErrorResponse;
  37 import org.springframework.beans.factory.annotation.Autowired;
  38
  39 /**
  40  * Exception Mapper class to handle
  41  * CambriaApiException
  42  * @author rajashree.khare
  43  *
  44  */
  45 @Provider
  46 @Singleton
  47 public class DMaaPCambriaExceptionMapper implements ExceptionMapper<CambriaApiException>{
  48
  49 /**
  50  * Error response obj
  51  */
  52         private ErrorResponse errRes;
  53
  54 /**
  55  * Logger obj
  56  */
  57
  58
  59         private static final EELFLogger LOGGER = EELFManager.getInstance().getLogger(DMaaPCambriaExceptionMapper.class);
  60
  61
  62         /**
  63          * Error msg obj
  64          */
  65         @Autowired
  66         private DMaaPErrorMessages msgs;
  67
  68         /**
  69          * HttpServletRequest obj
  70          */
  71         @Context
  72         private HttpServletRequest req;
  73
  74         /**
  75          * HttpServletResponse obj
  76          */
  77         @Context
  78         private HttpServletResponse res;
  79
  80         /**
  81          * Contructor for DMaaPCambriaExceptionMapper
  82          */
  83         public DMaaPCambriaExceptionMapper() {
  84                 super();
  85                 LOGGER.info("Cambria Exception Mapper Created..");
  86         }
  87
  88         /**
  89          * The toResponse method is called when
  90          * an exception of type CambriaApiException
  91          * is thrown.This method will send a custom error
  92          * response to the client.
  93          */
  94         @Override
  95         public Response toResponse(CambriaApiException ex) {
  96
  97                 LOGGER.info("Reached Cambria Exception Mapper..");
  98
  99                 /**
 100                  * Cambria Generic Exception
 101                  */
 102                 /*if(ex instanceof CambriaApiException)
 103                 {*/
 104
 105                         errRes = ex.getErrRes();
 106                         if(errRes!=null) {
 107
 108                                 Response response = Response.status(errRes.getHttpStatusCode()).header("exception",
 109                                                 errRes.getErrMapperStr()).build();
 110
 111                                 return response;
 112                         }
 113                         else
 114                         {
 115
 116                                 Response response = Response.status(ex.getStatus()).header("exception",
 117                                                 ex.getMessage()).build();
 118
 119                                 return response;
 120                         }
 121
 122
 123                 /*}
 124                 else
 125                 {
 126                         errRes = new ErrorResponse(HttpStatus.SC_NOT_FOUND,
 127                                         DMaaPResponseCode.SERVER_UNAVAILABLE.getResponseCode(), msgs.getServerUnav());
 128
 129                         Response response = Response.status(errRes.getHttpStatusCode()).header("exception",
 130                                         errRes.getErrMapperStr()).build();
 131
 132                         return response;
 133                 }*/
 134
 135         }
 136
 137
 138
 139 }