Data.Cloud.AmazonAPI.TAmazonQueueService
Delphi
TAmazonQueueService = class(TAmazonBasicService)
C++
class PASCALIMPLEMENTATION TAmazonQueueService : public TAmazonBasicService
Propriétés
Type | Visibilité | Source | Unité | Parent |
---|---|---|---|---|
class | public | Data.Cloud.AmazonAPI.pas Data.Cloud.AmazonAPI.hpp |
Data.Cloud.AmazonAPI | Data.Cloud.AmazonAPI |
Description
Vous permet d'établir une connexion à Amazon Simple Queue Service (SQS).
Cette classe fournit des méthodes que vous pouvez utiliser pour :
- Gérer des files d'attente :
- Gérer des messages :
- Ajouter un message à une file.
- Supprimer un seul message d'une file d'attente ou supprimer tous les messages dans une file d'attente.
- Modifier la visibilité d'un message.
- Obtenir ou lire des messages.
- Trouver le nombre maximum de messages que vous pouvez récupérer à partir d'une file d'attente.
Par ailleurs, TAmazonQueueService fournit des méthodes qui renvoient la réponse au format XML analysé :
Pour plus d'informations sur l'API Amazon Simple Queue Service (SQS), voir la documentation officielle Amazon Simple Queue Service (EN).
L'extrait de code suivant montre comment créer une nouvelle file d'attente en utilisant la classe TAmazonQueueService :
Delphi :
var
ResponseInfo: TCloudResponseInfo;
QueueURL: String;
QueueService: TAmazonQueueService;
begin
QueueService := TAmazonQueueService.Create(AmazonConnectionInfo1);
ResponseInfo := TCloudResponseInfo.Create;
try
if QueueService.CreateQueue('QueueName', QueueURL, -1, ResponseInfo) then
Memo1.Lines.Append('Success! QueueURL: ' + QueueURL);
else
Memo1.Lines.Append(Format('Failure! %s', [ResponseInfo.StatusMessage]));
finally
QueueService.Free;
ResponseInfo.Free;
end;
end;
C++ :
TCloudResponseInfo *ResponseInfo;
String QueueURL;
TAmazonQueueService *QueueService;
QueueService = new TAmazonQueueService(AmazonConnectionInfo1);
ResponseInfo = new TCloudResponseInfo;
try
{
if (QueueService->CreateQueue("testqueue", QueueURL, -1, ResponseInfo))
{
Memo1->Lines->Append("Success! QueueURL: " + QueueURL);
}
else
{
TVarRec args[1] = {ResponseInfo->StatusMessage};
Memo1->Lines->Append(Format("Failure! %s", args, 0));
}
}
__finally
{
delete QueueService;
delete ResponseInfo;
}