Index (delivery4j 1.1.6 API)

A B C D E F G H I J K L M N O P R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values

A

AbstractMessenger - Class in com.saicone.delivery4j: Messenger abstract class to send messages across channels using a Broker.
This class doesn't offer any abstract method making it usable as plain object, but it's suggested to extend it and override AbstractMessenger.loadBroker() if you want your own implementation.
AbstractMessenger() - Constructor for class com.saicone.delivery4j.AbstractMessenger
accept(byte[]) - Method in class com.saicone.delivery4j.MessageChannel: Accept the provided pre-decoded data into current consumer.
accept(String, byte[]) - Method in class com.saicone.delivery4j.AbstractMessenger: Receive provided byte data to be encoded as readable multi-line message.
accept(String, T) - Method in interface com.saicone.delivery4j.ChannelConsumer: Performs this operation with the given channel name and the data produced by itself.
ActiveMQBroker - Class in com.saicone.delivery4j.broker: ActiveMQ broker implementation to send data using topic producers and consumers.
ActiveMQBroker(Connection) - Constructor for class com.saicone.delivery4j.broker.ActiveMQBroker: Create an activemq broker by providing a connection.
ActiveMQBroker.Bridge - Class in com.saicone.delivery4j.broker: Bridge class to save message producer and consumer for specific topic.
ALPHABET - Static variable in class com.saicone.delivery4j.util.Z85: Z85 encoding alphabet, only the characters in this string are valid for Z85 encoding.
andThen(ChannelConsumer) - Method in interface com.saicone.delivery4j.ChannelConsumer: Returns a composed ChannelConsumer that performs, in sequence, this operation followed by the after operation.

B

BASE64 - Static variable in interface com.saicone.delivery4j.util.ByteCodec: Base64 byte codec that convert bytes into/from Base64 String.
bit32() - Static method in interface com.saicone.delivery4j.util.DataIdentifier: Get a 32-bit data identifier.
Bit32() - Constructor for class com.saicone.delivery4j.util.DataIdentifier.Bit32
bit64() - Static method in interface com.saicone.delivery4j.util.DataIdentifier: Get a 64-bit data identifier.
Bit64() - Constructor for class com.saicone.delivery4j.util.DataIdentifier.Bit64
Bridge(String) - Constructor for class com.saicone.delivery4j.broker.ActiveMQBroker.Bridge: Constructs a bridge with the provided channel.
Broker - Class in com.saicone.delivery4j: Represents an object that can transfer byte-array data across channels.
In popular terms, this is a globalized producer that deliver/publish temporary data to multiple consumers using topics or queues (depending on the implementation) and can also consume the data itself by subscribing to channels.
Broker() - Constructor for class com.saicone.delivery4j.Broker
ByteCodec<T> - Interface in com.saicone.delivery4j.util: Byte codec interface to encode and decode bytes into desired object.

C

cancel(T) - Method in interface com.saicone.delivery4j.util.TaskExecutor: Cancel a task type that was created by this executor.
ChannelConsumer<T> - Interface in com.saicone.delivery4j: Represents and operation that accept a channel name and the data produced by the channel.
Unlike Consumer, this operation can throw an IOException.
cleanMessages() - Method in class com.saicone.delivery4j.broker.SqlBroker: Clean old messages from database.
clear() - Method in class com.saicone.delivery4j.AbstractMessenger: Clear any message channels and incoming consumers.
clear() - Method in class com.saicone.delivery4j.Broker: Clear all subscribed channels from broker.
clear() - Method in class com.saicone.delivery4j.MessageChannel: Clear the current message channel instance.
close() - Method in class com.saicone.delivery4j.AbstractMessenger: Close the messenger instance connection.
close() - Method in class com.saicone.delivery4j.broker.ActiveMQBroker.Bridge: Close the current activemq connection.
close() - Method in class com.saicone.delivery4j.Broker: Close the broker connection.
close() - Method in class com.saicone.delivery4j.broker.JedisBroker.Listener: Close the subscription to channels.
close() - Method in class com.saicone.delivery4j.broker.LettuceBroker.Listener: Close the subscription to channels.
close() - Method in class com.saicone.delivery4j.broker.ValkeyBroker.Listener: Close the subscription to channels.
close() - Method in interface com.saicone.delivery4j.util.ConnectionSupplier: Close the provided connection, making it unable to give a value after this operation.
close() - Method in interface com.saicone.delivery4j.util.TaskExecutor
com.saicone.delivery4j - package com.saicone.delivery4j
com.saicone.delivery4j.broker - package com.saicone.delivery4j.broker
com.saicone.delivery4j.util - package com.saicone.delivery4j.util
ConnectionSupplier - Interface in com.saicone.delivery4j.util: Minimalist interface which provides a Connection.
This implementation can also provide information about connection state.
consume(ChannelConsumer) - Method in class com.saicone.delivery4j.MessageChannel: Set or append provided consumer into channel inbound consumer.
consumeBefore(ChannelConsumer) - Method in class com.saicone.delivery4j.MessageChannel: Set or append before provided consumer into channel inbound consumer.
contains(int) - Method in class com.saicone.delivery4j.util.DataIdentifier.Bit32: Check if the provided id belongs to a generated identifier.
contains(long) - Method in class com.saicone.delivery4j.util.DataIdentifier.Bit64: Check if the provided id belongs to a generated identifier.

D

