// Path: conduit/src/main/java/io/rtr/conduit/amqp/AMQPAsyncConsumerCallback.java
// public interface AMQPAsyncConsumerCallback {
//     void handle(AMQPMessageBundle messageBundle, AsyncResponse response);
//     void notifyOfActionFailure(Exception e);
//     void notifyOfShutdown(String consumerTag, ShutdownSignalException sig);
// }


import com.rabbitmq.client.MetricsCollector;
import io.rtr.conduit.amqp.AMQPAsyncConsumerCallback;
package io.rtr.conduit.amqp.impl;


public class AMQPAsyncConsumerBuilder extends AMQPConsumerBuilder<AMQPAsyncTransport
        , AMQPAsyncListenProperties
        , AMQPAsyncConsumerBuilder> {
// Path: conduit/src/main/java/io/rtr/conduit/amqp/AMQPAsyncConsumerCallback.java
// public interface AMQPAsyncConsumerCallback {
//     void handle(AMQPMessageBundle messageBundle, AsyncResponse response);
//     void notifyOfActionFailure(Exception e);
//     void notifyOfShutdown(String consumerTag, ShutdownSignalException sig);
// }


// Path: conduit/src/main/java/io/rtr/conduit/amqp/impl/AMQPAsyncConsumerBuilder.java
import com.rabbitmq.client.MetricsCollector;
import io.rtr.conduit.amqp.AMQPAsyncConsumerCallback;

package io.rtr.conduit.amqp.impl;


public class AMQPAsyncConsumerBuilder extends AMQPConsumerBuilder<AMQPAsyncTransport
        , AMQPAsyncListenProperties
        , AMQPAsyncConsumerBuilder> {
    private AMQPAsyncConsumerCallback callback;