侦听消息队列的Message Listener类示例详解

public class MessageReceive extends AbstractAdaptableMessageListener {
    private static final Logger LOGGER = LoggerFactory.getLogger(MessageReceive.class);
    @Override
    public void onMessage(Message message, Channel channel) throws Exception {
        LOGGER.info("receive message:{}", new String(message.getBody(), "UTF-8"));
    }
}

@FunctionalInterface
public interface MessageListener {
	void onMessage(Message message);
}

@FunctionalInterface
public interface ChannelAwareMessageListener {
	/**
	 * Callback for processing a received Rabbit message.
	 * <p>Implementors are supposed to process the given Message,
	 * typically sending reply messages through the given Session.
	 * @param message the received AMQP message (never <code>null</code>)
	 * @param channel the underlying Rabbit Channel (never <code>null</code>)
	 * @throws Exception Any.
	 */
	void onMessage(Message message, Channel channel) throws Exception;
}

@Override
	public void onMessage(Message message) {
		try {
			onMessage(message, null);
		}
		catch (Exception e) {
			throw new ListenerExecutionFailedException("Listener threw exception", e, message);
		}
	}