DataIdentifier - Interface in com.saicone.delivery4j.util: An object to generate and identify messages with a unique id.
DataIdentifier.Bit32 - Class in com.saicone.delivery4j.util: A 32-bit data identifier that generates unique integer ids.
DataIdentifier.Bit64 - Class in com.saicone.delivery4j.util: A 64-bit data identifier that generates unique long ids.
DEBUG - Static variable in interface com.saicone.delivery4j.util.LogFilter: Debug logging level.
Completely unnecessary information that is only useful when you want to track a problem in the code by providing a view of the running application as most descriptive way possible.
decode(byte[]) - Method in class com.saicone.delivery4j.MessageChannel: Decodes a byte array into a multi-line message.
decode(String) - Method in class com.saicone.delivery4j.util.Z85.Decoder: Decodes a Z85 encoded String into a newly created byte array using the Z85 encoding scheme.
decode(T) - Method in interface com.saicone.delivery4j.util.ByteCodec: Decodes an object type into a newly-allocated byte array.
Decoder() - Constructor for class com.saicone.delivery4j.util.Z85.Decoder
decodeToString(T) - Method in interface com.saicone.delivery4j.util.ByteCodec: Decodes an object type into a String using default charset.
decodeToString(T, Charset) - Method in interface com.saicone.delivery4j.util.ByteCodec: Decodes an object type into a String using the specified charset.
decrypt(byte[]) - Method in interface com.saicone.delivery4j.util.Encryptor: Decrypts the input data.
decryptUTF(byte[]) - Method in interface com.saicone.delivery4j.util.Encryptor: Decrypts the input data and return itself as readable String.
decryptUTF(byte[], Charset) - Method in interface com.saicone.delivery4j.util.Encryptor: Decrypts the input data and return itself as readable String.

E

empty() - Static method in interface com.saicone.delivery4j.util.Encryptor: Get an empty encryptor that does not perform any encryption/decryption.
This instance also writes and reads data using DataOutput/DataInput UTF methods.
EMPTY - Static variable in interface com.saicone.delivery4j.util.Encryptor: Empty encryptor instance.
encode(byte[]) - Method in interface com.saicone.delivery4j.util.ByteCodec: Encodes the specified byte array into object type.
encode(byte[]) - Method in class com.saicone.delivery4j.util.Z85.Encoder: Encodes the specified byte array into a String using the Z85 encoding scheme.
encode(Object...) - Method in class com.saicone.delivery4j.MessageChannel: Encodes the specified message lines into byte array.
encodeFromString(String) - Method in interface com.saicone.delivery4j.util.ByteCodec: Encodes the specified String into object type using default charset.
encodeFromString(String, Charset) - Method in interface com.saicone.delivery4j.util.ByteCodec: Encodes the specified String into object type using the specified charset.
Encoder() - Constructor for class com.saicone.delivery4j.util.Z85.Encoder
encrypt(byte[]) - Method in interface com.saicone.delivery4j.util.Encryptor: Encrypts the input data.
encryptor(Encryptor) - Method in class com.saicone.delivery4j.MessageChannel: Set the message encryptor for the current message channel.
Encryptor - Interface in com.saicone.delivery4j.util: Encryptor interface to encrypt and decrypt any provided String.
By default, this is just a bridge to regular Java Cipher usage.
encryptUTF(String) - Method in interface com.saicone.delivery4j.util.Encryptor: Encrypts the input String data and return itself as byte array.
encryptUTF(String, Charset) - Method in interface com.saicone.delivery4j.util.Encryptor: Encrypts the input String data and return itself as byte array.
ERROR - Static variable in interface com.saicone.delivery4j.util.LogFilter: Error logging level.
This level generally represent information that the logger must receive since an error have important consequences on the running code.
execute(Runnable) - Method in interface com.saicone.delivery4j.util.TaskExecutor: Executes the given command at some time in the future.
Unlike Executor.execute(Runnable), this method return the task itself, that can be cancelled at some time in the future.
For example, a recursive call that locks the thread can be cancelled if it's executed using this method.
execute(Runnable, long, long, TimeUnit) - Method in interface com.saicone.delivery4j.util.TaskExecutor: Executes the given command after the initial delay has passed, and then periodically executed with the specified period.
execute(Runnable, long, TimeUnit) - Method in interface com.saicone.delivery4j.util.TaskExecutor: Executes the given command after the time delay has passed.
execute(Runnable, Duration) - Method in interface com.saicone.delivery4j.util.TaskExecutor: Executes the given command after the time delay has passed.
execute(Runnable, Duration, Duration) - Method in interface com.saicone.delivery4j.util.TaskExecutor: Executes the given command after the initial delay has passed, and then periodically executed with the specified period.
executor() - Method in interface com.saicone.delivery4j.util.TaskExecutor: Return the current executor as Java Executor.

F

from(ExecutorService, ScheduledExecutorService) - Static method in interface com.saicone.delivery4j.util.TaskExecutor: Creates a TaskExecutor from an ExecutorService and a ScheduledExecutorService.
from(ScheduledExecutorService) - Static method in interface com.saicone.delivery4j.util.TaskExecutor: Creates a TaskExecutor from a ScheduledExecutorService.

G

