Creates a Resource that using passed-by-parameter AWS configurations, it encodes the acquisition and release of the resources needed to instantiate the Sqs.

Example

import cats.effect.Resource
import monix.eval.Task
import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider
import software.amazon.awssdk.regions.Region

val defaultCredentials = DefaultCredentialsProvider.create()
val sqsResource: Resource[Task, Sqs] = Sqs.create(defaultCredentials, Region.AWS_GLOBAL)

Creates a new Sqs instance out of the the passed AWS configurations.

It provides a fast forward access to the Sqs instance. Thus, it is the user's responsibility of the user to do a proper resource usage and so, closing the connection.

Example

import monix.execution.Scheduler.Implicits.global
import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider
import software.amazon.awssdk.regions.Region
import monix.eval.Task

val defaultCred = DefaultCredentialsProvider.create()
val sqs: Sqs = Sqs.createUnsafe(defaultCred, Region.AWS_GLOBAL)
// do your stuff here
sqs.close.runToFuture

Creates a instance of Sqs out of a SqsAsyncClient which provides a fast forward access to the Sqs that avoids dealing with a proper resource and usage.

Unsafe because the state of the passed SqsAsyncClient is not guaranteed, it can either be malformed or closed, which would result in underlying failures.

Example

import java.time.Duration
import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider
import software.amazon.awssdk.regions.Region.AWS_GLOBAL
import software.amazon.awssdk.http.nio.netty.NettyNioAsyncHttpClient
import software.amazon.awssdk.services.sqs.SqsAsyncClient

// the exceptions related with concurrency or timeouts from any of the requests
// might be solved by raising the `maxConcurrency`, `maxPendingConnectionAcquire` or
// `connectionAcquisitionTimeout` from the underlying netty http async client.
// see below an example on how to increase such values.

val httpClient = NettyNioAsyncHttpClient.builder()
  .maxConcurrency(500)
  .maxPendingConnectionAcquires(50000)
  .connectionAcquisitionTimeout(Duration.ofSeconds(60))
  .readTimeout(Duration.ofSeconds(60))
  .build()

val sqsAsyncClient: SqsAsyncClient = SqsAsyncClient
  .builder()
  .httpClient(httpClient)
  .credentialsProvider(DefaultCredentialsProvider.create())
  .region(AWS_GLOBAL)
  .build()

  val sqs: Sqs = Sqs.createUnsafe(sqsAsyncClient)

Provides a resource that uses the values from the config file to acquire and release a Sqs instance.

The config will come from MonixAwsConf which it is actually obtained from the application.conf file present under the resources folder.

Example

import monix.connect.aws.auth.MonixAwsConf
import monix.eval.Task
import monix.connect.sqs.Sqs

val awsConf: Task[MonixAwsConf] = MonixAwsConf.load()
Sqs.fromConfig(awsConf).use { sqs =>
       //business logic here
       Task.unit
 }

Provides a resource that uses the values from the config file to acquire and release a Sqs instance.

The config will come from MonixAwsConf which it is actually obtained from the application.conf file present under the resources folder.

Example

import monix.connect.aws.auth.MonixAwsConf
import monix.connect.sqs.Sqs
import monix.eval.Task
import software.amazon.awssdk.regions.Region

MonixAwsConf.load().flatMap{ awsConf =>
    // you can update your config from code too
    val updatedAwsConf = awsConf.copy(region = Region.AP_SOUTH_1)
    Sqs.fromConfig(updatedAwsConf).use { sqs =>
       //business logic here
       Task.unit
    }
}

Provides a resource that uses the values from the config file to acquire and release a Sqs instance.

It does not requires any input parameter as it expect the aws config to be set from application.conf, which has to be placed under the resources folder and will overwrite the defaults values from: https://github.com/monix/monix-connect/blob/master/aws-auth/src/main/resources/reference.conf.

Example

import monix.connect.aws.auth.MonixAwsConf
import monix.connect.sqs.Sqs
import monix.eval.Task

Sqs.fromConfig.use { sqs =>
   //business logic here
   Task.unit
}

Provides a resource that uses the values from the config file to acquire and release a Sqs instance.

It does not requires any input parameter as it expect the aws config to be set from application.conf, which has to be placed under the resources folder and will overwrite the defaults values from: https://github.com/monix/monix-connect/blob/master/aws-auth/src/main/resources/reference.conf.

Example

import monix.connect.aws.auth.MonixAwsConf
import monix.connect.sqs.Sqs
import monix.eval.Task

Sqs.fromConfig.use { sqs =>
   //business logic here
   Task.unit
}