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


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


public class AMQPSyncConsumerBuilder extends AMQPConsumerBuilder<AMQPTransport
        , AMQPListenProperties
        , AMQPSyncConsumerBuilder> {
// Path: conduit/src/main/java/io/rtr/conduit/amqp/AMQPConsumerCallback.java
// public interface AMQPConsumerCallback {
//     ActionResponse handle(AMQPMessageBundle messageBundle);
//     void notifyOfActionFailure(Exception e);
//     void notifyOfShutdown(String consumerTag, ShutdownSignalException sig);
// }


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

package io.rtr.conduit.amqp.impl;


public class AMQPSyncConsumerBuilder extends AMQPConsumerBuilder<AMQPTransport
        , AMQPListenProperties
        , AMQPSyncConsumerBuilder> {
    private AMQPConsumerCallback callback;