get() - Method in interface com.saicone.delivery4j.util.ConnectionSupplier
getBroker() - Method in class com.saicone.delivery4j.AbstractMessenger: Get the current broker.
getChannel() - Method in class com.saicone.delivery4j.broker.ActiveMQBroker.Bridge: Get the current subscribed channel.
getChannels() - Method in class com.saicone.delivery4j.AbstractMessenger: Get the current subscribed channels.
getClient() - Method in class com.saicone.delivery4j.broker.LettuceBroker: Get the current client.
getCodec() - Method in class com.saicone.delivery4j.PlainTextBroker: Get the current byte codec.
getConnection() - Method in class com.saicone.delivery4j.broker.NatsBroker: Get the current connection.
getConnection() - Method in class com.saicone.delivery4j.broker.RabbitMQBroker: The current connection.
getConnection() - Method in interface com.saicone.delivery4j.util.ConnectionSupplier: Get the connection object from this supplier.
getConnectionSupplier() - Method in class com.saicone.delivery4j.broker.PostgreSQLBroker: Get the current connection supplier that database connection is from.
getConnectionSupplier() - Method in class com.saicone.delivery4j.broker.SqlBroker: Get the current connection supplier that database connection is from.
getConsumer() - Method in class com.saicone.delivery4j.broker.ActiveMQBroker.Bridge: Get the current consumer used to listed messages from topic.
getConsumer() - Method in class com.saicone.delivery4j.Broker: Get the current channel consumer.
getConsumer() - Method in class com.saicone.delivery4j.MessageChannel: Get the current message consumer.
getDecoder() - Static method in class com.saicone.delivery4j.util.Z85: Get a Z85.Decoder instance that decodes using the Default Z85 encoding scheme.
getDispatcher() - Method in class com.saicone.delivery4j.broker.NatsBroker: Get the current dispatcher.
getEncoder() - Static method in class com.saicone.delivery4j.util.Z85: Get a Z85.Encoder instance that encodes using the Default Z85 encoding scheme.
getEncryptor() - Method in class com.saicone.delivery4j.MessageChannel: Get the current encryptor.
getExecutor() - Method in class com.saicone.delivery4j.AbstractMessenger: Get the current executor, by default ForkJoinPool.commonPool() is used.
getExecutor() - Method in class com.saicone.delivery4j.Broker: Get the current delayed executor.
getHikari() - Method in class com.saicone.delivery4j.broker.HikariBroker: Get the current hikari data source used on this instance.
getHikari() - Method in class com.saicone.delivery4j.broker.PostgreSQLHikariBroker: Get the current hikari data source used on this instance.
getIdentifier() - Method in class com.saicone.delivery4j.MessageChannel: Get the current data identifier.
getJedis() - Method in class com.saicone.delivery4j.broker.JedisBroker: Get the current pool.
getJedis() - Method in class com.saicone.delivery4j.broker.ValkeyBroker: Get the current pool.
getListener() - Method in class com.saicone.delivery4j.broker.JedisBroker: Get the current bridge to receive messages.
getListener() - Method in class com.saicone.delivery4j.broker.LettuceBroker: Get the current bridge to receive messages.
getListener() - Method in class com.saicone.delivery4j.broker.ValkeyBroker: Get the current bridge to receive messages.
getLogger() - Method in class com.saicone.delivery4j.Broker: Get the current logger.
getMessages() - Method in class com.saicone.delivery4j.broker.SqlBroker: Get all unread messages from database.
getName() - Method in class com.saicone.delivery4j.MessageChannel: Get the current channel name.
getPaddedDecoder() - Static method in class com.saicone.delivery4j.util.Z85: Get a Z85.Decoder instance that decodes using the Padded Z85 encoding scheme.
If a String is not a multiple of 5, it is padded with '\0' characters.
getPaddedEncoder() - Static method in class com.saicone.delivery4j.util.Z85: Get a Z85.Encoder instance that encodes using the Padded Z85 encoding scheme.
If an array length is not a multiple of 4, it is padded with empty bytes.
getProducer() - Method in class com.saicone.delivery4j.broker.ActiveMQBroker.Bridge: Get the current producer used to send messages to topic.
getProducer() - Method in class com.saicone.delivery4j.broker.KafkaBroker: Get the current producer.
getPubSubConnection() - Method in class com.saicone.delivery4j.broker.LettuceBroker: Get the current pubsub connection.
getSleepTime() - Method in class com.saicone.delivery4j.broker.JedisBroker: Get the current reconnection interval time.
getSleepTime() - Method in class com.saicone.delivery4j.broker.LettuceBroker: Get the current reconnection interval time.
getSleepTime() - Method in class com.saicone.delivery4j.broker.ValkeyBroker: Get the current reconnection interval time.
getSleepUnit() - Method in class com.saicone.delivery4j.broker.JedisBroker: Get the current reconnection interval unit.
getSleepUnit() - Method in class com.saicone.delivery4j.broker.LettuceBroker: Get the current reconnection interval unit.
getSleepUnit() - Method in class com.saicone.delivery4j.broker.ValkeyBroker: Get the current reconnection interval unit.
getStrictDecoder() - Static method in class com.saicone.delivery4j.util.Z85: Get a Z85.Decoder instance that decodes using the Strict Z85 encoding scheme.
getStrictEncoder() - Static method in class com.saicone.delivery4j.util.Z85: Get a Z85.Encoder instance that encodes using the Strict Z85 encoding scheme.
getSubscribedChannels() - Method in class com.saicone.delivery4j.Broker: Get the subscribed channels.
getTablePrefix() - Method in class com.saicone.delivery4j.broker.SqlBroker: Get the current table prefix that is used before messenger table name.

H

HikariBroker - Class in com.saicone.delivery4j.broker: Sql broker implementation that use hikari library to make connections to database.
The operations are the same as sql broker, it just made any connection with hikari library.
HikariBroker(HikariDataSource) - Constructor for class com.saicone.delivery4j.broker.HikariBroker: Constructs a hikari broker using the provided data source instance.

I

identifier(DataIdentifier) - Method in class com.saicone.delivery4j.MessageChannel: Set the data identifier for the current message channel.
INFO - Static variable in interface com.saicone.delivery4j.util.LogFilter: Info logging level.
Just one-time information that can be skipped and offer a general state of the running code.
isAvailable() - Method in class com.saicone.delivery4j.broker.JedisBroker: Check if the broker is available to send and receive messages.
isAvailable() - Method in class com.saicone.delivery4j.broker.LettuceBroker: Check if the broker is available to send and receive messages.
isAvailable() - Method in class com.saicone.delivery4j.broker.ValkeyBroker: Check if the broker is available to send and receive messages.
isClosable() - Method in interface com.saicone.delivery4j.util.ConnectionSupplier: Get the current connection type offered by this supplier.
isConnectionClosed() - Method in class com.saicone.delivery4j.broker.LettuceBroker: Check if the lettuce connection is closed or not.
isEnabled() - Method in class com.saicone.delivery4j.AbstractMessenger: Get the current messenger status.
isEnabled() - Method in class com.saicone.delivery4j.Broker: Get the current broker status.
isJedisClosed() - Method in class com.saicone.delivery4j.broker.JedisBroker: Check if the jedis connection is closed or not.
isJedisClosed() - Method in class com.saicone.delivery4j.broker.ValkeyBroker: Check if the jedis connection is closed or not.
isRunning() - Method in interface com.saicone.delivery4j.util.ConnectionSupplier: Get the current running status connection.

J

