Class StartPositionProperties
java.lang.Object
com.azure.spring.cloud.service.eventhubs.properties.StartPositionProperties
- All Implemented Interfaces:
com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.StartPosition
public class StartPositionProperties
extends Object
implements com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.StartPosition
The starting position from which to consume events.
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionThe event enqueued after the requested enqueuedDateTime becomes the current position.The offset of the event within that partition.The sequence number of the event within that partition.boolean
Whether the event of the specified sequence number is included.void
setEnqueuedDateTime
(Instant enqueuedDateTime) Set the enqueued date time.void
setInclusive
(boolean inclusive) Whether the position is inclusive.void
Set the offset.void
setSequenceNumber
(Long sequenceNumber) Set the sequence number.
-
Constructor Details
-
StartPositionProperties
public StartPositionProperties()Creates an instance ofStartPositionProperties
.
-
-
Method Details
-
getOffset
Description copied from interface:com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.StartPosition
The offset of the event within that partition. String keyword, "earliest" and "latest" (case-insensitive), are reserved for specifying the start and end of the partition. Other provided value will be cast to Long.- Specified by:
getOffset
in interfacecom.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.StartPosition
- Returns:
- The offset of the event within that partition.
-
setOffset
Set the offset.- Parameters:
offset
- The offset.
-
getSequenceNumber
Description copied from interface:com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.StartPosition
The sequence number of the event within that partition.- Specified by:
getSequenceNumber
in interfacecom.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.StartPosition
- Returns:
- The sequence number of the event within that partition.
-
setSequenceNumber
Set the sequence number.- Parameters:
sequenceNumber
- the sequence number.
-
getEnqueuedDateTime
Description copied from interface:com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.StartPosition
The event enqueued after the requested enqueuedDateTime becomes the current position.- Specified by:
getEnqueuedDateTime
in interfacecom.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.StartPosition
- Returns:
- The enqueued datetime.
-
setEnqueuedDateTime
Set the enqueued date time.- Parameters:
enqueuedDateTime
- The enqueued date time.
-
isInclusive
public boolean isInclusive()Description copied from interface:com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.StartPosition
Whether the event of the specified sequence number is included.- Specified by:
isInclusive
in interfacecom.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.StartPosition
- Returns:
- Whether to include the specified event.
-
setInclusive
public void setInclusive(boolean inclusive) Whether the position is inclusive.- Parameters:
inclusive
- Whether the position is inclusive.
-