Index

A B C D E G L M N O P R S T V 
All Classes and Interfaces|All Packages|Constant Field Values

A

addBuilderCustomizer(AzureServiceClientBuilderCustomizer<EventHubClientBuilder>) - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProducerFactory
Add a service client builder customizer to customize all the clients created from this factory.
addBuilderCustomizer(AzureServiceClientBuilderCustomizer<EventProcessorClientBuilder>) - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProcessorFactory
Add a service client builder customizer to customize all the clients created from this factory.
addBuilderCustomizer(String, AzureServiceClientBuilderCustomizer<EventHubClientBuilder>) - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProducerFactory
Add a service client builder customizer to customize the clients created from this factory with event hub name of value eventHub.
addBuilderCustomizer(String, String, AzureServiceClientBuilderCustomizer<EventProcessorClientBuilder>) - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProcessorFactory
Add a service client builder customizer to customize the clients created from this factory with event hub name of value eventHub and consumer group of value consumerGroup.
addListener(EventHubsProcessorFactory.Listener) - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProcessorFactory
 
addListener(EventHubsProcessorFactory.Listener) - Method in interface com.azure.spring.messaging.eventhubs.core.EventHubsProcessorFactory
Add a listener for this factory.
addListener(EventHubsProducerFactory.Listener) - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProducerFactory
 
addListener(EventHubsProducerFactory.Listener) - Method in interface com.azure.spring.messaging.eventhubs.core.EventHubsProducerFactory
Add a listener for this factory.

B

BATCH - Enum constant in enum com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointMode
Checkpoint after each processed batch of records.
BATCH_CONVERTED_APPLICATION_PROPERTIES - Static variable in class com.azure.spring.messaging.eventhubs.support.EventHubsHeaders
Batch converted application properties.
BATCH_CONVERTED_ENQUEUED_TIME - Static variable in class com.azure.spring.messaging.eventhubs.support.EventHubsHeaders
Batch converted enqueued time.
BATCH_CONVERTED_OFFSET - Static variable in class com.azure.spring.messaging.eventhubs.support.EventHubsHeaders
Batch converted offset.
BATCH_CONVERTED_SEQUENCE_NUMBER - Static variable in class com.azure.spring.messaging.eventhubs.support.EventHubsHeaders
Batch converted sequence number.
BATCH_CONVERTED_SYSTEM_PROPERTIES - Static variable in class com.azure.spring.messaging.eventhubs.support.EventHubsHeaders
Batch converted system properties.

C

CheckpointConfig - Class in com.azure.spring.messaging.eventhubs.core.checkpoint
Checkpoint config to describe different checkpoint strategies.
CheckpointConfig() - Constructor for class com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointConfig
Construct a CheckpointConfig with the CheckpointMode.RECORD mode.
CheckpointConfig(CheckpointMode) - Constructor for class com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointConfig
Construct a CheckpointConfig with the specified CheckpointMode mode.
CheckpointConfig(CheckpointMode, Integer) - Constructor for class com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointConfig
Construct a CheckpointConfig with the specified CheckpointMode mode and the amount of messages for each partition to do one checkpoint.
CheckpointConfig(CheckpointMode, Integer, Duration) - Constructor for class com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointConfig
Construct a CheckpointConfig with the specified CheckpointMode mode, the amount of messages for each partition to do one checkpoint and the time interval to do one checkpoint.
CheckpointConfig(CheckpointMode, Duration) - Constructor for class com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointConfig
Construct a CheckpointConfig with the specified CheckpointMode mode and the time interval to do one checkpoint.
CheckpointMode - Enum in com.azure.spring.messaging.eventhubs.core.checkpoint
The offset commit behavior enumeration.
com.azure.spring.messaging.eventhubs.core - package com.azure.spring.messaging.eventhubs.core
Spring Messaging Event Hubs core package.
com.azure.spring.messaging.eventhubs.core.checkpoint - package com.azure.spring.messaging.eventhubs.core.checkpoint
Event Hubs checkpoint configs.
com.azure.spring.messaging.eventhubs.core.listener - package com.azure.spring.messaging.eventhubs.core.listener
Spring Messaging Event Hubs listener implementation.
com.azure.spring.messaging.eventhubs.core.properties - package com.azure.spring.messaging.eventhubs.core.properties
Spring Messaging Event Hubs properties abstraction.
com.azure.spring.messaging.eventhubs.support - package com.azure.spring.messaging.eventhubs.support
Spring Messaging Event Hubs support utility class.
CommonProperties - Class in com.azure.spring.messaging.eventhubs.core.properties
Common properties shared by event hub namespace, a producer, and a consumer.
CommonProperties() - Constructor for class com.azure.spring.messaging.eventhubs.core.properties.CommonProperties
Create an instance of CommonProperties.
ConsumerProperties - Class in com.azure.spring.messaging.eventhubs.core.properties
An event hub consumer related properties.
ConsumerProperties() - Constructor for class com.azure.spring.messaging.eventhubs.core.properties.ConsumerProperties
Create an instance of ConsumerProperties
createProcessor(String, String, MessageListener<?>, EventHubsErrorHandler) - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProcessorFactory
 
