code: @Override
      public void handleMessage(Message message) throws Fault {
  
          //ignore the messages from SAM Server service itself
          BindingOperationInfo boi = message.getExchange().getBindingOperationInfo();
          if (null != boi){
              String operationName = boi.getName().toString();
              if (SAM_OPERATION.equals(operationName)) {
                  return;
              }
          }
  
          if (isRestWadlRequest(message)) {
              // skip handling REST service WADL requests - temporary fix since will be fixed in CXF soon
              return;
          }
  
          if (isOnewayResponse(message)) {
              // skip oneway response events
              return;
          }
  
          // Skip Swagger UI web static, swagger.json and swagger.yaml requests
          if (isSwaggerResourceRequest(message)) {
              return;
          }
  
          //check MessageID
          checkMessageID(message);
  
          Event event = mapper.mapToEvent(message);
  
          if (LOG.isLoggable(Level.FINE)) {
              String id = (event.getMessageInfo() != null) ? event.getMessageInfo().getMessageId() : null;
              LOG.fine("Store event [message_id=" + id + "] in cache.");
          }
          if (null != event) {
              queue.add(event);
          }
  
          // TESB-20624 skip duplicated event processing
          message.getInterceptorChain().remove(this);
      }
docs: /* (non-Javadoc)
  @see org.apache.cxf.interceptor.Interceptor#handleMessage(org.apache.cxf.message.Message)