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
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 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() - 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 binary in the binary store
put(String, InputStream, long, String, Map<String, String>) - Method in interface org.apache.sling.distribution.journal.BinaryStore
  Return the reference for the binary in the binary store.

## 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
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.
verify(String) - Method in interface org.apache.sling.distribution.journal.BinaryStore
  Verifies that the given reference belongs to this BinaryStore.

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