createProcessor(String, String, MessageListener<?>, EventHubsErrorHandler) - Method in interface com.azure.spring.messaging.eventhubs.core.EventHubsProcessorFactory
Create an EventProcessorClient to consume events from the specified event hub in the context of the given consumer group.
createProcessor(String, String, EventHubsContainerProperties) - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProcessorFactory
 
createProcessor(String, String, EventHubsContainerProperties) - Method in interface com.azure.spring.messaging.eventhubs.core.EventHubsProcessorFactory
Create an EventProcessorClient to consume events from the specified event hub in the context of the given consumer group.
createProducer(String) - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProducerFactory
 
createProducer(String) - Method in interface com.azure.spring.messaging.eventhubs.core.EventHubsProducerFactory
Create EventHubProducerAsyncClient to send events to the event hub.

D

DefaultEventHubsNamespaceProcessorFactory - Class in com.azure.spring.messaging.eventhubs.core
DefaultEventHubsNamespaceProcessorFactory(CheckpointStore) - Constructor for class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProcessorFactory
Construct a factory with the provided CheckpointStore.
DefaultEventHubsNamespaceProcessorFactory(CheckpointStore, NamespaceProperties) - Constructor for class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProcessorFactory
Construct a factory with the provided CheckpointStore and namespace level properties.
DefaultEventHubsNamespaceProcessorFactory(CheckpointStore, NamespaceProperties, PropertiesSupplier<ConsumerIdentifier, ProcessorProperties>) - Constructor for class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProcessorFactory
Construct a factory with the provided CheckpointStore, namespace level properties and processor PropertiesSupplier.
DefaultEventHubsNamespaceProcessorFactory(CheckpointStore, PropertiesSupplier<ConsumerIdentifier, ProcessorProperties>) - Constructor for class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProcessorFactory
Construct a factory with the provided CheckpointStore and processor PropertiesSupplier.
DefaultEventHubsNamespaceProducerFactory - Class in com.azure.spring.messaging.eventhubs.core
The EventHubsProducerFactory implementation to produce cached EventHubProducerAsyncClient instances for provided NamespaceProperties and optional producer PropertiesSupplier on each DefaultEventHubsNamespaceProducerFactory.createProducer(java.lang.String) invocation.
DefaultEventHubsNamespaceProducerFactory(NamespaceProperties) - Constructor for class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProducerFactory
Construct a factory with the provided namespace level configuration.
DefaultEventHubsNamespaceProducerFactory(NamespaceProperties, PropertiesSupplier<String, ProducerProperties>) - Constructor for class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProducerFactory
Construct a factory with the provided namespace level configuration and producer PropertiesSupplier.
destroy() - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProcessorFactory
 
destroy() - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProducerFactory
 
doStart() - Method in class com.azure.spring.messaging.eventhubs.core.listener.EventHubsMessageListenerContainer
 
doStop() - Method in class com.azure.spring.messaging.eventhubs.core.listener.EventHubsMessageListenerContainer
 

E

