Index

A B C D E F G H I L M N P R S T V 
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 Suppliers 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.
A B C D E F G H I L M N P R S T V 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form