File tree Expand file tree Collapse file tree 3 files changed +5
-5
lines changed
main/java/com/rabbitmq/client/amqp
test/java/com/rabbitmq/client/amqp/impl Expand file tree Collapse file tree 3 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -178,7 +178,7 @@ interface QueueSpecification {
178178 * @see <a href="https://www.rabbitmq.com/docs/maxlength#overflow-behaviour">Overflow
179179 * Behavior</a>
180180 */
181- QueueSpecification overflowStrategy (OverFlowStrategy overflow );
181+ QueueSpecification overflowStrategy (OverflowStrategy overflow );
182182
183183 /**
184184 * Set TTL for a queue.
@@ -478,7 +478,7 @@ public String strategy() {
478478 *
479479 * @see <a href="https://www.rabbitmq.com/docs/maxlength#overflow-behaviour">Overflow Behavior</a>
480480 */
481- enum OverFlowStrategy {
481+ enum OverflowStrategy {
482482 /** Drop the messages at the head of the queue. The default strategy. */
483483 DROP_HEAD ("drop-head" ),
484484 /** Discard the most recent published messages. */
@@ -488,7 +488,7 @@ enum OverFlowStrategy {
488488
489489 private final String strategy ;
490490
491- OverFlowStrategy (String strategy ) {
491+ OverflowStrategy (String strategy ) {
492492 this .strategy = strategy ;
493493 }
494494
Original file line number Diff line number Diff line change @@ -98,7 +98,7 @@ public Management.QueueSpecification overflowStrategy(String overflow) {
9898 }
9999
100100 @ Override
101- public Management .QueueSpecification overflowStrategy (Management .OverFlowStrategy overflow ) {
101+ public Management .QueueSpecification overflowStrategy (Management .OverflowStrategy overflow ) {
102102 this .arg ("x-overflow" , overflow .strategy ());
103103 return this ;
104104 }
Original file line number Diff line number Diff line change @@ -684,7 +684,7 @@ void publishedMessageShouldBeRejectedWhenQueueLimitIsReached(TestInfo info) {
684684 management
685685 .queue (q )
686686 .maxLength (maxLength )
687- .overflowStrategy (Management .OverFlowStrategy .REJECT_PUBLISH )
687+ .overflowStrategy (Management .OverflowStrategy .REJECT_PUBLISH )
688688 .declare ();
689689 CountDownLatch rejectedLatch = new CountDownLatch (1 );
690690 Publisher .Callback callback =
You can’t perform that action at this time.
0 commit comments