diff --git a/misk-aws/src/main/kotlin/misk/jobqueue/sqs/AwsSqsJobHandlerModule.kt b/misk-aws/src/main/kotlin/misk/jobqueue/sqs/AwsSqsJobHandlerModule.kt index 38b933103c2..53b9d1716a5 100644 --- a/misk-aws/src/main/kotlin/misk/jobqueue/sqs/AwsSqsJobHandlerModule.kt +++ b/misk-aws/src/main/kotlin/misk/jobqueue/sqs/AwsSqsJobHandlerModule.kt @@ -72,7 +72,7 @@ class AwsSqsJobHandlerModule private constructor( } @Singleton -internal class AwsSqsJobHandlerSubscriptionService @Inject constructor( +class AwsSqsJobHandlerSubscriptionService @Inject internal constructor( private val attributeImporter: AwsSqsQueueAttributeImporter, private val consumer: SqsJobConsumer, private val consumerMapping: Map, diff --git a/misk-aws/src/main/kotlin/misk/jobqueue/sqs/AwsSqsQueueAttributeImporter.kt b/misk-aws/src/main/kotlin/misk/jobqueue/sqs/AwsSqsQueueAttributeImporter.kt index b792271f575..1c14c272c0d 100644 --- a/misk-aws/src/main/kotlin/misk/jobqueue/sqs/AwsSqsQueueAttributeImporter.kt +++ b/misk-aws/src/main/kotlin/misk/jobqueue/sqs/AwsSqsQueueAttributeImporter.kt @@ -11,7 +11,7 @@ import java.time.Duration import java.util.concurrent.atomic.AtomicBoolean import jakarta.inject.Inject -internal class AwsSqsQueueAttributeImporter @Inject constructor( +class AwsSqsQueueAttributeImporter @Inject internal constructor( private val config: AwsSqsJobQueueConfig, private val leaseManager: LeaseManager, private val metrics: SqsMetrics, diff --git a/misk-aws/src/main/kotlin/misk/jobqueue/sqs/QueueResolver.kt b/misk-aws/src/main/kotlin/misk/jobqueue/sqs/QueueResolver.kt index ec47e9a3906..a88019e84b7 100644 --- a/misk-aws/src/main/kotlin/misk/jobqueue/sqs/QueueResolver.kt +++ b/misk-aws/src/main/kotlin/misk/jobqueue/sqs/QueueResolver.kt @@ -13,7 +13,7 @@ import jakarta.inject.Inject import jakarta.inject.Singleton @Singleton -internal class QueueResolver @Inject internal constructor( +class QueueResolver @Inject internal constructor( private val currentRegion: AwsRegion, private val currentAccount: AwsAccountId, private val defaultSQS: AmazonSQS, diff --git a/misk-aws/src/main/kotlin/misk/jobqueue/sqs/ResolvedQueue.kt b/misk-aws/src/main/kotlin/misk/jobqueue/sqs/ResolvedQueue.kt index a2ff768636d..f1a51c5e113 100644 --- a/misk-aws/src/main/kotlin/misk/jobqueue/sqs/ResolvedQueue.kt +++ b/misk-aws/src/main/kotlin/misk/jobqueue/sqs/ResolvedQueue.kt @@ -7,7 +7,7 @@ import misk.cloud.aws.AwsRegion import misk.jobqueue.QueueName /** [ResolvedQueue] provides information needed to reach an SQS queue */ -internal class ResolvedQueue( +class ResolvedQueue internal constructor( val name: QueueName, val sqsQueueName: QueueName, val url: String, diff --git a/misk-aws/src/main/kotlin/misk/jobqueue/sqs/SqsJobConsumer.kt b/misk-aws/src/main/kotlin/misk/jobqueue/sqs/SqsJobConsumer.kt index 0cd7480edf5..5613557efc8 100644 --- a/misk-aws/src/main/kotlin/misk/jobqueue/sqs/SqsJobConsumer.kt +++ b/misk-aws/src/main/kotlin/misk/jobqueue/sqs/SqsJobConsumer.kt @@ -31,7 +31,7 @@ import com.google.inject.Provider import jakarta.inject.Singleton @Singleton -internal class SqsJobConsumer @Inject internal constructor( +class SqsJobConsumer @Inject internal constructor( @ForSqsHandling private val handlingThreads: ExecutorService, @ForSqsHandling private val taskQueue: RepeatedTaskQueue, @ForSqsReceiving private val receivingThreads: ExecutorService, diff --git a/misk-aws/src/main/kotlin/misk/jobqueue/sqs/SqsMetrics.kt b/misk-aws/src/main/kotlin/misk/jobqueue/sqs/SqsMetrics.kt index 6b48f1b0490..748df7b3da4 100644 --- a/misk-aws/src/main/kotlin/misk/jobqueue/sqs/SqsMetrics.kt +++ b/misk-aws/src/main/kotlin/misk/jobqueue/sqs/SqsMetrics.kt @@ -11,7 +11,7 @@ import jakarta.inject.Singleton * for queues both client-side and on SQS with the same label. */ @Singleton -internal class SqsMetrics @Inject internal constructor(metrics: Metrics) { +class SqsMetrics @Inject internal constructor(metrics: Metrics) { val jobsEnqueued = metrics.counter( "jobs_enqueued_total", "total # of jobs sent to a queueName",