private class AmqpAcquisition.AmqpConsumer
extends com.rabbitmq.client.DefaultConsumer
Constructor and Description |
---|
AmqpAcquisition.AmqpConsumer(com.rabbitmq.client.Channel channel,
String name) |
Modifier and Type | Method and Description |
---|---|
void |
handleDelivery(String consumerTag,
com.rabbitmq.client.Envelope envelope,
com.rabbitmq.client.AMQP.BasicProperties properties,
byte[] body) |
void |
handleShutdownSignal(String consumerTag,
com.rabbitmq.client.ShutdownSignalException sig) |
private String name
public AmqpAcquisition.AmqpConsumer(com.rabbitmq.client.Channel channel, String name)
public void handleDelivery(String consumerTag, com.rabbitmq.client.Envelope envelope, com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body) throws IOException
handleDelivery
in interface com.rabbitmq.client.Consumer
handleDelivery
in class com.rabbitmq.client.DefaultConsumer
IOException
public void handleShutdownSignal(String consumerTag, com.rabbitmq.client.ShutdownSignalException sig)
handleShutdownSignal
in interface com.rabbitmq.client.Consumer
handleShutdownSignal
in class com.rabbitmq.client.DefaultConsumer
Copyright © 2015 ScalAgent D.T.. All Rights Reserved.