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;
}