Skip to content

Commit a9fa759

Browse files
committed
Remove wildcard for NIO write queue factory
No necessary here. References #410
1 parent d5b18f8 commit a9fa759

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

Diff for: src/main/java/com/rabbitmq/client/impl/nio/NioParams.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@
3434
*/
3535
public class NioParams {
3636

37-
static Function<? super NioContext, ? extends NioQueue> DEFAULT_WRITE_QUEUE_FACTORY =
37+
static Function<NioContext, NioQueue> DEFAULT_WRITE_QUEUE_FACTORY =
3838
ctx -> new BlockingQueueNioQueue(
3939
new ArrayBlockingQueue<>(ctx.getNioParams().getWriteQueueCapacity(), true),
4040
ctx.getNioParams().getWriteEnqueuingTimeoutInMs()
@@ -106,7 +106,7 @@ public class NioParams {
106106
*
107107
* @since 5.5.0
108108
*/
109-
private Function<? super NioContext, ? extends NioQueue> writeQueueFactory =
109+
private Function<NioContext, NioQueue> writeQueueFactory =
110110
DEFAULT_WRITE_QUEUE_FACTORY;
111111

112112
public NioParams() {
@@ -417,12 +417,12 @@ public ByteBufferFactory getByteBufferFactory() {
417417
* @since 5.5.0
418418
*/
419419
public NioParams setWriteQueueFactory(
420-
Function<? super NioContext, ? extends NioQueue> writeQueueFactory) {
420+
Function<NioContext, NioQueue> writeQueueFactory) {
421421
this.writeQueueFactory = writeQueueFactory;
422422
return this;
423423
}
424424

425-
public Function<? super NioContext, ? extends NioQueue> getWriteQueueFactory() {
425+
public Function<NioContext, NioQueue> getWriteQueueFactory() {
426426
return writeQueueFactory;
427427
}
428428
}

0 commit comments

Comments
 (0)