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 3434 */
3535public 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}
You can’t perform that action at this time.
0 commit comments