override fun performTask()

in ses-plugin-server/src/main/kotlin/jetbrains/buildServer/sesPlugin/sqs/awsCommunication/AmazonSQSCommunicatorImpl.kt [11:20]

• 8 lines of code
• 2 McCabe index (conditional complexity)

    override fun <T> performTask(bean: SQSBean, communicatorTask: AmazonSQSCommunicatorTask<T>): T {
        return awsClientsProvider.withClient(bean) {
            amazonSQSClientFactory.createAmazonSQSClient(this).use { sqs ->
                if (Thread.currentThread().isInterrupted) throw InterruptedException("Execution is interrupted")


                return@withClient communicatorTask.perform(sqs, queueUrlProvider.getQueueUrl(sqs, bean))
            }
        }
    }