ENQUEUED_TIME - Static variable in class com.azure.spring.messaging.eventhubs.support.EventHubsHeaders
Enqueued time.
EventHubsContainerProperties - Class in com.azure.spring.messaging.eventhubs.core.properties
The properties to describe an Event Hubs listener container.
EventHubsContainerProperties() - Constructor for class com.azure.spring.messaging.eventhubs.core.properties.EventHubsContainerProperties
Creates an instance of EventHubsContainerProperties.
EventHubsHeaders - Class in com.azure.spring.messaging.eventhubs.support
Azure Event Hubs internal headers for Spring Messaging messages.
EventHubsMessageListenerContainer - Class in com.azure.spring.messaging.eventhubs.core.listener
EventHubs message listener container using EventProcessorClient to subscribe to event hubs and consume events from all the partitions of each event hub.
EventHubsMessageListenerContainer(EventHubsProcessorFactory, EventHubsContainerProperties) - Constructor for class com.azure.spring.messaging.eventhubs.core.listener.EventHubsMessageListenerContainer
Create an instance using the supplied processor factory and container properties.
EventHubsProcessorFactory - Interface in com.azure.spring.messaging.eventhubs.core
The strategy to produce EventProcessorClient instance.
EventHubsProcessorFactory.Listener - Interface in com.azure.spring.messaging.eventhubs.core
Called whenever a processor is added or removed.
EventHubsProducerFactory - Interface in com.azure.spring.messaging.eventhubs.core
The strategy to produce EventHubProducerAsyncClient instance.
EventHubsProducerFactory.Listener - Interface in com.azure.spring.messaging.eventhubs.core
Called whenever a producer is added or removed.
EventHubsTemplate - Class in com.azure.spring.messaging.eventhubs.core
A template for executing sending operations asynchronously to Event Hubs.
EventHubsTemplate(EventHubsProducerFactory) - Constructor for class com.azure.spring.messaging.eventhubs.core.EventHubsTemplate
Create an instance using the supplied producer factory.

G

getBatch() - Method in class com.azure.spring.messaging.eventhubs.core.properties.ProcessorProperties
 
getCheckpointConfig() - Method in class com.azure.spring.messaging.eventhubs.core.properties.EventHubsContainerProperties
Get the checkpoint config.
getCloseContextConsumer() - Method in class com.azure.spring.messaging.eventhubs.core.properties.EventHubsContainerProperties
Get the consumer to consume close context.
getConnectionString() - Method in class com.azure.spring.messaging.eventhubs.core.properties.CommonProperties
 
getConsumerGroup() - Method in class com.azure.spring.messaging.eventhubs.core.properties.ConsumerProperties
 
getContainerProperties() - Method in class com.azure.spring.messaging.eventhubs.core.listener.EventHubsMessageListenerContainer
 
getCount() - Method in class com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointConfig
Get the amount of message for each partition to do one checkpoint.
getCustomEndpointAddress() - Method in class com.azure.spring.messaging.eventhubs.core.properties.CommonProperties
 
getDomainName() - Method in class com.azure.spring.messaging.eventhubs.core.properties.CommonProperties
 
getErrorHandler() - Method in class com.azure.spring.messaging.eventhubs.core.properties.EventHubsContainerProperties
Get the error handler of the container.
getEventHubName() - Method in class com.azure.spring.messaging.eventhubs.core.properties.CommonProperties
 
getFullyQualifiedNamespace() - Method in class com.azure.spring.messaging.eventhubs.core.properties.CommonProperties
 
getInitializationContextConsumer() - Method in class com.azure.spring.messaging.eventhubs.core.properties.EventHubsContainerProperties
Get the consumer to consume initialization context.
getInitialPartitionEventPosition() - Method in class com.azure.spring.messaging.eventhubs.core.properties.ProcessorProperties
 
getInterval() - Method in class com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointConfig
Get the time interval to do one checkpoint.
getLoadBalancing() - Method in class com.azure.spring.messaging.eventhubs.core.properties.ProcessorProperties
 
getMessageListener() - Method in class com.azure.spring.messaging.eventhubs.core.properties.EventHubsContainerProperties
Get the message listener of the container.
getMode() - Method in class com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointConfig
Get the checkpoint mode.
getNamespace() - Method in class com.azure.spring.messaging.eventhubs.core.properties.CommonProperties
 
getPartitionId() - Method in class com.azure.spring.messaging.eventhubs.core.PartitionSupplier
Get the partition id.
getPartitionKey() - Method in class com.azure.spring.messaging.eventhubs.core.PartitionSupplier
Get the partition key.
getPrefetchCount() - Method in class com.azure.spring.messaging.eventhubs.core.properties.ConsumerProperties
 
