@Override
		public MessageProperties toMessageProperties(AMQP.BasicProperties source, Envelope envelope,
				String charset) {
			MessageProperties properties = super.toMessageProperties(source, envelope, charset);
			properties.setDeliveryMode(null);
			return properties;
		}
Basic producer + basic consumer + concurrency + reply headers.
spring-xd-messagebus-rabbit/src/main/java/org/springframework/xd/dirt/integration/rabbit/RabbitMessageBus.java