InInterceptor

package es.sinjava.data;

import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.concurrent.atomic.AtomicLong;

import javax.annotation.PostConstruct;

import org.apache.cxf.message.Exchange;
import org.apache.cxf.message.Message;
import org.apache.cxf.phase.AbstractPhaseInterceptor;
import org.apache.cxf.phase.Phase;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

/**
 * Interceptor para controlar de forma transparente lo que entra: temas de
 * seguridad /etc etc
 *
 * @author [email protected]
 *
 */
@Component
public class InInterceptor extends AbstractPhaseInterceptor<Message> {

    private static final Logger LOG = LoggerFactory.getLogger(InInterceptor.class);

    private AtomicLong accessCounter = new AtomicLong(0);

    public InInterceptor() {
        super(Phase.READ);
    }

    public InInterceptor(String phase) {
        super(phase);
    }

    public void handleMessage(Message message) {

        LOG.debug("------ A la escucha el filtro {} ------------------------", accessCounter.getAndIncrement());
        String localeQuery = (String) message.get(Message.QUERY_STRING);

        LOG.debug("La consultad de la query :" + localeQuery);

        Map<String, List<String>> headers = (Map<String, List<String>>) message.get(Message.PROTOCOL_HEADERS);
        for (String head : headers.keySet()) {
            // me llega en la cabera lo que quiero en el sitio apropiado
            // else throw ChuckNorrisException
            LOG.debug("Cabecera : " + head);
        }
        String endpointURL = (String) message.get(Message.PATH_INFO);
        LOG.debug("Este es el metodo llamado :" + endpointURL);
        LOG.debug("Consulta final {}", message.get(Message.QUERY_STRING));
          Exchange exchange = message.getExchange();
          for( Entry<String, Object> entry:exchange.entrySet()){
              LOG.debug(entry.getKey()+ "  - " + entry.getValue().toString());
          }
    }
    @PostConstruct
    public void listening() {
        LOG.debug("------ A la escucha el filtro {} ---------", accessCounter.getAndIncrement());
    }
}