diff --git a/implementation/src/main/java/io/smallrye/mutiny/helpers/queues/Queues.java b/implementation/src/main/java/io/smallrye/mutiny/helpers/queues/Queues.java index 1cf5ca216..c43253776 100644 --- a/implementation/src/main/java/io/smallrye/mutiny/helpers/queues/Queues.java +++ b/implementation/src/main/java/io/smallrye/mutiny/helpers/queues/Queues.java @@ -29,8 +29,8 @@ private Queues() { static final Supplier EMPTY_QUEUE_SUPPLIER = EmptyQueue::new; static final Supplier SINGLETON_QUEUE_SUPPLIER = SingletonQueue::new; - static final Supplier XS_QUEUE_SUPPLIER = () -> new org.jctools.queues.SpscArrayQueue<>(BUFFER_XS); - static final Supplier S_QUEUE_SUPPLIER = () -> new org.jctools.queues.SpscArrayQueue<>(BUFFER_S); + static final Supplier XS_QUEUE_SUPPLIER = () -> new SpscArrayQueue<>(BUFFER_XS); + static final Supplier S_QUEUE_SUPPLIER = () -> new SpscArrayQueue<>(BUFFER_S); static final Supplier UNBOUNDED_QUEUE_SUPPLIER = () -> new SpscUnboundedArrayQueue<>(BUFFER_S); static final Supplier XS_UNBOUNDED_QUEUE_SUPPLIER = () -> new SpscUnboundedArrayQueue<>(BUFFER_XS); @@ -69,7 +69,7 @@ public static Supplier> get(int bufferSize) { if (computedSize > TOO_LARGE_TO_BE_BOUNDED) { return UNBOUNDED_QUEUE_SUPPLIER; } else { - return () -> new org.jctools.queues.SpscArrayQueue<>(computedSize); + return () -> new SpscArrayQueue<>(computedSize); } } @@ -99,7 +99,7 @@ public static Supplier> unbounded(int size) { * @return the queue */ public static Queue createMpscQueue() { - return new org.jctools.queues.MpscLinkedQueue<>(); + return new MpscLinkedQueue<>(); } /** @@ -110,7 +110,7 @@ public static Queue createMpscQueue() { * @return a new queue */ public static Queue createMpscArrayQueue(int size) { - return new org.jctools.queues.MpscArrayQueue<>(size); + return new MpscArrayQueue<>(size); } /**