PushWithOneThread.java

public class PushWithOneThread {
  
    @Value("${cloud.aws.sns.endpoint}")
    private String SNS_ENDPOINT;

    @Value("${cloud.aws.credentials.accessKey}")
    private String ACCESS_KEY;

    @Value("${cloud.aws.credentials.secretKey}")
    private String SECRET_KEY;
    
    @Inject
    private SQSUtils sqsUtils;

    @Inject
    private PushUtils pushUtils;
    
    public void send() {

        List<PushContainer> list;
        do {
            list = sqsUtils.receive(Constants.SQS_RECEIVE_COUNT);

            if (CollectionUtils.isEmpty(list) == false) {

                final List<PushContainer> candidates = new ArrayList<>(list);
                AWSCredentials credentials = new BasicAWSCredentials(ACCESS_KEY, SECRET_KEY);
                AmazonSNS snsClient = new AmazonSNSAsyncClient(credentials);
                snsClient.setEndpoint(SNS_ENDPOINT);

                for (PushContainer pc : candidates) {
                    boolean result = pushUtils.sendMessage(snsClient, pc.getDevice(), pc.getMessage());
                    if (result) {
                        log.info("[SUCCESS] send message succeeded...userId: [{}], pushToken: [{}]", pc.getDevice().getUserId(), pc.getDevice().getPushToken());
                    } else {
                        log.info("[FAIL] send message failed...userId: [{}], pushToken: [{}]", pc.getDevice().getUserId(), pc.getDevice().getPushToken());
                    }
                }
            }
        } while (CollectionUtils.isEmpty(list) == false);
    }
}