Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- accept(T) - Method in interface org.apache.sling.distribution.journal.MessageSender
-
Make sure every MessageSender also acts as Consumer
- ADD - Enum constant in enum org.apache.sling.distribution.journal.messages.PackageMessage.ReqType
- assertTopic(String) - Method in interface org.apache.sling.distribution.journal.MessagingProvider
-
Validate that a topic is suitably set up for the messaging implementation
- assignTo(long) - Method in interface org.apache.sling.distribution.journal.MessagingProvider
-
Create assign String to feed into poller based on a given offset.
- assignTo(Reset, long) - Method in interface org.apache.sling.distribution.journal.MessagingProvider
-
Get assign String to feed into createPoller based on either earliest or latest and a relative offset.
B
- BinaryStore - Interface in org.apache.sling.distribution.journal
-
Abstraction for storing binaries
C
- ClearCommand - Class in org.apache.sling.distribution.journal.messages
- ClearCommand() - Constructor for class org.apache.sling.distribution.journal.messages.ClearCommand
- create(Class<T>, MessageHandler<T>) - Static method in class org.apache.sling.distribution.journal.HandlerAdapter
- createPoller(String, Reset, String, Map<String, String>, HandlerAdapter<?>...) - Method in interface org.apache.sling.distribution.journal.MessagingProvider
-
Create a poller which listens to a topic and starts at a given reset or assigned offset.
- createPoller(String, Reset, String, HandlerAdapter<?>...) - Method in interface org.apache.sling.distribution.journal.MessagingProvider
-
Create a poller which listens to a topic and starts at a given reset or assigned offset.
- createPoller(String, Reset, HandlerAdapter<?>...) - Method in interface org.apache.sling.distribution.journal.MessagingProvider
- createSender(String) - Method in interface org.apache.sling.distribution.journal.MessagingProvider
-
Create sender for a specific topic
D
- deepPaths - Variable in class org.apache.sling.distribution.journal.messages.PackageDistributedMessage
- DELETE - Enum constant in enum org.apache.sling.distribution.journal.messages.PackageMessage.ReqType
- DiscoveryMessage - Class in org.apache.sling.distribution.journal.messages
- DiscoveryMessage() - Constructor for class org.apache.sling.distribution.journal.messages.DiscoveryMessage
E
- earliest - Enum constant in enum org.apache.sling.distribution.journal.Reset
- ERROR_TOPIC - Static variable in class org.apache.sling.distribution.journal.ExceptionEventSender
- ExceptionEventSender - Class in org.apache.sling.distribution.journal
-
This is used by the journal adapter to send events for exceptions that happen when distribution talks to the journal.
- ExceptionEventSender(EventAdmin) - Constructor for class org.apache.sling.distribution.journal.ExceptionEventSender
F
- fromNumber(int) - Static method in enum org.apache.sling.distribution.journal.messages.PackageStatusMessage.Status
- FullMessage<T> - Class in org.apache.sling.distribution.journal
- FullMessage(MessageInfo, T) - Constructor for class org.apache.sling.distribution.journal.FullMessage
G
- get(String) - Method in interface org.apache.sling.distribution.journal.BinaryStore
-
Return an input stream for the identifier
- getCreateTime() - Method in interface org.apache.sling.distribution.journal.MessageInfo
- getHandler() - Method in class org.apache.sling.distribution.journal.HandlerAdapter
- getInfo() - Method in class org.apache.sling.distribution.journal.FullMessage
- getMessage() - Method in class org.apache.sling.distribution.journal.FullMessage
- getNumber() - Method in enum org.apache.sling.distribution.journal.messages.PackageStatusMessage.Status
- getOffset() - Method in interface org.apache.sling.distribution.journal.MessageInfo
- getPartition() - Method in interface org.apache.sling.distribution.journal.MessageInfo
- getProps() - Method in interface org.apache.sling.distribution.journal.MessageInfo
- getResponseCode() - Method in exception class org.apache.sling.distribution.journal.MessagingException
- getServerUri() - Method in interface org.apache.sling.distribution.journal.MessagingProvider
-
Return the uri of the messaging system backend.
- getTopic() - Method in interface org.apache.sling.distribution.journal.MessageInfo
- getType() - Method in class org.apache.sling.distribution.journal.HandlerAdapter
H
- handle(MessageInfo, T) - Method in interface org.apache.sling.distribution.journal.MessageHandler
- HandlerAdapter<T> - Class in org.apache.sling.distribution.journal
I
- IMPORTED - Enum constant in enum org.apache.sling.distribution.journal.messages.PackageStatusMessage.Status
-
The package has been applied
- INVALIDATE - Enum constant in enum org.apache.sling.distribution.journal.messages.PackageMessage.ReqType
J
- JournalAvailable - Interface in org.apache.sling.distribution.journal
-
Marker service to signal that the Journal service is available and correctly configured
K
- KEY_ERROR_CODE - Static variable in class org.apache.sling.distribution.journal.ExceptionEventSender
- KEY_MESSAGE - Static variable in class org.apache.sling.distribution.journal.ExceptionEventSender
- KEY_TYPE - Static variable in class org.apache.sling.distribution.journal.ExceptionEventSender
L
- latest - Enum constant in enum org.apache.sling.distribution.journal.Reset
- ListPrinter - Class in org.apache.sling.distribution.journal.messages
- LogMessage - Class in org.apache.sling.distribution.journal.messages
- LogMessage() - Constructor for class org.apache.sling.distribution.journal.messages.LogMessage
M
- MessageHandler<T> - Interface in org.apache.sling.distribution.journal
- MessageInfo - Interface in org.apache.sling.distribution.journal
- MessageSender<T> - Interface in org.apache.sling.distribution.journal
- MessagingException - Exception Class in org.apache.sling.distribution.journal
- MessagingException(String) - Constructor for exception class org.apache.sling.distribution.journal.MessagingException
- MessagingException(String, Exception) - Constructor for exception class org.apache.sling.distribution.journal.MessagingException
- MessagingException(String, String) - Constructor for exception class org.apache.sling.distribution.journal.MessagingException
- MessagingProvider - Interface in org.apache.sling.distribution.journal
-
Messaging abstraction for a journal based messaging like Apache Kafka.
O
- offset - Variable in class org.apache.sling.distribution.journal.messages.PackageDistributedMessage
- OffsetMessage - Class in org.apache.sling.distribution.journal.messages
-
Synthetic message create by poller to signal the offset when starting from earliest or latest.
- OffsetMessage() - Constructor for class org.apache.sling.distribution.journal.messages.OffsetMessage
- org.apache.sling.distribution.journal - package org.apache.sling.distribution.journal
- org.apache.sling.distribution.journal.messages - package org.apache.sling.distribution.journal.messages
P
- PackageDistributedMessage - Class in org.apache.sling.distribution.journal.messages
- PackageDistributedMessage() - Constructor for class org.apache.sling.distribution.journal.messages.PackageDistributedMessage
- packageId - Variable in class org.apache.sling.distribution.journal.messages.PackageDistributedMessage
- PackageMessage - Class in org.apache.sling.distribution.journal.messages
- PackageMessage() - Constructor for class org.apache.sling.distribution.journal.messages.PackageMessage
- PackageMessage.ReqType - Enum in org.apache.sling.distribution.journal.messages
- PackageStatusMessage - Class in org.apache.sling.distribution.journal.messages
- PackageStatusMessage() - Constructor for class org.apache.sling.distribution.journal.messages.PackageStatusMessage
- PackageStatusMessage.Status - Enum in org.apache.sling.distribution.journal.messages
- paths - Variable in class org.apache.sling.distribution.journal.messages.PackageDistributedMessage
- PingMessage - Class in org.apache.sling.distribution.journal.messages
- PingMessage() - Constructor for class org.apache.sling.distribution.journal.messages.PingMessage
- pubAgentName - Variable in class org.apache.sling.distribution.journal.messages.PackageDistributedMessage
- put(String, InputStream, long) - Method in interface org.apache.sling.distribution.journal.BinaryStore
-
Return the reference for the
R
- REMOVED - Enum constant in enum org.apache.sling.distribution.journal.messages.PackageStatusMessage.Status
-
The package has been removed explicitly
- REMOVED_FAILED - Enum constant in enum org.apache.sling.distribution.journal.messages.PackageStatusMessage.Status
-
The package has been removed automatically after failing every retry attempts
- Reset - Enum in org.apache.sling.distribution.journal
- retrieveOffset(String, Reset) - Method in interface org.apache.sling.distribution.journal.MessagingProvider
-
Retrieve earliest or latest offset for a topic
- RunnableUtil - Class in org.apache.sling.distribution.journal
S
- send(Exception) - Method in class org.apache.sling.distribution.journal.ExceptionEventSender
- send(T) - Method in interface org.apache.sling.distribution.journal.MessageSender
- send(T, Map<String, String>) - Method in interface org.apache.sling.distribution.journal.MessageSender
- startBackgroundThread(Runnable, String) - Static method in class org.apache.sling.distribution.journal.RunnableUtil
- SubscriberConfig - Class in org.apache.sling.distribution.journal.messages
- SubscriberConfig() - Constructor for class org.apache.sling.distribution.journal.messages.SubscriberConfig
- SubscriberState - Class in org.apache.sling.distribution.journal.messages
- SubscriberState() - Constructor for class org.apache.sling.distribution.journal.messages.SubscriberState
T
- TEST - Enum constant in enum org.apache.sling.distribution.journal.messages.PackageMessage.ReqType
- toString() - Method in class org.apache.sling.distribution.journal.HandlerAdapter
- toString() - Method in class org.apache.sling.distribution.journal.messages.PackageMessage
- toString(boolean) - Method in class org.apache.sling.distribution.journal.messages.PackageMessage
V
- valueOf(String) - Static method in enum org.apache.sling.distribution.journal.messages.PackageMessage.ReqType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.sling.distribution.journal.messages.PackageStatusMessage.Status
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.sling.distribution.journal.Reset
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum org.apache.sling.distribution.journal.messages.PackageMessage.ReqType
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.apache.sling.distribution.journal.messages.PackageStatusMessage.Status
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.apache.sling.distribution.journal.Reset
-
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