File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
src/main/java/com/rabbitmq/client/impl/nio Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change 36
36
*/
37
37
public class NioParams {
38
38
39
- static Function <? super NioContext , ? extends NioQueue > DEFAULT_WRITE_QUEUE_FACTORY =
39
+ static Function <NioContext , NioQueue > DEFAULT_WRITE_QUEUE_FACTORY =
40
40
ctx -> new BlockingQueueNioQueue (
41
41
new ArrayBlockingQueue <>(ctx .getNioParams ().getWriteQueueCapacity (), true ),
42
42
ctx .getNioParams ().getWriteEnqueuingTimeoutInMs ()
@@ -112,7 +112,7 @@ public void configure(SSLEngine sslEngine) throws IOException {
112
112
*
113
113
* @since 5.5.0
114
114
*/
115
- private Function <? super NioContext , ? extends NioQueue > writeQueueFactory =
115
+ private Function <NioContext , NioQueue > writeQueueFactory =
116
116
DEFAULT_WRITE_QUEUE_FACTORY ;
117
117
118
118
public NioParams () {
@@ -422,12 +422,12 @@ public ByteBufferFactory getByteBufferFactory() {
422
422
* @since 5.5.0
423
423
*/
424
424
public NioParams setWriteQueueFactory (
425
- Function <? super NioContext , ? extends NioQueue > writeQueueFactory ) {
425
+ Function <NioContext , NioQueue > writeQueueFactory ) {
426
426
this .writeQueueFactory = writeQueueFactory ;
427
427
return this ;
428
428
}
429
429
430
- public Function <? super NioContext , ? extends NioQueue > getWriteQueueFactory () {
430
+ public Function <NioContext , NioQueue > getWriteQueueFactory () {
431
431
return writeQueueFactory ;
432
432
}
433
433
}
You can’t perform that action at this time.
0 commit comments