public AgentSink()

in src/main/java/software/amazon/cloudwatchlogs/emf/sinks/AgentSink.java [44:57]

• 14 lines of code
• 1 McCabe index (conditional complexity)

    public AgentSink(
            String logGroupName,
            String logStreamName,
            Endpoint endpoint,
            SocketClientFactory clientFactory,
            int asyncQueueDepth,
            Supplier<RetryStrategy> retryStrategy) {
        this.logGroupName = logGroupName;
        this.logStreamName = logStreamName;
        client = clientFactory.getClient(endpoint);
        queue = new LinkedBlockingQueue<>(asyncQueueDepth);
        executor = createSingleThreadedExecutor();
        this.retryStrategyFactory = retryStrategy;
    }