onMessage method

gistfile1.java

	@Override
	public final void onMessage(final Message message, final Channel channel) throws IOException {
		try {
			logger.all().logInfo(String.format("Received Message: %s",message));
			Assert.notNull(message, "Unknow message: " + message);
			if (consumerEnabled()) {
				T object = getObject(message);
				this.beforeOnMessage(object);
				R response = this.onMessage(object);
				this.afterOnMessage(object);
				channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
				sendReplyMessage(message, channel, response);
			}
		} catch (ClassCastException | MessageConversionException | IllegalArgumentException | NullPointerException ex) {
			logger.file().logError(String.format("Unknow message: message=%s error=%s", message, ex.getMessage()), ex);
			logger.splunk().logError(String.format("Unknow message: message=%s error=%s", message, ex.getMessage()));
			rejectMessage(message, channel, false);
		} catch (RuntimeException ex) {
			logger.file().logError(String.format("Unexpected Error: message=%s error=%s", message, ex.getMessage()), ex);
			logger.splunk().logError(String.format("Unexpected Error: message=%s error=%s", message, ex.getMessage()));
			cleanReplyToAddress(message);
			redeliveryMessage(message, channel);
		}
	}

	/**
	 * Reject message.
	 * <p/>
	 * @param message the message
	 * @param channel the channel
	 * @param requeue the requeue
	 * <p/>
	 * @throws IOException Signals that an I/O exception has occurred.
	 */
	private void rejectMessage(final Message message, final Channel channel, boolean requeue) throws IOException {
		channel.basicReject(message.getMessageProperties().getDeliveryTag(), requeue);
	}