EventPosition Classe

Paquet:

com.azure.messaging.eventhubs.models

Artefact Maven:

com.azure:azure-messaging-eventhubs:5.18.7

• java.lang.Object
• • com.azure.messaging.eventhubs.models.EventPosition

public final class EventPosition

Définit une position d’un EventData dans le flux de partition Event Hub. La position peut être un décalage, un numéro de séquence ou une heure utc en file d’attente.

Résumé de la méthode

Modificateur et type	Méthode et description
static EventPosition	earliest() Correspond à l’emplacement du premier événement présent dans la partition.
boolean	equals(Object obj)
static EventPosition	fromEnqueuedTime(Instant enqueuedDateTime) Crée une position au niveau du donné Instant.
static EventPosition	fromOffset(long offset) Crée une position pour un événement dans la partition au décalage fourni.
static EventPosition	fromSequenceNumber(long sequenceNumber) Crée une position pour un événement dans la partition au numéro de séquence fourni.
static EventPosition	fromSequenceNumber(long sequenceNumber, boolean isInclusive) Crée une position au niveau du numéro de séquence donné.
Instant	getEnqueuedDateTime() Obtient l’instant, en UTC, à partir duquel l’événement suivant disponible doit être choisi.
String	getOffset() Obtient la position relative de l’événement dans le contexte du flux.
Long	getSequenceNumber() Obtient le numéro de séquence de l’événement.
int	hashCode()
boolean	isInclusive() Obtient la valeur booléenne de si l’événement est inclus.
static EventPosition	latest() Correspond à la fin de la partition, où plus aucun événement n’est actuellement mis en file d’attente.
String	toString()

Méthodes héritées de java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Détails de la méthode

earliest

public static EventPosition earliest()

Correspond à l’emplacement du premier événement présent dans la partition. Utilisez cette position pour commencer à recevoir à partir du premier événement qui a été mis en file d’attente dans la partition qui n’a pas expiré en raison de la stratégie de rétention.

Retours:

défini EventPosition sur le début d’un flux Event Hub.

equals

public boolean equals(Object obj)

Remplacements:

EventPosition.equals(Object obj)

Paramètres:

obj

fromEnqueuedTime

public static EventPosition fromEnqueuedTime(Instant enqueuedDateTime)

Crée une position au niveau du donné Instant. Correspond à un instance spécifique dans une partition pour commencer à rechercher un événement. L’événement mis en file d’attente après la demande enqueuedDateTime devient la position actuelle.

Paramètres:

enqueuedDateTime - Instant, en UTC, à partir duquel l’événement suivant disponible doit être choisi.

Retours:

Objet EventPosition.

fromOffset

public static EventPosition fromOffset(long offset)

Crée une position pour un événement dans la partition au décalage fourni. L’événement à ce décalage n’est pas inclus. Au lieu de cela, l’événement suivant est retourné.

Le décalage est la position relative de l’événement dans le contexte du flux. Le décalage ne doit pas être considéré comme une valeur stable, car le même décalage peut faire référence à un événement différent à mesure que les événements atteignent la limite d’âge pour la rétention et ne sont plus visibles dans le flux.

Paramètres:

offset - Décalage de l’événement dans cette partition.

Retours:

Objet EventPosition.

fromSequenceNumber

public static EventPosition fromSequenceNumber(long sequenceNumber)

Crée une position pour un événement dans la partition au numéro de séquence fourni. L’événement avec le numéro de séquence n’est pas inclus. Au lieu de cela, l’événement suivant est retourné.

Paramètres:

sequenceNumber - est le numéro de séquence de l’événement.

Retours:

Objet EventPosition.

fromSequenceNumber

public static EventPosition fromSequenceNumber(long sequenceNumber, boolean isInclusive)

Crée une position au niveau du numéro de séquence donné. Si isInclusive a la valeur true, l’événement avec le même numéro de séquence est retourné. Sinon, l’événement suivant dans la séquence est reçu.

Paramètres:

sequenceNumber - est le numéro de séquence de l’événement.

isInclusive - Si la valeur est true, l’événement avec le sequenceNumber est inclus ; sinon, l’événement suivant est reçu.

Retours:

Objet EventPosition.

getEnqueuedDateTime

public Instant getEnqueuedDateTime()

Obtient l’instant, en UTC, à partir duquel l’événement suivant disponible doit être choisi.

Retours:

Instant, en UTC, à partir duquel l’événement suivant disponible doit être choisi.

getOffset

public String getOffset()

Obtient la position relative de l’événement dans le contexte du flux. Le décalage ne doit pas être considéré comme une valeur stable, car le même décalage peut faire référence à un événement différent à mesure que les événements atteignent la limite d’âge pour la rétention et ne sont plus visibles dans le flux.

Retours:

Décalage de l’événement dans cette partition.

getSequenceNumber

public Long getSequenceNumber()

Obtient le numéro de séquence de l’événement.

Retours:

Numéro de séquence de l’événement.

hashCode

public int hashCode()

Remplacements:

EventPosition.hashCode()

isInclusive

public boolean isInclusive()

Obtient la valeur booléenne de si l’événement est inclus. Si la valeur est true, l’événement avec le sequenceNumber est inclus ; sinon, l’événement suivant est reçu.

Retours:

Boolean si l’événement sera reçu.

latest

public static EventPosition latest()

Correspond à la fin de la partition, où plus aucun événement n’est actuellement mis en file d’attente. Utilisez cette position pour commencer à recevoir de l’événement suivant à mettre en file d’attente dans la partition lors receiveFromPartition(String partitionId, EventPosition startingPosition) de l’appel.

Retours:

Défini EventPosition à la fin d’un flux Event Hubs et écoute les nouveaux événements.

toString

public String toString()

Remplacements:

EventPosition.toString()