Package io.bitbucket.avalanchelaboratory.async.service.rabbit

Class ModuleMessageListener

java.lang.Object

io.bitbucket.avalanchelaboratory.async.service.rabbit.ModuleMessageListener

@Component
@ConditionalOnProperty(prefix="rabbit",
                       name="enabled",
                       havingValue="true")
public class ModuleMessageListener
extends Object

Constructor Summary

Constructors

Constructor	Description
ModuleMessageListener()

Method Summary

Modifier and Type	Method	Description
void	processModuleMessage(ModuleMessage message, com.rabbitmq.client.Channel channel, long tag)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ModuleMessageListener

public ModuleMessageListener()

Method Details

processModuleMessage

@RabbitListener(queues="#{rabbitQueueNameHelper.getQueueName()}")
public void processModuleMessage(ModuleMessage message,
 com.rabbitmq.client.Channel channel,
 @Header("amqp_deliveryTag")
 long tag)
                          throws IOException

Throws:

IOException