public class JobStatusMonitor
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private static org.apache.commons.logging.Log |
log |
private static com.fasterxml.jackson.databind.ObjectMapper |
MAPPER |
private java.lang.String |
queueUrl |
private AmazonSNSClient |
sns |
private AmazonSQSClient |
sqs |
private java.lang.String |
topicArn |
Constructor and Description |
---|
JobStatusMonitor(AmazonSQSClient sqs,
AmazonSNSClient sns)
Constructs a JobStatusMonitor that will use the specified clients for
polling archive download job status.
|
JobStatusMonitor(AWSCredentialsProvider credentialsProvider,
ClientConfiguration clientConfiguration) |
Modifier and Type | Method and Description |
---|---|
private void |
deleteMessage(Message message) |
java.lang.String |
getTopicArn() |
private java.util.Map<java.lang.String,java.lang.String> |
newAttributes(java.lang.String... keyValuePairs) |
private void |
setupQueueAndTopic() |
void |
shutdown() |
private void |
sleep(long milliseconds) |
void |
waitForJobToComplete(java.lang.String jobId)
Poll the SQS queue to see if we've received a message about the job completion yet.
|
private static final com.fasterxml.jackson.databind.ObjectMapper MAPPER
private AmazonSQSClient sqs
private AmazonSNSClient sns
private java.lang.String queueUrl
private java.lang.String topicArn
private static final org.apache.commons.logging.Log log
public JobStatusMonitor(AWSCredentialsProvider credentialsProvider, ClientConfiguration clientConfiguration)
public JobStatusMonitor(AmazonSQSClient sqs, AmazonSNSClient sns)
sqs
- The client for working with Amazon SQS when polling archive
retrieval job status.sns
- The client for working with Amazon SNS when polling archive
retrieval job status.public java.lang.String getTopicArn()
public void shutdown()
public void waitForJobToComplete(java.lang.String jobId)
private void sleep(long milliseconds)
private void deleteMessage(Message message)
private void setupQueueAndTopic()
private java.util.Map<java.lang.String,java.lang.String> newAttributes(java.lang.String... keyValuePairs)