Java(Logger, Supplier) - Constructor for class com.saicone.delivery4j.util.LogFilter.Java: Constructor of Java LogFilter.
JAVA - Static variable in interface com.saicone.delivery4j.util.TaskExecutor: Task executor object that use Java methods to execute tasks.
Is NOT suggested to use this object due is not scalable and doesn't use any thread pool, make a better implementation instead.
JedisBroker - Class in com.saicone.delivery4j.broker: Redis broker implementation to send data via publish and subscriptions.
This kind of broker will encode any byte array as String and viceversa.
Some operations made in this instance can fail due authentication errors, so it requires the password as well.
JedisBroker(UnifiedJedis) - Constructor for class com.saicone.delivery4j.broker.JedisBroker: Constructs a redis broker with provided redis client.
JedisBroker(UnifiedJedis, Function) - Constructor for class com.saicone.delivery4j.broker.JedisBroker: Constructs a redis broker with provided redis client and bridge.
JedisBroker.Listener - Class in com.saicone.delivery4j.broker: Bridge class to detect received messages from Redis database.

K

KafkaBroker<K> - Class in com.saicone.delivery4j.broker: Kafka broker implementation to publish and consumer using empty-keys records.
Take in count that any producer and consumer used in this instance should be compatible with byte array values.
KafkaBroker(Properties, Properties) - Constructor for class com.saicone.delivery4j.broker.KafkaBroker: Constructs a kafka broker using provided properties for producer and consumer.
KafkaBroker(KafkaProducer, KafkaConsumer) - Constructor for class com.saicone.delivery4j.broker.KafkaBroker: Constructs a kafka broker using provided producer and consumer.

L

LettuceBroker - Class in com.saicone.delivery4j.broker: Redis broker implementation to send data via publish and subscriptions.
This kind of broker will encode any byte array as String and viceversa.
Some operations made in this instance can fail due authentication errors, so it requires the password as well.
LettuceBroker(RedisClient) - Constructor for class com.saicone.delivery4j.broker.LettuceBroker: Constructs a redis broker with provided redis client.
LettuceBroker(RedisClient, Function) - Constructor for class com.saicone.delivery4j.broker.LettuceBroker: Constructs a redis broker with provided redis client and bridge.
LettuceBroker.Listener - Class in com.saicone.delivery4j.broker: Bridge class to detect received messages from Redis database.
Listener(JedisBroker) - Constructor for class com.saicone.delivery4j.broker.JedisBroker.Listener: Constructs a bridge with provided broker.
Listener(LettuceBroker) - Constructor for class com.saicone.delivery4j.broker.LettuceBroker.Listener: Constructs a bridge with provided broker.
Listener(ValkeyBroker) - Constructor for class com.saicone.delivery4j.broker.ValkeyBroker.Listener: Constructs a bridge with provided broker.
loadBroker() - Method in class com.saicone.delivery4j.AbstractMessenger: Method to load the used broker on data transfer operations.
log(int, String) - Method in class com.saicone.delivery4j.util.LogFilter.Java
log(int, String) - Method in interface com.saicone.delivery4j.util.LogFilter: Log a message.
log(int, String) - Method in class com.saicone.delivery4j.util.LogFilter.Log4j
log(int, String) - Method in class com.saicone.delivery4j.util.LogFilter.Slf4j
log(int, String, Throwable) - Method in class com.saicone.delivery4j.util.LogFilter.Java
log(int, String, Throwable) - Method in interface com.saicone.delivery4j.util.LogFilter: Log a message, with associated Throwable information.
log(int, String, Throwable) - Method in class com.saicone.delivery4j.util.LogFilter.Log4j
log(int, String, Throwable) - Method in class com.saicone.delivery4j.util.LogFilter.Slf4j
log(int, Supplier) - Method in class com.saicone.delivery4j.util.LogFilter.Java
log(int, Supplier) - Method in interface com.saicone.delivery4j.util.LogFilter: Log a message, which is only to be constructed if the logging level is allowed by current implementation.
log(int, Supplier) - Method in class com.saicone.delivery4j.util.LogFilter.Log4j
log(int, Supplier) - Method in class com.saicone.delivery4j.util.LogFilter.Slf4j
log(int, Supplier, Throwable) - Method in class com.saicone.delivery4j.util.LogFilter.Java
log(int, Supplier, Throwable) - Method in interface com.saicone.delivery4j.util.LogFilter: Log a message, which is only to be constructed if the logging level is allowed by current implementation.
log(int, Supplier, Throwable) - Method in class com.saicone.delivery4j.util.LogFilter.Log4j
log(int, Supplier, Throwable) - Method in class com.saicone.delivery4j.util.LogFilter.Slf4j
Log4j(Logger, Supplier) - Constructor for class com.saicone.delivery4j.util.LogFilter.Log4j: Constructor of Log4j LogFilter.
LogFilter - Interface in com.saicone.delivery4j.util: A minimalist representation of a Logger implementation with a small amount of logging levels.
Unlike normal logger implementations, this one uses numbers as levels:
1 = ERROR / SEVERE
2 = WARNING
3 = INFO
4 = DEBUG INFORMATION
LogFilter.Java - Class in com.saicone.delivery4j.util: Java Util Logging implementation of LogFilter.
LogFilter.Log4j - Class in com.saicone.delivery4j.util: Log4j2 implementation of LogFilter.
LogFilter.Slf4j - Class in com.saicone.delivery4j.util: SLF4J implementation of LogFilter.
logger() - Method in class com.saicone.delivery4j.util.LogFilter.Java: Get the underlying Java Util Logging logger.
logger() - Method in class com.saicone.delivery4j.util.LogFilter.Log4j: Get the underlying Log4j2 logger.
logger() - Method in class com.saicone.delivery4j.util.LogFilter.Slf4j: Get the underlying SLF4J logger.

M

