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 {
178
178
* @see <a href="https://www.rabbitmq.com/docs/maxlength#overflow-behaviour">Overflow
179
179
* Behavior</a>
180
180
*/
181
- QueueSpecification overflowStrategy (OverFlowStrategy overflow );
181
+ QueueSpecification overflowStrategy (OverflowStrategy overflow );
182
182
183
183
/**
184
184
* Set TTL for a queue.
@@ -478,7 +478,7 @@ public String strategy() {
478
478
*
479
479
* @see <a href="https://www.rabbitmq.com/docs/maxlength#overflow-behaviour">Overflow Behavior</a>
480
480
*/
481
- enum OverFlowStrategy {
481
+ enum OverflowStrategy {
482
482
/** Drop the messages at the head of the queue. The default strategy. */
483
483
DROP_HEAD ("drop-head" ),
484
484
/** Discard the most recent published messages. */
@@ -488,7 +488,7 @@ enum OverFlowStrategy {
488
488
489
489
private final String strategy ;
490
490
491
- OverFlowStrategy (String strategy ) {
491
+ OverflowStrategy (String strategy ) {
492
492
this .strategy = strategy ;
493
493
}
494
494
Original file line number Diff line number Diff line change @@ -98,7 +98,7 @@ public Management.QueueSpecification overflowStrategy(String overflow) {
98
98
}
99
99
100
100
@ Override
101
- public Management .QueueSpecification overflowStrategy (Management .OverFlowStrategy overflow ) {
101
+ public Management .QueueSpecification overflowStrategy (Management .OverflowStrategy overflow ) {
102
102
this .arg ("x-overflow" , overflow .strategy ());
103
103
return this ;
104
104
}
Original file line number Diff line number Diff line change @@ -684,7 +684,7 @@ void publishedMessageShouldBeRejectedWhenQueueLimitIsReached(TestInfo info) {
684
684
management
685
685
.queue (q )
686
686
.maxLength (maxLength )
687
- .overflowStrategy (Management .OverFlowStrategy .REJECT_PUBLISH )
687
+ .overflowStrategy (Management .OverflowStrategy .REJECT_PUBLISH )
688
688
.declare ();
689
689
CountDownLatch rejectedLatch = new CountDownLatch (1 );
690
690
Publisher .Callback callback =
You can’t perform that action at this time.
0 commit comments