diff --git a/src/main/java/com/rabbitmq/client/amqp/Management.java b/src/main/java/com/rabbitmq/client/amqp/Management.java index badbe2bff..b71b4e91e 100644 --- a/src/main/java/com/rabbitmq/client/amqp/Management.java +++ b/src/main/java/com/rabbitmq/client/amqp/Management.java @@ -178,7 +178,7 @@ interface QueueSpecification { * @see Overflow * Behavior */ - QueueSpecification overflowStrategy(OverFlowStrategy overflow); + QueueSpecification overflowStrategy(OverflowStrategy overflow); /** * Set TTL for a queue. @@ -478,7 +478,7 @@ public String strategy() { * * @see Overflow Behavior */ - enum OverFlowStrategy { + enum OverflowStrategy { /** Drop the messages at the head of the queue. The default strategy. */ DROP_HEAD("drop-head"), /** Discard the most recent published messages. */ @@ -488,7 +488,7 @@ enum OverFlowStrategy { private final String strategy; - OverFlowStrategy(String strategy) { + OverflowStrategy(String strategy) { this.strategy = strategy; } diff --git a/src/main/java/com/rabbitmq/client/amqp/impl/AmqpQueueSpecification.java b/src/main/java/com/rabbitmq/client/amqp/impl/AmqpQueueSpecification.java index 0555e96bb..fb7932e93 100644 --- a/src/main/java/com/rabbitmq/client/amqp/impl/AmqpQueueSpecification.java +++ b/src/main/java/com/rabbitmq/client/amqp/impl/AmqpQueueSpecification.java @@ -98,7 +98,7 @@ public Management.QueueSpecification overflowStrategy(String overflow) { } @Override - public Management.QueueSpecification overflowStrategy(Management.OverFlowStrategy overflow) { + public Management.QueueSpecification overflowStrategy(Management.OverflowStrategy overflow) { this.arg("x-overflow", overflow.strategy()); return this; } diff --git a/src/test/java/com/rabbitmq/client/amqp/impl/AmqpTest.java b/src/test/java/com/rabbitmq/client/amqp/impl/AmqpTest.java index 36b3f5fad..ed610f672 100644 --- a/src/test/java/com/rabbitmq/client/amqp/impl/AmqpTest.java +++ b/src/test/java/com/rabbitmq/client/amqp/impl/AmqpTest.java @@ -684,7 +684,7 @@ void publishedMessageShouldBeRejectedWhenQueueLimitIsReached(TestInfo info) { management .queue(q) .maxLength(maxLength) - .overflowStrategy(Management.OverFlowStrategy.REJECT_PUBLISH) + .overflowStrategy(Management.OverflowStrategy.REJECT_PUBLISH) .declare(); CountDownLatch rejectedLatch = new CountDownLatch(1); Publisher.Callback callback =