maxLevel() - Method in class com.saicone.delivery4j.util.LogFilter.Java
maxLevel() - Method in class com.saicone.delivery4j.util.LogFilter.Log4j
maxLevel() - Method in interface com.saicone.delivery4j.util.LogFilter: The maximum logging level accepted by the used logger implementation.
maxLevel() - Method in class com.saicone.delivery4j.util.LogFilter.Slf4j
message(String, byte[]) - Method in class com.saicone.delivery4j.broker.LettuceBroker.Listener
message(String, String, byte[]) - Method in class com.saicone.delivery4j.broker.LettuceBroker.Listener
MessageChannel - Class in com.saicone.delivery4j: An object to consume channel messages.
This object can also provide an Encryptor to make a secure message delivery.
MessageChannel(String) - Constructor for class com.saicone.delivery4j.MessageChannel: Constructs a message channel with provided name.
MessageChannel(String, ChannelConsumer) - Constructor for class com.saicone.delivery4j.MessageChannel: Constructs a message channel with provided name and consumer.

N

NatsBroker - Class in com.saicone.delivery4j.broker: NATS broker implementation to publish data and consume it with subject subscription.
NatsBroker(Connection) - Constructor for class com.saicone.delivery4j.broker.NatsBroker: Constructs a nats broker with provided connection.
next() - Method in class com.saicone.delivery4j.util.DataIdentifier.Bit32: Generate the next unique id.
next() - Method in class com.saicone.delivery4j.util.DataIdentifier.Bit64: Generate the next unique id.

O

of(String) - Static method in class com.saicone.delivery4j.MessageChannel: Create a message channel with provided name.
of(String, int, String, String, String, String) - Static method in class com.saicone.delivery4j.broker.RabbitMQBroker: Create a rabbitmq broker with provided parameters.
of(String, String) - Static method in class com.saicone.delivery4j.broker.KafkaBroker: Create a kafka broker with provided parameters.
This method by default use `void` keys to provide a full empty-key interaction.
of(String, String) - Static method in class com.saicone.delivery4j.broker.RabbitMQBroker: Create a rabbitmq broker with provided parameters.
of(String, String, String) - Static method in class com.saicone.delivery4j.broker.HikariBroker: Create a hikari broker with the provided connection parameters.
of(String, String, String) - Static method in class com.saicone.delivery4j.broker.PostgreSQLBroker: Create a postgres broker with the provided connection parameters.
of(String, String, String) - Static method in class com.saicone.delivery4j.broker.PostgreSQLHikariBroker: Create a postgres hikari broker with the provided connection parameters.
of(String, String, String) - Static method in class com.saicone.delivery4j.broker.SqlBroker: Create a sql broker with the provided connection parameters.
of(String, String, String, boolean) - Static method in class com.saicone.delivery4j.broker.NatsBroker: Create a nats broker with provided parameters.
of(String, String, String, Duration) - Static method in class com.saicone.delivery4j.broker.NatsBroker: Create a nats broker with provided parameters.
of(String, SecretKey) - Static method in interface com.saicone.delivery4j.util.Encryptor: Create an encryptor with provided arguments that performs automatic resets if any error occurs on encryption/decryption.
of(URI, String) - Static method in class com.saicone.delivery4j.broker.RabbitMQBroker: Create a rabbitmq broker with provided parameters.
of(Consumer) - Static method in class com.saicone.delivery4j.broker.NatsBroker: Create a nats broker by providing builder options.
of(Consumer) - Static method in class com.saicone.delivery4j.broker.ActiveMQBroker: Create an activemq broker by providing connection factory.
of(SecretKey) - Static method in interface com.saicone.delivery4j.util.Encryptor: Create an encryptor with provided arguments that performs automatic resets if any error occurs on encryption/decryption.
onClose() - Method in class com.saicone.delivery4j.broker.ActiveMQBroker
onClose() - Method in class com.saicone.delivery4j.broker.JedisBroker
onClose() - Method in class com.saicone.delivery4j.broker.KafkaBroker
onClose() - Method in class com.saicone.delivery4j.broker.LettuceBroker
onClose() - Method in class com.saicone.delivery4j.broker.NatsBroker
onClose() - Method in class com.saicone.delivery4j.Broker: Method to run when broker closes.
onClose() - Method in class com.saicone.delivery4j.broker.PostgreSQLBroker
onClose() - Method in class com.saicone.delivery4j.broker.RabbitMQBroker
onClose() - Method in class com.saicone.delivery4j.broker.SqlBroker
onClose() - Method in class com.saicone.delivery4j.broker.ValkeyBroker
onMessage(byte[], byte[]) - Method in class com.saicone.delivery4j.broker.JedisBroker.Listener
onMessage(byte[], byte[]) - Method in class com.saicone.delivery4j.broker.ValkeyBroker.Listener
onMessage(Message) - Method in class com.saicone.delivery4j.broker.ActiveMQBroker.Bridge
onStart() - Method in class com.saicone.delivery4j.broker.ActiveMQBroker
onStart() - Method in class com.saicone.delivery4j.broker.JedisBroker
onStart() - Method in class com.saicone.delivery4j.broker.KafkaBroker
onStart() - Method in class com.saicone.delivery4j.broker.LettuceBroker
onStart() - Method in class com.saicone.delivery4j.broker.NatsBroker
onStart() - Method in class com.saicone.delivery4j.Broker: Method to run when broker starts
onStart() - Method in class com.saicone.delivery4j.broker.PostgreSQLBroker
onStart() - Method in class com.saicone.delivery4j.broker.RabbitMQBroker
onStart() - Method in class com.saicone.delivery4j.broker.SqlBroker
onStart() - Method in class com.saicone.delivery4j.broker.ValkeyBroker
onSubscribe(byte[], int) - Method in class com.saicone.delivery4j.broker.JedisBroker.Listener
onSubscribe(byte[], int) - Method in class com.saicone.delivery4j.broker.ValkeyBroker.Listener
onSubscribe(String...) - Method in class com.saicone.delivery4j.broker.ActiveMQBroker
onSubscribe(String...) - Method in class com.saicone.delivery4j.broker.JedisBroker
onSubscribe(String...) - Method in class com.saicone.delivery4j.broker.KafkaBroker
onSubscribe(String...) - Method in class com.saicone.delivery4j.broker.LettuceBroker
onSubscribe(String...) - Method in class com.saicone.delivery4j.broker.NatsBroker
onSubscribe(String...) - Method in class com.saicone.delivery4j.Broker: Method to run when broker is being subscribed to new channels.
onSubscribe(String...) - Method in class com.saicone.delivery4j.broker.PostgreSQLBroker
onSubscribe(String...) - Method in class com.saicone.delivery4j.broker.RabbitMQBroker
onSubscribe(String...) - Method in class com.saicone.delivery4j.broker.ValkeyBroker
onUnsubscribe(byte[], int) - Method in class com.saicone.delivery4j.broker.JedisBroker.Listener
onUnsubscribe(byte[], int) - Method in class com.saicone.delivery4j.broker.ValkeyBroker.Listener
onUnsubscribe(String...) - Method in class com.saicone.delivery4j.broker.ActiveMQBroker
onUnsubscribe(String...) - Method in class com.saicone.delivery4j.broker.JedisBroker
onUnsubscribe(String...) - Method in class com.saicone.delivery4j.broker.KafkaBroker
onUnsubscribe(String...) - Method in class com.saicone.delivery4j.broker.LettuceBroker
onUnsubscribe(String...) - Method in class com.saicone.delivery4j.broker.NatsBroker
onUnsubscribe(String...) - Method in class com.saicone.delivery4j.Broker: Method to run when broker is being unsubscribed from channels.
onUnsubscribe(String...) - Method in class com.saicone.delivery4j.broker.PostgreSQLBroker
onUnsubscribe(String...) - Method in class com.saicone.delivery4j.broker.RabbitMQBroker
onUnsubscribe(String...) - Method in class com.saicone.delivery4j.broker.ValkeyBroker

