A B C D E F G H I J K L M O P R S T V 
All Classes All Packages

A

accept(T) - Method in interface org.apache.sling.distribution.journal.MessageSender
Make sure every MessageSender also acts as Consumer
ADD - 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 - 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 - 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 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 - org.apache.sling.distribution.journal.messages.PackageStatusMessage.Status
The package has been applied
INVALIDATE - 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 - org.apache.sling.distribution.journal.Reset
 
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 in org.apache.sling.distribution.journal
 
MessagingException(String) - Constructor for exception org.apache.sling.distribution.journal.MessagingException
 
MessagingException(String, Exception) - Constructor for exception org.apache.sling.distribution.journal.MessagingException
 
MessagingException(String, String) - Constructor for exception 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(String, PackageMessage.ReqType, String, String, long, byte[], String, String, String, List<String>, List<String>) - 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 - org.apache.sling.distribution.journal.messages.PackageStatusMessage.Status
The package has been removed explicitly
REMOVED_FAILED - 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 - 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
 

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.
A B C D E F G H I J K L M O P R S T V 
All Classes All Packages