s

sqs-streams

A reactive interface for consuming AWS SQS messages using rxJava, with a high-level component for queueing data to be processed by a user-supplied function with retries and exponential backoff.
https://github.com/Cimpress-MCP/sqs-streams
The Apache Software License, Version 2.0
CT B2B Core Squad
using with exponential queueing data backoff supplied interface messages function consuming processed level component retries high rxjava reactive user
Files download
File Operation
sqs-streams-0.8.60-1fa74c5.jar download
sqs-streams-0.8.60-1fa74c5.pom download
sqs-streams-0.8.60-1fa74c5-sources.jar download
Apache Maven 
<dependency>
  <groupId>com.github.cimpress-mcp</groupId>
  <artifactId>sqs-streams</artifactId>
  <version>0.8.60-1fa74c5</version>
</dependency>
Gradle Groovy 
implementation 'com.github.cimpress-mcp:sqs-streams:0.8.60-1fa74c5'
Gradle Kotlin 
implementation("com.github.cimpress-mcp:sqs-streams:0.8.60-1fa74c5")
Scala SBT 
libraryDependencies += "com.github.cimpress-mcp" % "sqs-streams" % "0.8.60-1fa74c5"
Groovy Grape 
@Grapes(
  @Grab(group='com.github.cimpress-mcp', module='sqs-streams', version='0.8.60-1fa74c5')
)
Apache Ivy 
<dependency org="com.github.cimpress-mcp" name="sqs-streams" rev="0.8.60-1fa74c5" />
Leiningen 
[com.github.cimpress-mcp/sqs-streams "0.8.60-1fa74c5"]
Apache Buildr 
'com.github.cimpress-mcp:sqs-streams:jar:0.8.60-1fa74c5'
Dependencies

compile

|-- org.slf4j:slf4j-api:1.7.25

|-- io.reactivex:rxjava:1.2.3

|-- com.amazonaws:aws-java-sdk-sqs:1.11.313

|-- net.logstash.logback:logstash-logback-encoder:4.11

test

|-- junit:junit:4.12

|-- org.mockito:mockito-core:1.10.19

|-- org.elasticmq:elasticmq-rest-sqs_2.11:0.11.1

|-- org.scalatest:scalatest_2.11:3.0.0

|-- com.typesafe.akka:akka-testkit_2.11:2.4.14

|-- io.reactivex:rxscala_2.11:0.26.4

|-- org.slf4j:slf4j-simple:1.7.21