P

PlainTextBroker - Class in com.saicone.delivery4j: Represents a Broker implementation that send and receive plain-text data using a specified byte codec to convert byte arrays into/from String.
PlainTextBroker() - Constructor for class com.saicone.delivery4j.PlainTextBroker
PostgreSQLBroker - Class in com.saicone.delivery4j.broker: PostgreSQL broker implementation to send data using LISTEN and NOTIFY statements.

Is this scalable?
No
Allows large messages?
No
Should I use it?
Maybe
PostgreSQLBroker(ConnectionSupplier) - Constructor for class com.saicone.delivery4j.broker.PostgreSQLBroker: Constructs a postgres broker using the provided connection supplier instance.
PostgreSQLBroker(Connection) - Constructor for class com.saicone.delivery4j.broker.PostgreSQLBroker: Constructs a postgres broker using the provided connection instance.
This constructor assumes that the given connection should not be closed after return it.
PostgreSQLHikariBroker - Class in com.saicone.delivery4j.broker: PostgreSQL broker implementation that use hikari library to make connections to database.
The operations are the same as PostgreSQL broker, it just made any connection with hikari library.
PostgreSQLHikariBroker(HikariDataSource) - Constructor for class com.saicone.delivery4j.broker.PostgreSQLHikariBroker: Constructs a postgres hikari broker using the provided data source instance.
psubscribed(String, long) - Method in class com.saicone.delivery4j.broker.LettuceBroker.Listener
punsubscribed(String, long) - Method in class com.saicone.delivery4j.broker.LettuceBroker.Listener

R

RabbitMQBroker - Class in com.saicone.delivery4j.broker: RabbitMQ broker implementation to send data using queue and consumer via exchange.
RabbitMQBroker(Connection, String) - Constructor for class com.saicone.delivery4j.broker.RabbitMQBroker: Constructs a rabbitmq broker with provided parameters.
read(DataInput) - Method in class com.saicone.delivery4j.util.DataIdentifier.Bit32
read(DataInput) - Method in class com.saicone.delivery4j.util.DataIdentifier.Bit64
read(DataInput) - Method in interface com.saicone.delivery4j.util.DataIdentifier: Read an id from the input and check if it doesn't belong to a generated identifier, if it does, the id is invalid and should be ignored.
readUTF(DataInput) - Method in interface com.saicone.delivery4j.util.Encryptor: Reads and decrypts a String from the provided DataInput.
readUTF(DataInput, Charset) - Method in interface com.saicone.delivery4j.util.Encryptor: Reads and decrypts a String from the provided DataInput.
receive(String, byte[]) - Method in class com.saicone.delivery4j.Broker: Receive byte array from provided channel.
receive(String, String) - Method in class com.saicone.delivery4j.PlainTextBroker: Receive plain-text data from specified channel.

S