getSharedConnection() - Method in class com.azure.spring.messaging.eventhubs.core.properties.NamespaceProperties
 
getTrackLastEnqueuedEventProperties() - Method in class com.azure.spring.messaging.eventhubs.core.properties.ProcessorProperties
 

L

LAST_ENQUEUED_EVENT_PROPERTIES - Static variable in class com.azure.spring.messaging.eventhubs.support.EventHubsHeaders
Last enqueued event properties.

M

MANUAL - Enum constant in enum com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointMode
User decide when to checkpoint manually

N

NamespaceProperties - Class in com.azure.spring.messaging.eventhubs.core.properties
An event hub namespace related properties.
NamespaceProperties() - Constructor for class com.azure.spring.messaging.eventhubs.core.properties.NamespaceProperties
The default constructor.

O

OFFSET - Static variable in class com.azure.spring.messaging.eventhubs.support.EventHubsHeaders
Offset.

P

PARTITION_COUNT - Enum constant in enum com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointMode
Checkpoint once for number of message specified by CheckpointConfig.getCount() ()} in each partition
PartitionSupplier - Class in com.azure.spring.messaging.eventhubs.core
Represents a supplier of partition id or key.
PartitionSupplier() - Constructor for class com.azure.spring.messaging.eventhubs.core.PartitionSupplier
Create an instance of PartitionSupplier.
processorAdded(String, String, EventProcessorClient) - Method in interface com.azure.spring.messaging.eventhubs.core.EventHubsProcessorFactory.Listener
The callback method that the processor has been added.
ProcessorProperties - Class in com.azure.spring.messaging.eventhubs.core.properties
An event hub processor related properties.
ProcessorProperties() - Constructor for class com.azure.spring.messaging.eventhubs.core.properties.ProcessorProperties
Create an instance of ProcessorProperties.
processorRemoved(String, String, EventProcessorClient) - Method in interface com.azure.spring.messaging.eventhubs.core.EventHubsProcessorFactory.Listener
The default callback method that the processor has been removed.
producerAdded(String, EventHubProducerAsyncClient) - Method in interface com.azure.spring.messaging.eventhubs.core.EventHubsProducerFactory.Listener
The callback method that the producer has been added.
ProducerProperties - Class in com.azure.spring.messaging.eventhubs.core.properties
An event hub producer related properties.
ProducerProperties() - Constructor for class com.azure.spring.messaging.eventhubs.core.properties.ProducerProperties
Create an instance of ProducerProperties.
producerRemoved(String, EventHubProducerAsyncClient) - Method in interface com.azure.spring.messaging.eventhubs.core.EventHubsProducerFactory.Listener
The default callback method that the producer has been removed.

R

RECORD - Enum constant in enum com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointMode
Checkpoint after each processed record.
removeListener(EventHubsProcessorFactory.Listener) - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProcessorFactory
 
removeListener(EventHubsProcessorFactory.Listener) - Method in interface com.azure.spring.messaging.eventhubs.core.EventHubsProcessorFactory
Remove a listener from this factory.
removeListener(EventHubsProducerFactory.Listener) - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProducerFactory
 
removeListener(EventHubsProducerFactory.Listener) - Method in interface com.azure.spring.messaging.eventhubs.core.EventHubsProducerFactory
Remove a listener

S

send(String, Collection<Message<T>>) - Method in class com.azure.spring.messaging.eventhubs.core.EventHubsTemplate
Send a Collection<Message> to the given destination synchronously.
send(String, Collection<Message<T>>, PartitionSupplier) - Method in class com.azure.spring.messaging.eventhubs.core.EventHubsTemplate
Send a Collection<Message> to the given destination with a given partition supplier synchronously.
sendAsync(String, Collection<Message<T>>) - Method in class com.azure.spring.messaging.eventhubs.core.EventHubsTemplate
Send a Collection<Message> to the given destination asynchronously.
sendAsync(String, Collection<Message<T>>, PartitionSupplier) - Method in class com.azure.spring.messaging.eventhubs.core.EventHubsTemplate
Send a Collection<Message> to the given destination with a given partition supplier asynchronously.
sendAsync(String, Message<T>) - Method in class com.azure.spring.messaging.eventhubs.core.EventHubsTemplate
 
