Skip to content

Commit 2590705

Browse files
committed
Remove wildcard for NIO write queue factory
No necessary here. References #410 (cherry picked from commit a9fa759)
1 parent 5e0c25a commit 2590705

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/main/java/com/rabbitmq/client/impl/nio/NioParams.java

Lines changed: 4 additions & 4 deletions
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() {
@@ -413,12 +413,12 @@ public ByteBufferFactory getByteBufferFactory() {
413413
* @since 5.5.0
414414
*/
415415
public NioParams setWriteQueueFactory(
416-
Function<? super NioContext, ? extends NioQueue> writeQueueFactory) {
416+
Function<NioContext, NioQueue> writeQueueFactory) {
417417
this.writeQueueFactory = writeQueueFactory;
418418
return this;
419419
}
420420

421-
public Function<? super NioContext, ? extends NioQueue> getWriteQueueFactory() {
421+
public Function<NioContext, NioQueue> getWriteQueueFactory() {
422422
return writeQueueFactory;
423423
}
424424
}

0 commit comments

Comments
 (0)