send(byte[]) - Method in class com.saicone.delivery4j.broker.ActiveMQBroker.Bridge: Send data to producer.
send(String, byte[]) - Method in class com.saicone.delivery4j.broker.ActiveMQBroker
send(String, byte[]) - Method in class com.saicone.delivery4j.broker.JedisBroker
send(String, byte[]) - Method in class com.saicone.delivery4j.broker.KafkaBroker
send(String, byte[]) - Method in class com.saicone.delivery4j.broker.LettuceBroker
send(String, byte[]) - Method in class com.saicone.delivery4j.broker.NatsBroker
send(String, byte[]) - Method in class com.saicone.delivery4j.broker.RabbitMQBroker
send(String, byte[]) - Method in class com.saicone.delivery4j.Broker: Send byte data array to provided channel.
send(String, byte[]) - Method in class com.saicone.delivery4j.broker.ValkeyBroker
send(String, byte[]) - Method in class com.saicone.delivery4j.PlainTextBroker
send(String, String) - Method in class com.saicone.delivery4j.broker.PostgreSQLBroker
send(String, String) - Method in class com.saicone.delivery4j.broker.SqlBroker
send(String, String) - Method in class com.saicone.delivery4j.PlainTextBroker: Send plain-text data to specified channel.
send(String, Object...) - Method in class com.saicone.delivery4j.AbstractMessenger: Send multi-line message to provided channel name.
Take in count this method accept any Object as message lines, but everything will be converted to String.
If any object is null or "null" it will be sent as null object, and any consumer will get a null object as well.
send(ProducerRecord) - Method in class com.saicone.delivery4j.broker.KafkaBroker: Send a producer record into current producer.
setBroker(Broker) - Method in class com.saicone.delivery4j.AbstractMessenger: Set a broker to transfer data.
setCodec(ByteCodec) - Method in class com.saicone.delivery4j.PlainTextBroker: Replace the current byte codec.
setConsumer(ChannelConsumer) - Method in class com.saicone.delivery4j.Broker: Replace the current channel consumer.
setEnabled(boolean) - Method in class com.saicone.delivery4j.Broker: Set broker status.
setExecutor(TaskExecutor) - Method in class com.saicone.delivery4j.Broker: Replace the current delayed executor.
setExecutor(Executor) - Method in class com.saicone.delivery4j.AbstractMessenger: Replace the current executor with a custom implementation.
setHeaders(Iterable) - Method in class com.saicone.delivery4j.broker.KafkaBroker: Set the default headers used on every producer record created by this instance.
setKey(K) - Method in class com.saicone.delivery4j.broker.KafkaBroker: Set the default key used on every producer record created by this instance.
setLogger(LogFilter) - Method in class com.saicone.delivery4j.Broker: Replace the current logger.
setPartition(Integer) - Method in class com.saicone.delivery4j.broker.KafkaBroker: Set the default partition used on every producer record created by this instance.
setPollInterval(int, TimeUnit) - Method in class com.saicone.delivery4j.broker.SqlBroker: Set the poll that will be used to check for new messages from database, this is the maximum communication delay between applications.
Setting a different poll interval between applications may cause synchronization errors due it's value is multiplied by 3 to delete old messages from database in that interval.
By default, 10 seconds is used.
setReconnectionInterval(int, TimeUnit) - Method in class com.saicone.delivery4j.broker.JedisBroker: Set the reconnection interval that will be used on this redis broker instance.
By default, 8 seconds is used.
setReconnectionInterval(int, TimeUnit) - Method in class com.saicone.delivery4j.broker.KafkaBroker: Set the reconnection interval that will be used on this kafka broker instance.
By default, 8 seconds is used.
setReconnectionInterval(int, TimeUnit) - Method in class com.saicone.delivery4j.broker.LettuceBroker: Set the reconnection interval that will be used on this redis broker instance.
By default, 8 seconds is used.
setReconnectionInterval(int, TimeUnit) - Method in class com.saicone.delivery4j.broker.PostgreSQLBroker: Set the reconnection interval that will be used on this postgres broker instance.
By default, 8 seconds is used.
setReconnectionInterval(int, TimeUnit) - Method in class com.saicone.delivery4j.broker.RabbitMQBroker: Set the reconnection interval that will be used on this redis broker instance.
setReconnectionInterval(int, TimeUnit) - Method in class com.saicone.delivery4j.broker.ValkeyBroker: Set the reconnection interval that will be used on this valkey broker instance.
By default, 8 seconds is used.
setTablePrefix(String) - Method in class com.saicone.delivery4j.broker.SqlBroker: Set the table prefix that will be used before messenger table name.
setTimeout(long, TimeUnit) - Method in class com.saicone.delivery4j.broker.KafkaBroker: Set the record poll timeout, this is the maximum communication delay between applications.
By default, 5 seconds is used.
setTimeout(long, TimeUnit) - Method in class com.saicone.delivery4j.broker.PostgreSQLBroker: Set timeout that will be used to listen for new notifications from database, this is the maximum communication delay between applications.
By default, 5 seconds is used.
simple(String) - Static method in class com.saicone.delivery4j.broker.JedisBroker: Create a redis broker with provided URL string.
The URL must be in redis[s]://[[user][:password]@]host[:port][/database] format.
simple(String) - Static method in class com.saicone.delivery4j.broker.LettuceBroker: Create a redis broker with provided URL string.
The URL must be in redis[s]://[[user][:password]@]host[:port][/database] format.
simple(String) - Static method in class com.saicone.delivery4j.broker.ValkeyBroker: Create a valkey broker with provided url.
simple(String, String, Integer, boolean) - Static method in class com.saicone.delivery4j.broker.JedisBroker: Create a redis broker with provided parameters.
simple(String, String, Integer, boolean) - Static method in class com.saicone.delivery4j.broker.LettuceBroker: Create a redis broker with provided parameters.
simple(String, String, Integer, boolean) - Static method in class com.saicone.delivery4j.broker.ValkeyBroker: Create a valkey broker with provided parameters.
simple(URI) - Static method in class com.saicone.delivery4j.broker.JedisBroker: Create a redis broker with provided URI.
The URI must be in redis[s]://[[user][:password]@]host[:port][/database] format.
simple(URI) - Static method in class com.saicone.delivery4j.broker.LettuceBroker: Create a redis broker with provided URI.
The URI must be in redis[s]://[[user][:password]@]host[:port][/database] format.
simple(URI) - Static method in class com.saicone.delivery4j.broker.ValkeyBroker: Create a valkey broker with provided uri.
Slf4j(Logger, Supplier) - Constructor for class com.saicone.delivery4j.util.LogFilter.Slf4j: Constructor of SLF4J LogFilter.
SqlBroker - Class in com.saicone.delivery4j.broker: Sql broker implementation to send data via polling.
Take in count that this is not a real broker, can be used as one but the client is doing all the job via insertion and repeatable deletion.
SqlBroker(ConnectionSupplier) - Constructor for class com.saicone.delivery4j.broker.SqlBroker: Constructs a sql broker using the provided connection supplier instance.
SqlBroker(Connection) - Constructor for class com.saicone.delivery4j.broker.SqlBroker: Constructs a sql broker using the provided connection instance.
This constructor assumes that the given connection should not be closed after return it.
start() - Method in class com.saicone.delivery4j.AbstractMessenger: Start the messenger instance connection.
start() - Method in class com.saicone.delivery4j.broker.JedisBroker.Listener: Start the subscription to channels.
start() - Method in class com.saicone.delivery4j.broker.LettuceBroker.Listener: Start the subscription to channels.
start() - Method in class com.saicone.delivery4j.Broker: Start the broker connection.
start() - Method in class com.saicone.delivery4j.broker.ValkeyBroker.Listener: Start the subscription to channels.
start(Broker) - Method in class com.saicone.delivery4j.AbstractMessenger: Start the messenger instance connection with a provided broker.
subscribe() - Method in class com.saicone.delivery4j.broker.JedisBroker.Listener: Subscribe to channels and lock the thread until an error occurs or the subscription is closed.
subscribe() - Method in class com.saicone.delivery4j.broker.LettuceBroker.Listener: Subscribe to channels and lock the thread until an error occurs or the subscription is closed.
subscribe() - Method in class com.saicone.delivery4j.broker.ValkeyBroker.Listener: Subscribe to channels and lock the thread until an error occurs or the subscription is closed.
subscribe(MessageChannel) - Method in class com.saicone.delivery4j.AbstractMessenger: Subscribe to provided message channel.
his method will make an automatic subscription into broker if it exists and is not subscribed to provided channel.
subscribe(String) - Method in class com.saicone.delivery4j.AbstractMessenger: Find or create a message channel subscription.
This method will make an automatic subscription into broker if it exists and is not subscribed to provided channel name.
subscribe(String...) - Method in class com.saicone.delivery4j.Broker: Subscribe broker into provided channels names.
Any repeated channel will be ignored.
subscribed(String, long) - Method in class com.saicone.delivery4j.broker.LettuceBroker.Listener

