Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- AbstractAzureMessageConverter<I,
O> - Class in com.azure.spring.messaging.converter -
Abstract class handles common conversion logic between <T> and
Message
- AbstractAzureMessageConverter() - Constructor for class com.azure.spring.messaging.converter.AbstractAzureMessageConverter
- AbstractMessageListenerContainer - Class in com.azure.spring.messaging.listener
-
The base implementation for the
MessageListenerContainer
. - AbstractMessageListenerContainer() - Constructor for class com.azure.spring.messaging.listener.AbstractMessageListenerContainer
- AzureCheckpointer - Class in com.azure.spring.messaging.checkpoint
-
Azure implementation for check point callback.
- AzureCheckpointer(Supplier<Mono<Void>>) - Constructor for class com.azure.spring.messaging.checkpoint.AzureCheckpointer
-
Construct the checkpointer with the
Supplier
for a success operation. - AzureCheckpointer(Supplier<Mono<Void>>, Supplier<Mono<Void>>) - Constructor for class com.azure.spring.messaging.checkpoint.AzureCheckpointer
-
Construct the checkpointer with
Supplier
s for a success operation and failure operation. - AzureHeaders - Class in com.azure.spring.messaging
-
The Azure specific message headers constants.
- AzureHeaders() - Constructor for class com.azure.spring.messaging.AzureHeaders
-
To construct an
AzureHeaders
instance. - AzureMessageConverter<I,
O> - Interface in com.azure.spring.messaging.converter -
A converter to turn the payload of a
Message
from serialized form to a typed Object and vice versa. - AzureSendFailureException - Exception in com.azure.spring.messaging
-
An exception that is the payload of an
ErrorMessage
when a send fails. - AzureSendFailureException(Message<?>, Throwable) - Constructor for exception com.azure.spring.messaging.AzureSendFailureException
-
Construct the
AzureSendFailureException
with the specified detail message and nested exception.
B
- BATCH - Enum constant in enum com.azure.spring.messaging.ListenerMode
-
Each
Message
will be converted from a collection of records returned by a poll. - BATCH_CONVERTED_PARTITION_KEY - Static variable in class com.azure.spring.messaging.AzureHeaders
-
Batch converted partition key.
- buildCustomHeaders(I) - Method in class com.azure.spring.messaging.converter.AbstractAzureMessageConverter
-
Build custom headers from messages received from brokers.
C
- Checkpointer - Interface in com.azure.spring.messaging.checkpoint
-
A callback to perform checkpoint for received messages.
- CHECKPOINTER - Static variable in class com.azure.spring.messaging.AzureHeaders
-
The CHECKPOINTER header for checkpoint the specific message.
- com.azure.spring.messaging - package com.azure.spring.messaging
-
Spring Messaging Azure abstraction.
- com.azure.spring.messaging.checkpoint - package com.azure.spring.messaging.checkpoint
-
Spring Messaging checkpoint abstraction.
- com.azure.spring.messaging.converter - package com.azure.spring.messaging.converter
-
Spring Messaging converter abstraction.
- com.azure.spring.messaging.core - package com.azure.spring.messaging.core
-
Spring Messaging operation abstraction.
- com.azure.spring.messaging.listener - package com.azure.spring.messaging.listener
-
Spring Messaging listener abstraction.
- ConsumerIdentifier - Class in com.azure.spring.messaging
-
The class to describe the consumer identifier according to the consumer destination and group.
- ConsumerIdentifier(String) - Constructor for class com.azure.spring.messaging.ConsumerIdentifier
-
Construct an instance via the consumer destination, which is used for Service Bus Queue.
- ConsumerIdentifier(String, String) - Constructor for class com.azure.spring.messaging.ConsumerIdentifier
-
Construct an instance via the consumer destination and group, which is used for Event Hubs and Service Bus Topic.
- ConversionException - Exception in com.azure.spring.messaging.converter
-
The conversion specific
NestedRuntimeException
. - ConversionException(String) - Constructor for exception com.azure.spring.messaging.converter.ConversionException
-
Construct a
ConversionException
with the specified detail message. - ConversionException(String, Throwable) - Constructor for exception com.azure.spring.messaging.converter.ConversionException
-
Construct a
NestedRuntimeException
with the specified detail message and nested exception.
D
- doStart() - Method in class com.azure.spring.messaging.listener.AbstractMessageListenerContainer
-
Prepare the underlying SDK processor client and start it for subscribing.
- doStop() - Method in class com.azure.spring.messaging.listener.AbstractMessageListenerContainer
-
Stop the underlying SDK processor client.
E
- equals(Object) - Method in class com.azure.spring.messaging.ConsumerIdentifier
F
- failure() - Method in class com.azure.spring.messaging.checkpoint.AzureCheckpointer
- failure() - Method in interface com.azure.spring.messaging.checkpoint.Checkpointer
-
Acknowledge failure of current message.
- fromByte(byte[]) - Method in class com.azure.spring.messaging.converter.AbstractAzureMessageConverter
-
Build an Azure message from the Spring
Message
's payload, when the payload is a byte array. - fromMessage(Message<?>, Class<O>) - Method in class com.azure.spring.messaging.converter.AbstractAzureMessageConverter
- fromMessage(Message<?>, Class<O>) - Method in interface com.azure.spring.messaging.converter.AzureMessageConverter
-
Convert the payload of a
Message
from a serialized form to a typed Object of the specified target class. - fromPayload(Object, Class<U>) - Method in class com.azure.spring.messaging.converter.AbstractAzureMessageConverter
-
Convert payload from byte array to object.
- fromString(String) - Method in class com.azure.spring.messaging.converter.AbstractAzureMessageConverter
-
Build an Azure message from the Spring
Message
's payload, when the payload is a String.
G
- getBeanName() - Method in class com.azure.spring.messaging.listener.AbstractMessageListenerContainer
-
Return the bean name.
- getContainerProperties() - Method in interface com.azure.spring.messaging.listener.MessageListenerContainer
-
Return the container properties for this container.
- getDestination() - Method in class com.azure.spring.messaging.ConsumerIdentifier
-
Get the destination.
- getGroup() - Method in class com.azure.spring.messaging.ConsumerIdentifier
-
Get the group.
- getObjectMapper() - Method in class com.azure.spring.messaging.converter.AbstractAzureMessageConverter
-
Get the object mapper.
- getPayload(I) - Method in class com.azure.spring.messaging.converter.AbstractAzureMessageConverter
-
Get the payload of the received Azure message.
- getPhase() - Method in class com.azure.spring.messaging.listener.AbstractMessageListenerContainer
- getProperties(K) - Method in interface com.azure.spring.messaging.PropertiesSupplier
-
Get the properties by the key.
H
- hasGroup() - Method in class com.azure.spring.messaging.ConsumerIdentifier
-
Return whether the consumer is in a group or not.
- hashCode() - Method in class com.azure.spring.messaging.ConsumerIdentifier
I
- internalToMessage(I, Map<String, Object>, Class<U>) - Method in class com.azure.spring.messaging.converter.AbstractAzureMessageConverter
-
Convert the message received from Azure service to Spring
Message
according to the target payload class. - isActive() - Method in class com.azure.spring.messaging.listener.AbstractMessageListenerContainer
-
Whether this listener container has been started, no matter whether it is stopped later.
- isRunning() - Method in class com.azure.spring.messaging.listener.AbstractMessageListenerContainer
L
- lifecycleMonitor - Variable in class com.azure.spring.messaging.listener.AbstractMessageListenerContainer
-
Life cycle monitor.
- ListenerMode - Enum in com.azure.spring.messaging
-
The listener mode for consuming messages, RECORD or BATCH.
M
- MESSAGE_SESSION - Static variable in class com.azure.spring.messaging.AzureHeaders
-
Message session.
- MessageListenerContainer - Interface in com.azure.spring.messaging.listener
-
Internal abstraction used by the framework representing a message listener container.
N
- NAME - Static variable in class com.azure.spring.messaging.AzureHeaders
-
Name.
P
- PARTITION_ID - Static variable in class com.azure.spring.messaging.AzureHeaders
-
Partition ID.
- PARTITION_KEY - Static variable in class com.azure.spring.messaging.AzureHeaders
-
Partition key.
- PREFIX - Static variable in class com.azure.spring.messaging.AzureHeaders
-
Header prefix.
- PropertiesSupplier<K,
V> - Interface in com.azure.spring.messaging -
An interface to provide properties by providing key.
R
- RAW_PARTITION_ID - Static variable in class com.azure.spring.messaging.AzureHeaders
-
Raw partition ID.
- RECORD - Enum constant in enum com.azure.spring.messaging.ListenerMode
-
Each
Message
will be converted from a single record
S
- SCHEDULED_ENQUEUE_MESSAGE - Static variable in class com.azure.spring.messaging.AzureHeaders
-
Scheduled enqueue message.
- send(String, Message<T>) - Method in interface com.azure.spring.messaging.core.SendOperation
-
Send a
Message
to the given destination synchronously. - sendAsync(String, Message<T>) - Method in interface com.azure.spring.messaging.core.SendOperation
-
Send a
Message
to the given destination asynchronously. - SendOperation - Interface in com.azure.spring.messaging.core
-
Operations for sending
Message
to a destination. - setBeanName(String) - Method in class com.azure.spring.messaging.listener.AbstractMessageListenerContainer
- setCustomHeaders(MessageHeaders, O) - Method in class com.azure.spring.messaging.converter.AbstractAzureMessageConverter
-
Set the custom headers for messages to be sent to different brokers.
- setupMessageListener(MessageListener<?>) - Method in interface com.azure.spring.messaging.listener.MessageListenerContainer
-
Set up the message listener to use.
- start() - Method in class com.azure.spring.messaging.listener.AbstractMessageListenerContainer
- stop() - Method in class com.azure.spring.messaging.listener.AbstractMessageListenerContainer
- stop(Runnable) - Method in class com.azure.spring.messaging.listener.AbstractMessageListenerContainer
- success() - Method in class com.azure.spring.messaging.checkpoint.AzureCheckpointer
- success() - Method in interface com.azure.spring.messaging.checkpoint.Checkpointer
-
Acknowledge success of current message.
T
- toMessage(I, Class<U>) - Method in interface com.azure.spring.messaging.converter.AzureMessageConverter
-
Create an empty header
Message
by default. - toMessage(I, Map<String, Object>, Class<U>) - Method in class com.azure.spring.messaging.converter.AbstractAzureMessageConverter
- toMessage(I, Map<String, Object>, Class<U>) - Method in interface com.azure.spring.messaging.converter.AzureMessageConverter
-
Create a
Message
whose payload is the result of converting the given payload Object to serialized form. - toPayload(Object) - Method in class com.azure.spring.messaging.converter.AbstractAzureMessageConverter
-
Convert payload object to byte array.
V
- valueOf(String) - Static method in enum com.azure.spring.messaging.ListenerMode
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum com.azure.spring.messaging.ListenerMode
-
Returns an array containing the constants of this enum type, in the order they are declared.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form