SEQUENCE_NUMBER - Static variable in class com.azure.spring.messaging.eventhubs.support.EventHubsHeaders
Sequence number.
setCheckpointConfig(CheckpointConfig) - Method in class com.azure.spring.messaging.eventhubs.core.properties.EventHubsContainerProperties
Set the checkpoint config.
setCloseContextConsumer(Consumer<CloseContext>) - Method in class com.azure.spring.messaging.eventhubs.core.properties.EventHubsContainerProperties
Set the consumer to consume close context.
setConnectionString(String) - Method in class com.azure.spring.messaging.eventhubs.core.properties.CommonProperties
Set the connection string.
setConsumerGroup(String) - Method in class com.azure.spring.messaging.eventhubs.core.properties.ConsumerProperties
Set the custom endpoint address.
setCount(Integer) - Method in class com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointConfig
Set the amount of message for each partition to do one checkpoint.
setCustomEndpointAddress(String) - Method in class com.azure.spring.messaging.eventhubs.core.properties.CommonProperties
Set the custom endpoint address.
setDefaultCredential(TokenCredential) - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProcessorFactory
Set the default credential for all clients generated from this factory.
setDefaultCredential(TokenCredential) - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProducerFactory
Set the default credential for all clients generated from this factory.
setDomainName(String) - Method in class com.azure.spring.messaging.eventhubs.core.properties.CommonProperties
Set the domain name.
setErrorHandler(EventHubsErrorHandler) - Method in class com.azure.spring.messaging.eventhubs.core.listener.EventHubsMessageListenerContainer
Set the error handler to call when the listener throws an exception.
setErrorHandler(EventHubsErrorHandler) - Method in class com.azure.spring.messaging.eventhubs.core.properties.EventHubsContainerProperties
Set the error handler for the container.
setEventHubName(String) - Method in class com.azure.spring.messaging.eventhubs.core.properties.CommonProperties
Set the event hub name.
setInitializationContextConsumer(Consumer<InitializationContext>) - Method in class com.azure.spring.messaging.eventhubs.core.properties.EventHubsContainerProperties
Set the consumer to consume initialization context.
setInterval(Duration) - Method in class com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointConfig
Set the time interval to do one checkpoint.
setMessageConverter(AzureMessageConverter<EventData, EventData>) - Method in class com.azure.spring.messaging.eventhubs.core.EventHubsTemplate
Set the message converter to use.
setMessageListener(MessageListener<?>) - Method in class com.azure.spring.messaging.eventhubs.core.properties.EventHubsContainerProperties
Set the message listener for the container.
setMode(CheckpointMode) - Method in class com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointConfig
Set the checkpoint mode.
setNamespace(String) - Method in class com.azure.spring.messaging.eventhubs.core.properties.CommonProperties
Set the namespace.
setPartitionId(String) - Method in class com.azure.spring.messaging.eventhubs.core.PartitionSupplier
Set the partition id.
setPartitionKey(String) - Method in class com.azure.spring.messaging.eventhubs.core.PartitionSupplier
Set the partition key.
setPrefetchCount(Integer) - Method in class com.azure.spring.messaging.eventhubs.core.properties.ConsumerProperties
Set the prefetch count.
setSharedConnection(Boolean) - Method in class com.azure.spring.messaging.eventhubs.core.properties.NamespaceProperties
Set if to enable shared connection.
setTokenCredentialResolver(AzureCredentialResolver<TokenCredential>) - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProcessorFactory
Set the token credential resolver.
setTokenCredentialResolver(AzureCredentialResolver<TokenCredential>) - Method in class com.azure.spring.messaging.eventhubs.core.DefaultEventHubsNamespaceProducerFactory
Set the token credential resolver.
setTrackLastEnqueuedEventProperties(Boolean) - Method in class com.azure.spring.messaging.eventhubs.core.properties.ProcessorProperties
Set whether to track the last enqueued event properties.
setupMessageListener(MessageListener<?>) - Method in class com.azure.spring.messaging.eventhubs.core.listener.EventHubsMessageListenerContainer
 

T

TIME - Enum constant in enum com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointMode
Checkpoint once for each time interval specified by CheckpointConfig.getInterval() ()}

V

valueOf(String) - Static method in enum com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointMode
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointMode
Returns an array containing the constants of this enum type, in the order they are declared.
A B C D E G L M N O P R S T V 
All Classes and Interfaces|All Packages|Constant Field Values