@ RabbitListener ( queues = "${hawkbit.dmf.rabbitmq.receiverQueue:dmf_receiver}" , containerFactory = "listenerContainerFactory" ) public Message onMessage ( final Message message , @ Header ( name = MessageHeaderKey . TYPE , required = false ) final String type , @ Header ( name = MessageHeaderKey . TENANT , required = false ) final String tenant ) { return onMessage ( message , type , tenant , getRabbitTemplate ( ) . getConnectionFactory ( ) . getVirtualHost ( ) ) ; }
Method to handle all incoming DMF amqp messages .