Class RabbitStdConsumer

java.lang.Object
com.kamikazejam.kamicommon.amqp.data.RabbitStdConsumer

public class RabbitStdConsumer extends Object
  • Constructor Details

    • RabbitStdConsumer

      public RabbitStdConsumer(@NotNull @NotNull String queueName, @NotNull @NotNull RabbitServerCallback callback, boolean autoAck)
  • Method Details

    • createConsumer

      @NotNull public @NotNull com.rabbitmq.client.DefaultConsumer createConsumer(@NotNull @NotNull com.rabbitmq.client.Channel channel)