Changing receive to not have client. Missed it on the last commit

rstradling · Jul 24, 2018 · d3b12d7 · d3b12d7
1 parent 56d69bf
commit d3b12d7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/examples/src/main/scala/com/github/rstradling/awsio/examples/SqsFs2Example.scala b/examples/src/main/scala/com/github/rstradling/awsio/examples/SqsFs2Example.scala
@@ -38,7 +38,7 @@ object SqsFs2Example extends App {
         .messageBody("MyBody")
         .build
       pubMsg <- message.send(sendMessageRequest)
-      acker <- processAndAck.processAndAck(message, urlResp.queueUrl(), messageRequest, {m : Message =>
+      acker <- Fs2AckProcessor.process(message, urlResp.queueUrl(), messageRequest, {m : Message =>
         println(m)
         Right(()): Either[Throwable, Unit]
       }).compile.drain

diff --git a/sqs-fs2/src/main/scala/com/github/rstradling/awsio/sqs/fs2/Fs2AckProcessor.scala b/sqs-fs2/src/main/scala/com/github/rstradling/awsio/sqs/fs2/Fs2AckProcessor.scala
@@ -5,7 +5,6 @@ import cats.implicits._
 import com.github.rstradling.awsio.sqs.ReceiveLoop
 import com.github.rstradling.awsio.sqs.MessageOps
 import com.github.rstradling.awsio.sqs.AckProcessor
-import software.amazon.awssdk.services.sqs.SQSAsyncClient
 import software.amazon.awssdk.services.sqs.model.ReceiveMessageRequest
 import software.amazon.awssdk.services.sqs.model.Message
 import software.amazon.awssdk.services.sqs.model.DeleteMessageRequest
@@ -27,8 +26,7 @@ object Fs2AckProcessor {
     * @tparam B
     * @return
     */
-  def process[F[_]: Effect, B](client: SQSAsyncClient,
-                       messageOps: MessageOps[F],
+  def process[F[_]: Effect, B](messageOps: MessageOps[F],
                        queueUrl: String,
                        receiveMessageRequest: ReceiveMessageRequest,
                        handler: Message => Either[Throwable, B])(