CloudQueue Classe
- java.
lang. Object - com.
microsoft. azure. storage. queue. CloudQueue
- com.
public class CloudQueue
Cette classe représente une file d’attente dans le service file d’attente Microsoft Azure.
Récapitulatif du constructeur
Constructeur | Description |
---|---|
CloudQueue(final StorageUri uri) |
Crée un instance de la classe à l’aide de la file d’attente spécifiée. La file d’attente doit inclure un jeton SAP. |
CloudQueue(final StorageUri uri, final StorageCredentials credentials) |
Crée un instance de la classe à l’aide de la file d’attente et des informations d’identification spécifiées. Si contient un jeton SAS, les informations d’identification doivent être . |
CloudQueue(final String queueName, final CloudQueueClient client) |
Crée un instance de la classe à l’aide du nom et du client spécifiés. |
CloudQueue(final URI uri) |
Crée un instance de la classe à l’aide de l’URI de file d’attente spécifié. La file d’attente doit inclure un jeton SAP. |
CloudQueue(final URI uri, final StorageCredentials credentials) |
Crée un instance de la classe à l’aide de la file d’attente et des informations d’identification spécifiées. Si contient un jeton SAS, les informations d’identification doivent être . |
Résumé de la méthode
Modificateur et type | Méthode et description |
---|---|
void |
addMessage(final CloudQueueMessage message)
Ajoute un message à l’arrière de la file d’attente. |
void |
addMessage(final CloudQueueMessage message, final int timeToLiveInSeconds, final int initialVisibilityDelayInSeconds, QueueRequestOptions options, OperationContext opContext)
Ajoute un message à l’arrière de la file d’attente avec les options spécifiées. |
void |
clear()
Efface tous les messages de la file d'attente. |
void |
clear(QueueRequestOptions options, OperationContext opContext)
Efface tous les messages de la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés. |
void |
create()
Crée la file d'attente. |
void |
create(QueueRequestOptions options, OperationContext opContext)
Crée la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés. |
boolean |
createIfNotExists()
Crée la file d'attente, si elle n'existe pas encore. |
boolean |
createIfNotExists(QueueRequestOptions options, OperationContext opContext)
Crée la file d’attente si elle n’existe pas déjà, à l’aide des options de requête et du contexte d’opération spécifiés. |
void |
delete()
Supprime la file d'attente. |
void |
delete(QueueRequestOptions options, OperationContext opContext)
Supprime la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés. |
boolean |
deleteIfExists()
Supprime la file d'attente, si elle existe. |
boolean |
deleteIfExists(QueueRequestOptions options, OperationContext opContext)
Supprime la file d’attente si elle existe, à l’aide des options de requête et du contexte d’opération spécifiés. |
void |
deleteMessage(final CloudQueueMessage message)
Supprime le message spécifié de la file d’attente. |
void |
deleteMessage(final CloudQueueMessage message, QueueRequestOptions options, OperationContext opContext)
Supprime le message spécifié de la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés. |
void |
downloadAttributes()
Télécharge les métadonnées de la file d’attente et la valeur approximative du nombre de messages. |
void |
downloadAttributes(QueueRequestOptions options, OperationContext opContext)
Télécharge les métadonnées de la file d’attente et la valeur approximative du nombre de messages, à l’aide des options de requête et du contexte d’opération spécifiés. |
Queue |
downloadPermissions()
Télécharge les paramètres d’autorisation pour la file d’attente. |
Queue |
downloadPermissions(QueueRequestOptions options, OperationContext opContext)
Télécharge les paramètres d’autorisations pour la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés. |
boolean |
exists()
Retourne une valeur qui indique si la file d’attente existe. |
boolean |
exists(QueueRequestOptions options, OperationContext opContext)
Retourne une valeur qui indique si la file d’attente existe, à l’aide des options de requête et du contexte d’opération spécifiés. |
String |
generateSharedAccessSignature(final SharedAccessQueuePolicy policy, final String groupPolicyIdentifier)
Retourne une signature d'accès partagé pour la file d'attente. |
String |
generateSharedAccessSignature(final SharedAccessQueuePolicy policy, final String groupPolicyIdentifier, final IPRange ipRange, final SharedAccessProtocols protocols)
Retourne une signature d'accès partagé pour la file d'attente. |
long |
getApproximateMessageCount()
Obtient le nombre approximatif de messages de la file d’attente. Cette valeur est initialisée par une demande adressée à downloadAttributes() et représente le nombre approximatif de messages lorsque cette demande est terminée. |
HashMap<String, String> |
getMetadata()
Obtient la collection de métadonnées de la file d’attente telle qu’elle est stockée dans cet objet. Cette valeur est initialisée avec les métadonnées de la file d’attente par un appel à downloadAttributes(), et est définie sur la file d’attente avec un appel à uploadMetadata(). |
String |
getName()
Obtient le nom de la file d'attente. |
Cloud |
getServiceClient()
Obtient le client du service de file d’attente associé à cette file d’attente. |
boolean |
getShouldEncodeMessage()
Obtient la valeur indiquant si le message doit être encodé en base 64. |
final Storage |
getStorageUri()
Retourne la liste des URI pour tous les emplacements. |
URI |
getUri()
Obtient l’URI absolu pour cette file d’attente. |
Cloud |
peekMessage()
Affiche un message de la file d’attente. Une demande d’aperçu récupère un message à l’avant de la file d’attente sans modifier sa visibilité. |
Cloud |
peekMessage(final QueueRequestOptions options, final OperationContext opContext)
Affiche un message de la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés. Une demande d’aperçu récupère un message à l’avant de la file d’attente sans modifier sa visibilité. |
Iterable<Cloud |
peekMessages(final int numberOfMessages)
Affiche un nombre spécifié de messages de la file d’attente. Une demande d’aperçu récupère les messages à l’avant de la file d’attente sans modifier leur visibilité. |
Iterable<Cloud |
peekMessages(final int numberOfMessages, QueueRequestOptions options, OperationContext opContext)
Affiche un ensemble de messages de la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés. Une demande d’aperçu récupère les messages à l’avant de la file d’attente sans modifier leur visibilité. |
Cloud |
retrieveMessage()
Récupère un message à l’avant de la file d’attente à l’aide des options de requête par défaut. Cette opération marque le message récupéré comme invisible dans la file d’attente pour la période de visibilité par défaut. |
Cloud |
retrieveMessage(final int visibilityTimeoutInSeconds, final QueueRequestOptions options, final OperationContext opContext)
Récupère un message à partir de l’avant de la file d’attente, à l’aide des options de requête et du contexte d’opération spécifiés. Cette opération marque le message récupéré comme invisible dans la file d’attente pour la période de visibilité spécifiée. |
Iterable<Cloud |
retrieveMessages(final int numberOfMessages)
Récupère le nombre spécifié de messages à l’avant de la file d’attente à l’aide des options de requête par défaut. Cette opération marque les messages récupérés comme invisibles dans la file d’attente pour la période de visibilité par défaut. |
Iterable<Cloud |
retrieveMessages(final int numberOfMessages, final int visibilityTimeoutInSeconds, QueueRequestOptions options, OperationContext opContext)
Récupère le nombre spécifié de messages à partir de l’avant de la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés. Cette opération marque les messages récupérés comme invisibles dans la file d’attente pour la période de visibilité par défaut. |
void |
setMetadata(final HashMap<String, String> metadata)
Définit la collection de métadonnées des paires nom-valeur à définir dans la file d’attente avec un uploadMetadata() appel. Cette collection remplacera toutes les métadonnées de file d’attente existantes. Si cette valeur est définie sur une collection vide, les métadonnées de la file d’attente sont effacées lors d’un uploadMetadata() appel. |
void |
setShouldEncodeMessage(final boolean shouldEncodeMessage)
Définit l’indicateur indiquant si le message doit être encodé en base 64. |
void |
updateMessage(final CloudQueueMessage message, final int visibilityTimeoutInSeconds)
Mises à jour le message spécifié dans la file d’attente avec une nouvelle valeur de délai d’expiration de visibilité en secondes. |
void |
updateMessage(final CloudQueueMessage message, final int visibilityTimeoutInSeconds, final EnumSet<MessageUpdateFields> messageUpdateFields, QueueRequestOptions options, OperationContext opContext)
Mises à jour un message dans la file d’attente, à l’aide des options de requête et du contexte d’opération spécifiés. |
void |
uploadMetadata()
Charge les métadonnées de l’objet dans la file d’attente. |
void |
uploadMetadata(QueueRequestOptions options, OperationContext opContext)
Charge les métadonnées de l’objet dans la file d’attente, à l’aide des options de requête et du contexte d’opération spécifiés. |
void |
uploadPermissions(final QueuePermissions permissions)
Charge les autorisations de la file d’attente. |
void |
uploadPermissions(final QueuePermissions permissions, QueueRequestOptions options, OperationContext opContext)
Charge les autorisations de la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés. |
Détails du constructeur
CloudQueue
public CloudQueue(final StorageUri uri)
Crée un instance de la classe à l’aide de la file d’attente spécifiée. La file d’attente doit inclure un jeton SAP.
Parameters:
StorageUri
qui représente l’URI absolu de la file d’attente.
Throws:
CloudQueue
public CloudQueue(final StorageUri uri, final StorageCredentials credentials)
Crée un instance de la classe à l’aide de la file d’attente et des informations d’identification spécifiées. Si contient un jeton SAS, les informations d’identification doivent être .
Parameters:
StorageUri
qui représente l’URI absolu de la file d’attente.
Throws:
CloudQueue
protected CloudQueue(final String queueName, final CloudQueueClient client)
Crée un instance de la classe à l’aide du nom et du client spécifiés.
Parameters:
Throws:
CloudQueue
public CloudQueue(final URI uri)
Crée un instance de la classe à l’aide de l’URI de file d’attente spécifié. La file d’attente doit inclure un jeton SAP.
Parameters:
java.net.URI
qui représente l’URI absolu de la file d’attente.
Throws:
CloudQueue
public CloudQueue(final URI uri, final StorageCredentials credentials)
Crée un instance de la classe à l’aide de la file d’attente et des informations d’identification spécifiées. Si contient un jeton SAS, les informations d’identification doivent être .
Parameters:
java.net.URI
qui représente l’URI absolu de la file d’attente.
Throws:
Détails de la méthode
addMessage
public void addMessage(final CloudQueueMessage message)
Ajoute un message à l’arrière de la file d’attente.
Parameters:
Throws:
addMessage
public void addMessage(final CloudQueueMessage message, final int timeToLiveInSeconds, final int initialVisibilityDelayInSeconds, QueueRequestOptions options, OperationContext opContext)
Ajoute un message à l’arrière de la file d’attente avec les options spécifiées.
Parameters:
null
utilise les options de requête par défaut du client de service associé ( CloudQueueClient).
Throws:
clear
public void clear()
Efface tous les messages de la file d'attente.
Throws:
clear
public void clear(QueueRequestOptions options, OperationContext opContext)
Efface tous les messages de la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés.
Parameters:
null
utilise les options de requête par défaut du client de service associé ( CloudQueueClient).
Throws:
create
public void create()
Crée la file d'attente.
Throws:
create
public void create(QueueRequestOptions options, OperationContext opContext)
Crée la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés.
Parameters:
null
utilise les options de requête par défaut du client de service associé ( CloudQueueClient).
Throws:
createIfNotExists
public boolean createIfNotExists()
Crée la file d'attente, si elle n'existe pas encore.
Returns:
true
est créée dans le service de stockage ; sinon, false
Throws:
createIfNotExists
public boolean createIfNotExists(QueueRequestOptions options, OperationContext opContext)
Crée la file d’attente si elle n’existe pas déjà, à l’aide des options de requête et du contexte d’opération spécifiés.
Parameters:
null
utilise les options de requête par défaut du client de service associé ( CloudQueueClient).
Returns:
true
est créée dans le service de stockage ; sinon, false
Throws:
delete
public void delete()
Supprime la file d'attente.
Throws:
delete
public void delete(QueueRequestOptions options, OperationContext opContext)
Supprime la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés.
Parameters:
null
utilise les options de requête par défaut du client de service associé ( CloudQueueClient).
Throws:
deleteIfExists
public boolean deleteIfExists()
Supprime la file d'attente, si elle existe.
Returns:
true
existait dans le service de stockage et a été supprimée ; sinon false
.Throws:
deleteIfExists
public boolean deleteIfExists(QueueRequestOptions options, OperationContext opContext)
Supprime la file d’attente si elle existe, à l’aide des options de requête et du contexte d’opération spécifiés.
Parameters:
null
utilise les options de requête par défaut du client de service associé ( CloudQueueClient).
Returns:
true
existait dans le service de stockage et a été supprimée ; sinon false
.Throws:
deleteMessage
public void deleteMessage(final CloudQueueMessage message)
Supprime le message spécifié de la file d’attente.
Parameters:
Throws:
deleteMessage
public void deleteMessage(final CloudQueueMessage message, QueueRequestOptions options, OperationContext opContext)
Supprime le message spécifié de la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés.
Parameters:
null
utilise les options de requête par défaut du client de service associé ( CloudQueueClient).
Throws:
downloadAttributes
public void downloadAttributes()
Télécharge les métadonnées de la file d’attente et la valeur approximative du nombre de messages.
Throws:
downloadAttributes
public void downloadAttributes(QueueRequestOptions options, OperationContext opContext)
Télécharge les métadonnées de la file d’attente et la valeur approximative du nombre de messages, à l’aide des options de requête et du contexte d’opération spécifiés.
Parameters:
null
utilise les options de requête par défaut du client de service associé ( CloudQueue).
Throws:
downloadPermissions
public QueuePermissions downloadPermissions()
Télécharge les paramètres d’autorisation pour la file d’attente.
Returns:
Throws:
downloadPermissions
public QueuePermissions downloadPermissions(QueueRequestOptions options, OperationContext opContext)
Télécharge les paramètres d’autorisations pour la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés.
Parameters:
null
utilise les options de requête par défaut du client de service associé ( CloudQueueClient).
Returns:
Throws:
exists
public boolean exists()
Retourne une valeur qui indique si la file d’attente existe.
Returns:
true
si la file d’attente existe dans le service de stockage , sinon false
.
Throws:
exists
public boolean exists(QueueRequestOptions options, OperationContext opContext)
Retourne une valeur qui indique si la file d’attente existe, à l’aide des options de requête et du contexte d’opération spécifiés.
Parameters:
null
utilise les options de requête par défaut du client de service associé ( CloudQueueClient).
Returns:
true
si la file d’attente existe dans le service de stockage , sinon false
.
Throws:
generateSharedAccessSignature
public String generateSharedAccessSignature(final SharedAccessQueuePolicy policy, final String groupPolicyIdentifier)
Retourne une signature d'accès partagé pour la file d'attente.
Parameters:
Returns:
Throws:
generateSharedAccessSignature
public String generateSharedAccessSignature(final SharedAccessQueuePolicy policy, final String groupPolicyIdentifier, final IPRange ipRange, final SharedAccessProtocols protocols)
Retourne une signature d'accès partagé pour la file d'attente.
Parameters:
Returns:
Throws:
getApproximateMessageCount
public long getApproximateMessageCount()
Obtient le nombre approximatif de messages de la file d’attente. Cette valeur est initialisée par une demande adressée à downloadAttributes() et représente le nombre approximatif de messages lorsque cette demande est terminée.
Returns:
Long
qui représente le nombre approximatif de messages de la file d’attente.getMetadata
public HashMap
Obtient la collection de métadonnées de la file d’attente telle qu’elle est stockée dans cet objet. Cette valeur est initialisée avec les métadonnées de la file d’attente par un appel à downloadAttributes(), et est définie sur la file d’attente avec un appel à uploadMetadata().
Returns:
java.util.HashMap
qui représente les métadonnées de la file d’attente.getName
public String getName()
Obtient le nom de la file d'attente.
Returns:
String
qui représente le nom de la file d’attente.getServiceClient
public CloudQueueClient getServiceClient()
Obtient le client du service de file d’attente associé à cette file d’attente.
Returns:
getShouldEncodeMessage
public boolean getShouldEncodeMessage()
Obtient la valeur indiquant si le message doit être encodé en base 64.
Returns:
Boolean
qui indique si le message doit être encodé en base 64.getStorageUri
public final StorageUri getStorageUri()
Retourne la liste des URI pour tous les emplacements.
Returns:
StorageUri
qui représente la liste des URI pour tous les emplacements.getUri
public URI getUri()
Obtient l’URI absolu pour cette file d’attente.
Returns:
java.net.URI
qui représente l’URI de cette file d’attente.peekMessage
public CloudQueueMessage peekMessage()
Affiche un message de la file d’attente. Une demande d’aperçu récupère un message à l’avant de la file d’attente sans modifier sa visibilité.
Returns:
Throws:
peekMessage
public CloudQueueMessage peekMessage(final QueueRequestOptions options, final OperationContext opContext)
Affiche un message de la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés. Une demande d’aperçu récupère un message à l’avant de la file d’attente sans modifier sa visibilité.
Parameters:
null
utilise les options de requête par défaut du client de service associé ( CloudQueueClient).
Returns:
Throws:
peekMessages
public Iterable
Affiche un nombre spécifié de messages de la file d’attente. Une demande d’aperçu récupère les messages à l’avant de la file d’attente sans modifier leur visibilité.
Parameters:
Returns:
Throws:
peekMessages
public Iterable
Affiche un ensemble de messages de la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés. Une demande d’aperçu récupère les messages à l’avant de la file d’attente sans modifier leur visibilité.
Parameters:
null
utilise les options de requête par défaut du client de service associé ( CloudQueueClient).
Returns:
Throws:
retrieveMessage
public CloudQueueMessage retrieveMessage()
Récupère un message à l’avant de la file d’attente à l’aide des options de requête par défaut. Cette opération marque le message récupéré comme invisible dans la file d’attente pour la période de visibilité par défaut.
Returns:
Throws:
retrieveMessage
public CloudQueueMessage retrieveMessage(final int visibilityTimeoutInSeconds, final QueueRequestOptions options, final OperationContext opContext)
Récupère un message à partir de l’avant de la file d’attente, à l’aide des options de requête et du contexte d’opération spécifiés. Cette opération marque le message récupéré comme invisible dans la file d’attente pour la période de visibilité spécifiée.
Parameters:
null
utilise les options de requête par défaut du client de service associé ( CloudQueueClient).
Returns:
Throws:
retrieveMessages
public Iterable
Récupère le nombre spécifié de messages à l’avant de la file d’attente à l’aide des options de requête par défaut. Cette opération marque les messages récupérés comme invisibles dans la file d’attente pour la période de visibilité par défaut.
Parameters:
Returns:
Throws:
retrieveMessages
public Iterable
Récupère le nombre spécifié de messages à partir de l’avant de la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés. Cette opération marque les messages récupérés comme invisibles dans la file d’attente pour la période de visibilité par défaut.
Parameters:
null
utilise les options de requête par défaut du client de service associé ( CloudQueueClient).
Returns:
Throws:
setMetadata
public void setMetadata(final HashMap
Définit la collection de métadonnées des paires nom-valeur à définir dans la file d’attente avec un uploadMetadata() appel. Cette collection remplacera toutes les métadonnées de file d’attente existantes. Si cette valeur est définie sur une collection vide, les métadonnées de la file d’attente sont effacées lors d’un uploadMetadata() appel.
Parameters:
java.util.HashMap
qui représente les métadonnées affectées à la file d’attente.
setShouldEncodeMessage
public void setShouldEncodeMessage(final boolean shouldEncodeMessage)
Définit l’indicateur indiquant si le message doit être encodé en base 64.
Parameters:
updateMessage
public void updateMessage(final CloudQueueMessage message, final int visibilityTimeoutInSeconds)
Mises à jour le message spécifié dans la file d’attente avec une nouvelle valeur de délai d’expiration de visibilité en secondes.
Parameters:
Throws:
updateMessage
public void updateMessage(final CloudQueueMessage message, final int visibilityTimeoutInSeconds, final EnumSet
Mises à jour un message dans la file d’attente, à l’aide des options de requête et du contexte d’opération spécifiés.
Parameters:
EnumSet
MessageUpdateFields valeurs qui spécifie les parties du message à mettre à jour.
null
utilise les options de requête par défaut du client de service associé ( CloudQueueClient).
Throws:
uploadMetadata
public void uploadMetadata()
Charge les métadonnées de l’objet dans la file d’attente.
Throws:
uploadMetadata
public void uploadMetadata(QueueRequestOptions options, OperationContext opContext)
Charge les métadonnées de l’objet dans la file d’attente, à l’aide des options de requête et du contexte d’opération spécifiés.
Parameters:
null
utilise les options de requête par défaut du client de service associé ( CloudQueueClient).
Throws:
uploadPermissions
public void uploadPermissions(final QueuePermissions permissions)
Charge les autorisations de la file d’attente.
Parameters:
Throws:
uploadPermissions
public void uploadPermissions(final QueuePermissions permissions, QueueRequestOptions options, OperationContext opContext)
Charge les autorisations de la file d’attente à l’aide des options de requête et du contexte d’opération spécifiés.
Parameters:
null
utilise les options de requête par défaut du client de service associé ( CloudQueueClient).
Throws:
S’applique à
Azure SDK for Java