File tree Expand file tree Collapse file tree 3 files changed +14
-9
lines changed
powertools-sqs/src/main/java/software/amazon/lambda/powertools/sqs Expand file tree Collapse file tree 3 files changed +14
-9
lines changed Original file line number Diff line number Diff line change 22
22
import com .amazonaws .services .lambda .runtime .events .SQSEvent ;
23
23
import com .fasterxml .jackson .core .JsonProcessingException ;
24
24
import com .fasterxml .jackson .databind .ObjectMapper ;
25
- import org .apache .commons .logging .Log ;
26
- import org .apache .commons .logging .LogFactory ;
25
+
26
+ import org .slf4j .Logger ;
27
+ import org .slf4j .LoggerFactory ;
28
+
27
29
import software .amazon .awssdk .services .sqs .SqsClient ;
28
30
import software .amazon .lambda .powertools .sqs .internal .BatchContext ;
29
31
import software .amazon .lambda .powertools .sqs .internal .SqsLargeMessageAspect ;
36
38
* A class of helper functions to add additional functionality to {@link SQSEvent} processing.
37
39
*/
38
40
public final class SqsUtils {
39
- private static final Log LOG = LogFactory . getLog (SqsUtils .class );
41
+ private static final Logger LOG = LoggerFactory . getLogger (SqsUtils .class );
40
42
41
43
private static final ObjectMapper objectMapper = new ObjectMapper ();
42
44
private static SqsClient client = SqsClient .create ();
Original file line number Diff line number Diff line change 1
1
package software .amazon .lambda .powertools .sqs .internal ;
2
2
3
+ import org .slf4j .Logger ;
4
+ import org .slf4j .LoggerFactory ;
5
+
3
6
import java .util .ArrayList ;
4
7
import java .util .List ;
5
8
6
- import org .apache .commons .logging .Log ;
7
- import org .apache .commons .logging .LogFactory ;
8
9
import software .amazon .awssdk .services .sqs .SqsClient ;
9
10
import software .amazon .awssdk .services .sqs .model .DeleteMessageBatchRequest ;
10
11
import software .amazon .awssdk .services .sqs .model .DeleteMessageBatchRequestEntry ;
17
18
import static java .util .stream .Collectors .toList ;
18
19
19
20
public final class BatchContext {
20
- private static final Log LOG = LogFactory . getLog (BatchContext .class );
21
+ private static final Logger LOG = LoggerFactory . getLogger (BatchContext .class );
21
22
22
23
private final List <SQSMessage > success = new ArrayList <>();
23
24
private final List <SQSMessage > failures = new ArrayList <>();
Original file line number Diff line number Diff line change 14
14
import com .amazonaws .services .s3 .model .S3Object ;
15
15
import com .amazonaws .services .s3 .model .S3ObjectInputStream ;
16
16
import com .amazonaws .util .IOUtils ;
17
- import org .apache .commons .logging .Log ;
18
- import org .apache .commons .logging .LogFactory ;
17
+
19
18
import org .aspectj .lang .ProceedingJoinPoint ;
20
19
import org .aspectj .lang .annotation .Around ;
21
20
import org .aspectj .lang .annotation .Aspect ;
22
21
import org .aspectj .lang .annotation .Pointcut ;
22
+ import org .slf4j .Logger ;
23
+ import org .slf4j .LoggerFactory ;
24
+
23
25
import software .amazon .lambda .powertools .sqs .SqsLargeMessage ;
24
26
import software .amazon .payloadoffloading .PayloadS3Pointer ;
25
27
30
32
@ Aspect
31
33
public class SqsLargeMessageAspect {
32
34
33
- private static final Log LOG = LogFactory . getLog (SqsLargeMessageAspect .class );
35
+ private static final Logger LOG = LoggerFactory . getLogger (SqsLargeMessageAspect .class );
34
36
private static AmazonS3 amazonS3 = AmazonS3ClientBuilder .defaultClient ();
35
37
36
38
@ SuppressWarnings ({"EmptyMethod" })
You can’t perform that action at this time.
0 commit comments