Skip to content

Commit 23acb94

Browse files
committed
feat: support java 21 virtual threads
Signed-off-by: Marcos Tischer Vallim <[email protected]>
1 parent 53b8d77 commit 23acb94

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

amazon-sns-java-messaging-lib-v2/src/main/java/com/amazon/sns/messaging/lib/core/AmazonSnsTemplate.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -19,11 +19,10 @@
1919
import java.util.concurrent.BlockingQueue;
2020
import java.util.concurrent.ConcurrentHashMap;
2121
import java.util.concurrent.ConcurrentMap;
22-
import java.util.concurrent.Executors;
2322
import java.util.function.UnaryOperator;
2423

24+
import com.amazon.sns.messaging.lib.concurrent.ExecutorsProvider;
2525
import com.amazon.sns.messaging.lib.concurrent.RingBufferBlockingQueue;
26-
import com.amazon.sns.messaging.lib.concurrent.ThreadFactoryProvider;
2726
import com.amazon.sns.messaging.lib.model.RequestEntry;
2827
import com.amazon.sns.messaging.lib.model.TopicProperty;
2928
import com.fasterxml.jackson.databind.ObjectMapper;
@@ -43,7 +42,7 @@ private AmazonSnsTemplate(
4342
final ObjectMapper objectMapper,
4443
final UnaryOperator<PublishBatchRequest> publishDecorator) {
4544
super(
46-
new AmazonSnsProducer<>(pendingRequests, topicRequests, Executors.newSingleThreadExecutor(ThreadFactoryProvider.getThreadFactory())),
45+
new AmazonSnsProducer<>(pendingRequests, topicRequests, ExecutorsProvider.getThreadExecutor()),
4746
new AmazonSnsConsumer<>(amazonSnsClient, topicProperty, objectMapper, pendingRequests, topicRequests, AbstractAmazonSnsTemplate.getAmazonSnsThreadPoolExecutor(topicProperty), publishDecorator)
4847
);
4948
}

0 commit comments

Comments
 (0)