blob: b640e6b4a86445129be5f0be4bd1b5d2def1f8d1 [file] [log] [blame]
package org.apache.nuvem.cloud.messageQueueService.impl;
import com.amazonaws.AmazonWebServiceClient;
import com.amazonaws.auth.AWSCredentials;
import com.amazonaws.services.sqs.AmazonSQSClient;
public class AmazonMessageQueueServiceClient {
public static AmazonWebServiceClient getAmazonSQSClient(final String accessKey, final String secretKey) {
if(accessKey == null || secretKey == null){
return new MockAmazonSQSClient();
}
AWSCredentials awsCredentials = new AWSCredentials() {
@Override
public String getAWSAccessKeyId() {
return accessKey;
}
@Override
public String getAWSSecretKey() {
return secretKey;
}
};
return new AmazonSQSClient(awsCredentials);
}
}