|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object com.xerox.amazonws.common.AWSConnection com.xerox.amazonws.common.AWSQueryConnection com.xerox.amazonws.sqs2.QueueService
public class QueueService
This class provides an interface with the Amazon SQS service. It provides high level methods for listing and creating message queues.
Field Summary |
---|
Fields inherited from class com.xerox.amazonws.common.AWSConnection |
---|
headers |
Constructor Summary | |
---|---|
QueueService(String awsAccessId,
String awsSecretKey)
Initializes the queue service with your AWS login information. |
|
QueueService(String awsAccessId,
String awsSecretKey,
boolean isSecure)
Initializes the queue service with your AWS login information. |
|
QueueService(String awsAccessId,
String awsSecretKey,
boolean isSecure,
String server)
Initializes the queue service with your AWS login information. |
|
QueueService(String awsAccessId,
String awsSecretKey,
boolean isSecure,
String server,
int port)
Initializes the queue service with your AWS login information. |
Method Summary | ||
---|---|---|
MessageQueue |
getMessageQueue(String queueName)
Returns a new message queue. |
|
MessageQueue |
getOrCreateMessageQueue(String queueName)
Creates a new message queue. |
|
MessageQueue |
getOrCreateMessageQueue(String queueName,
int timeout)
Creates a new message queue. |
|
List<MessageQueue> |
listMessageQueues(String queueNamePrefix)
Retrieves a list of message queues. |
|
protected
|
makeRequestInt(org.apache.http.client.methods.HttpRequestBase method,
String action,
Map<String,String> params,
Class<T> respType)
|
Methods inherited from class com.xerox.amazonws.common.AWSQueryConnection |
---|
close, close, getConnectionManagerTimeout, getConnectionTimeout, getHeaders, getHttpClient, getMaxConnections, getMaxRetries, getServerTimeZone, getSoTimeout, getString, httpDate, makeRequest, setConnectionManagerTimeout, setConnectionTimeout, setHttpClient, setMaxConnections, setMaxRetries, setProxyValues, setProxyValues, setProxyValues, setServerTimeZone, setSoTimeout, useSystemProxy |
Methods inherited from class com.xerox.amazonws.common.AWSConnection |
---|
encode, encode, getAlgorithm, getAwsAccessKeyId, getPort, getResourcePrefix, getSecretAccessKey, getServer, getSignatureVersion, getUrl, isSecure, makeURL, setResourcePrefix, setServer, setSignatureVersion, urlencode |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public QueueService(String awsAccessId, String awsSecretKey)
awsAccessId
- The your user key into AWSawsSecretKey
- The secret string used to generate signatures for authentication.public QueueService(String awsAccessId, String awsSecretKey, boolean isSecure)
awsAccessId
- The your user key into AWSawsSecretKey
- The secret string used to generate signatures for authentication.isSecure
- True if the data should be encrypted on the wire on the way to or from SQS.public QueueService(String awsAccessId, String awsSecretKey, boolean isSecure, String server)
awsAccessId
- The your user key into AWSawsSecretKey
- The secret string used to generate signatures for authentication.isSecure
- True if the data should be encrypted on the wire on the way to or from SQS.server
- Which host to connect to. Usually, this will be queue.amazonaws.compublic QueueService(String awsAccessId, String awsSecretKey, boolean isSecure, String server, int port)
awsAccessId
- The your user key into AWSawsSecretKey
- The secret string used to generate signatures for authentication.isSecure
- True if the data should be encrypted on the wire on the way to or from SQS.server
- Which host to connect to. Usually, this will be queue.amazonaws.comport
- Which port to use.Method Detail |
---|
public MessageQueue getOrCreateMessageQueue(String queueName) throws SQSException
queueName
- name of queue to be created
SQSException
public MessageQueue getOrCreateMessageQueue(String queueName, int timeout) throws SQSException
queueName
- name of queue to be createdtimeout
- the duration (in seconds) the retrieved message is hidden from
subsequent calls to retrieve.
SQSException
public MessageQueue getMessageQueue(String queueName) throws SQSException
queueName
- qualified name of queue
SQSException
public List<MessageQueue> listMessageQueues(String queueNamePrefix) throws SQSException
queueNamePrefix
- the optional prefix for filtering results. can be null.
SQSException
protected <T> T makeRequestInt(org.apache.http.client.methods.HttpRequestBase method, String action, Map<String,String> params, Class<T> respType) throws SQSException
SQSException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |