StompInboundChannelInterceptor.java

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.simp.stomp.StompHeaderAccessor;
import org.springframework.messaging.support.ChannelInterceptorAdapter;

public class StompInboundChannelInterceptor extends ChannelInterceptorAdapter {

    static final Log LOG = LogFactory.getLog(StompInboundChannelInterceptor.class);

    @Override
    public Message<?> preSend(Message<?> message, MessageChannel channel) {
        StompHeaderAccessor headers = StompHeaderAccessor.wrap(message);
        LOG.debug("I'm intercepting your message, command = " + headers.getCommand() + ", dest = " + headers.getDestination());
        return message;
    }
}