T

TaskExecutor<T> - Interface in com.saicone.delivery4j.util: An object that executes submitted Runnable tasks and return itself as cancellable objects.
Unlike Executor, this kind of object allows to execute delayed and repeatable tasks.

U

unsubscribe(String...) - Method in class com.saicone.delivery4j.Broker: Unsubscribe broker from provided channels names.
Any repeated channel will be ignored.
unsubscribe0() - Method in class com.saicone.delivery4j.broker.JedisBroker.Listener: Unsubscribe from channels and unlock the thread.
unsubscribe0() - Method in class com.saicone.delivery4j.broker.LettuceBroker.Listener: Unsubscribe from channels and unlock the thread.
unsubscribe0() - Method in class com.saicone.delivery4j.broker.ValkeyBroker.Listener: Unsubscribe from channels and unlock the thread.
unsubscribed(String, long) - Method in class com.saicone.delivery4j.broker.LettuceBroker.Listener

V

ValkeyBroker - Class in com.saicone.delivery4j.broker: Valkey broker implementation to send data via publish and subscriptions.
This kind of broker will encode any byte array as String and viceversa.
Some operations made in this instance can fail due authentication errors, so it requires the password as well.
ValkeyBroker(UnifiedJedis) - Constructor for class com.saicone.delivery4j.broker.ValkeyBroker: Constructs a valkey broker with provided jedis.
ValkeyBroker(UnifiedJedis, Function) - Constructor for class com.saicone.delivery4j.broker.ValkeyBroker: Constructs a valkey broker with provided jedis and bridge.
ValkeyBroker.Listener - Class in com.saicone.delivery4j.broker: Bridge class to detect received messages from Valkey database.
valueOf(Class, int) - Static method in interface com.saicone.delivery4j.util.LogFilter: Create a LogFilter instance for the given class, using the best available logging implementation found on classpath.
valueOf(Class, Supplier) - Static method in interface com.saicone.delivery4j.util.LogFilter: Create a LogFilter instance for the given class, using the best available logging implementation found on classpath.
valueOf(Object, int) - Static method in interface com.saicone.delivery4j.util.LogFilter: Create a LogFilter instance for the given object, using the best available logging implementation found on classpath.
The object can be of type Class, String or a Logger instance itself.
valueOf(Object, Supplier) - Static method in interface com.saicone.delivery4j.util.LogFilter: Create a LogFilter instance for the given object, using the best available logging implementation found on classpath.
The object can be of type Class, String or a Logger instance itself.
valueOf(String, int) - Static method in interface com.saicone.delivery4j.util.LogFilter: Create a LogFilter instance for the given name, using the best available logging implementation found on classpath.
valueOf(String, String, String) - Static method in interface com.saicone.delivery4j.util.ConnectionSupplier: Create a connection supplier using the provided connection parameters.
valueOf(String, Supplier) - Static method in interface com.saicone.delivery4j.util.LogFilter: Create a LogFilter instance for the given name, using the best available logging implementation found on classpath.
valueOf(Connection) - Static method in interface com.saicone.delivery4j.util.ConnectionSupplier: Get a wrapped connection supplier instance with the provided connection.
This method assumes that the given connection should not be closed after return it.

W

WARNING - Static variable in interface com.saicone.delivery4j.util.LogFilter: Warning logging level.
Similar importance as error, but the information that offer this level mean that even though the running code encountered an error, it can continue.
write(DataOutput) - Method in class com.saicone.delivery4j.util.DataIdentifier.Bit32
write(DataOutput) - Method in class com.saicone.delivery4j.util.DataIdentifier.Bit64
write(DataOutput) - Method in interface com.saicone.delivery4j.util.DataIdentifier: Write a new unique id to the output.
writeUTF(DataOutput, String) - Method in interface com.saicone.delivery4j.util.Encryptor: Encrypts and writes the input String into the provided DataOutput.
writeUTF(DataOutput, String, Charset) - Method in interface com.saicone.delivery4j.util.Encryptor: Encrypts and writes the input String into the provided DataOutput.

Z

Z85 - Class in com.saicone.delivery4j.util: A Java implementation of the Z85 encoding scheme, based on the Z85 specification used by ZeroMQ, which is derivative of Ascii85 (and part of the Base85 family) encoding mechanism, but focused on source code usability.
This implementation contains the following types of encoding and decoding: Default
Z85 - Static variable in interface com.saicone.delivery4j.util.ByteCodec: Z85 byte codec that convert bytes into/from Z85 String.
Z85.Decoder - Class in com.saicone.delivery4j.util: This class provides methods to decode Z85 encoded Strings into byte arrays.
Z85.Encoder - Class in com.saicone.delivery4j.util: This class provides methods to encode byte arrays into Z85 encoded Strings.

A B C D E F G H I J K L M N O P R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values