@Test
void shouldSetTheOriginalMessageExchangeOnInTheHeaders() {

	message.getMessageProperties().setReceivedExchange("the.original.exchange");
	recoverer = new RepublishMessageRecoverer(amqpTemplate, "error");
	recoverer.recover(message, cause);
	assertThat(message.getMessageProperties().getHeaders().get("x-original-exchange")).isEqualTo("the.original.exchange");
}