Index

B C D F G H I L M O P Q S V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

B

batchThreshold(int) - Method in class io.github.elimelt.pmqueue.QueueConfig.Builder

Sets the batch threshold for the message queue.

BLOCK_HEADER_SIZE - Static variable in class io.github.elimelt.pmqueue.core.PersistentMessageQueue

The size of the block header in bytes.

build() - Method in class io.github.elimelt.pmqueue.QueueConfig.Builder

Builds the QueueConfig.

build() - Method in class io.github.elimelt.pmqueue.QueueFactory.CustomQueueBuilder

Builds the MessageQueue instance.

Builder() - Constructor for class io.github.elimelt.pmqueue.QueueConfig.Builder

Creates a new Builder.

C

checksumEnabled(boolean) - Method in class io.github.elimelt.pmqueue.QueueConfig.Builder

Enables or disables checksums.

close() - Method in class io.github.elimelt.pmqueue.consumer.DefaultMessageConsumer

close() - Method in class io.github.elimelt.pmqueue.core.PersistentMessageQueue

Closes the queue, ensuring all pending writes are flushed to disk.

close() - Method in class io.github.elimelt.pmqueue.producer.DefaultMessageProducer

createDebugQueue(String) - Static method in class io.github.elimelt.pmqueue.QueueFactory

Creates a queue with debug logging enabled.

createDurableQueue(String) - Static method in class io.github.elimelt.pmqueue.QueueFactory

Creates a queue optimized for durability and reliability.

createHighThroughputQueue(String) - Static method in class io.github.elimelt.pmqueue.QueueFactory

Creates a queue optimized for high throughput scenarios.

createLargeMessageQueue(String) - Static method in class io.github.elimelt.pmqueue.QueueFactory

Creates a queue optimized for storing large messages.

createLowMemoryQueue(String) - Static method in class io.github.elimelt.pmqueue.QueueFactory

Creates a queue optimized for low memory environments.

createQueue(String) - Static method in class io.github.elimelt.pmqueue.QueueFactory

Default queue configuration suitable for general use.

createQueue(String) - Method in enum io.github.elimelt.pmqueue.QueueFactory.QueuePreset

Creates a new MessageQueue instance with the specified configuration.

CustomQueueBuilder() - Constructor for class io.github.elimelt.pmqueue.QueueFactory.CustomQueueBuilder

Creates a new CustomQueueBuilder.

D

debugEnabled(boolean) - Method in class io.github.elimelt.pmqueue.QueueConfig.Builder

Enables or disables debug mode.

defaultBufferSize(int) - Method in class io.github.elimelt.pmqueue.QueueConfig.Builder

Sets the default buffer size for the message queue.

DefaultMessageConsumer - Class in io.github.elimelt.pmqueue.consumer

Default implementation of MessageConsumer.

DefaultMessageConsumer(MessageQueue, Consumer<Message>, int, long) - Constructor for class io.github.elimelt.pmqueue.consumer.DefaultMessageConsumer

Creates a new DefaultMessageConsumer.

DefaultMessageProducer - Class in io.github.elimelt.pmqueue.producer

Default implementation of MessageProducer.

DefaultMessageProducer(MessageQueue) - Constructor for class io.github.elimelt.pmqueue.producer.DefaultMessageProducer

Creates a new DefaultMessageProducer.

deserialize(byte[]) - Static method in class io.github.elimelt.pmqueue.message.MessageSerializer

Deserializes a byte array into a Message object.

DURABLE - Enum constant in enum io.github.elimelt.pmqueue.QueueFactory.QueuePreset

Configures the queue with durability settings.

F

filePath(String) - Method in class io.github.elimelt.pmqueue.QueueConfig.Builder

Sets the file path for the message queue.

flushBatch() - Method in class io.github.elimelt.pmqueue.core.PersistentMessageQueue

Flushes the current write batch to disk.

G

getBatchThreshold() - Method in class io.github.elimelt.pmqueue.QueueConfig

Returns the batch threshold for the message queue.

getConsumerThread() - Method in class io.github.elimelt.pmqueue.consumer.DefaultMessageConsumer

Returns the consumer thread.

getData() - Method in class io.github.elimelt.pmqueue.message.Message

Returns a copy of the message data.

getDefaultBufferSize() - Method in class io.github.elimelt.pmqueue.QueueConfig

Returns the default buffer size for the message queue.

getFilePath() - Method in class io.github.elimelt.pmqueue.QueueConfig

Returns the file path for the message queue.

getInitialFileSize() - Method in class io.github.elimelt.pmqueue.QueueConfig

Returns the initial file size for the message queue.

getMaxBufferSize() - Method in class io.github.elimelt.pmqueue.QueueConfig

Returns the maximum buffer size for the message queue.

getMaxFileSize() - Method in class io.github.elimelt.pmqueue.QueueConfig

Returns the maximum file size for the message queue.

getMessageType() - Method in class io.github.elimelt.pmqueue.message.Message

Returns the message type identifier.

getRunning() - Method in class io.github.elimelt.pmqueue.consumer.DefaultMessageConsumer

Returns true if the consumer is running.

getTimestamp() - Method in class io.github.elimelt.pmqueue.message.Message

Returns the timestamp when this message was created.

H

hashCode() - Method in class io.github.elimelt.pmqueue.message.Message

Computes and caches the hash code for this message using the FNV-1a algorithm.

HIGH_THROUGHPUT - Enum constant in enum io.github.elimelt.pmqueue.QueueFactory.QueuePreset

Configures the queue with high throughput settings.

I

initialFileSize(int) - Method in class io.github.elimelt.pmqueue.QueueConfig.Builder

Sets the initial file size for the message queue.

io.github.elimelt.pmqueue - package io.github.elimelt.pmqueue

io.github.elimelt.pmqueue.consumer - package io.github.elimelt.pmqueue.consumer

io.github.elimelt.pmqueue.core - package io.github.elimelt.pmqueue.core

io.github.elimelt.pmqueue.message - package io.github.elimelt.pmqueue.message

io.github.elimelt.pmqueue.producer - package io.github.elimelt.pmqueue.producer

isChecksumEnabled() - Method in class io.github.elimelt.pmqueue.QueueConfig

Returns whether checksums are enabled.

isDebugEnabled() - Method in class io.github.elimelt.pmqueue.QueueConfig

Returns whether debug mode is enabled.

isEmpty() - Method in class io.github.elimelt.pmqueue.core.PersistentMessageQueue

Checks if the queue is empty.

isEmpty() - Method in interface io.github.elimelt.pmqueue.MessageQueue

Checks if the queue is empty.

L

LOW_MEMORY - Enum constant in enum io.github.elimelt.pmqueue.QueueFactory.QueuePreset

Configures the queue with large message settings.

M

maxBufferSize(int) - Method in class io.github.elimelt.pmqueue.QueueConfig.Builder

Sets the maximum buffer size for the message queue.

maxFileSize(long) - Method in class io.github.elimelt.pmqueue.QueueConfig.Builder

Sets the maximum file size for the message queue.

Message - Class in io.github.elimelt.pmqueue.message

A high-performance, immutable message container optimized for memory efficiency and fast access.

Message(byte[], int) - Constructor for class io.github.elimelt.pmqueue.message.Message

Creates a new Message with the specified data and message type.

MessageConsumer - Interface in io.github.elimelt.pmqueue.consumer

Interface for consuming messages.

MessageProducer - Interface in io.github.elimelt.pmqueue.producer

Interface for sending messages.

MessageQueue - Interface in io.github.elimelt.pmqueue

Interface for message queues.

MessageSerializer - Class in io.github.elimelt.pmqueue.message

A high-performance serializer for Message objects using direct memory operations.

O

offer(Message) - Method in class io.github.elimelt.pmqueue.core.PersistentMessageQueue

Offers a message to the queue.

offer(Message) - Method in interface io.github.elimelt.pmqueue.MessageQueue

Stores a message in the queue.

P

PAGE_SIZE - Static variable in class io.github.elimelt.pmqueue.core.PersistentMessageQueue

The size of a page in bytes.

PersistentMessageQueue - Class in io.github.elimelt.pmqueue.core

A high-performance, persistent queue implementation for storing messages on disk.

PersistentMessageQueue(QueueConfig) - Constructor for class io.github.elimelt.pmqueue.core.PersistentMessageQueue

Creates a new persistent message queue with custom configuration.

PersistentMessageQueue(String) - Constructor for class io.github.elimelt.pmqueue.core.PersistentMessageQueue

Creates a new persistent message queue with default configuration.

poll() - Method in class io.github.elimelt.pmqueue.core.PersistentMessageQueue

Retrieves and removes the head of the queue, or returns null if the queue is empty.

poll() - Method in interface io.github.elimelt.pmqueue.MessageQueue

Retrieves a message from the queue.

Q

QUEUE_HEADER_SIZE - Static variable in class io.github.elimelt.pmqueue.core.PersistentMessageQueue

The size of the queue header in bytes.

QueueConfig - Class in io.github.elimelt.pmqueue

Configuration for a message queue.

QueueConfig.Builder - Class in io.github.elimelt.pmqueue

Builder for QueueConfig.

QueueFactory - Class in io.github.elimelt.pmqueue

Factory for creating MessageQueue instances with various configurations.

QueueFactory.CustomQueueBuilder - Class in io.github.elimelt.pmqueue

Creates a queue with a custom configuration.

QueueFactory.QueuePreset - Enum in io.github.elimelt.pmqueue

Predefined queue configurations

S

send(byte[], int) - Method in class io.github.elimelt.pmqueue.producer.DefaultMessageProducer

send(byte[], int) - Method in interface io.github.elimelt.pmqueue.producer.MessageProducer

Sends a message to a message queue.

serialize(Message) - Static method in class io.github.elimelt.pmqueue.message.MessageSerializer

Serializes a Message object into a byte array.

start() - Method in class io.github.elimelt.pmqueue.consumer.DefaultMessageConsumer

start() - Method in interface io.github.elimelt.pmqueue.consumer.MessageConsumer

Starts consuming messages.

stop() - Method in class io.github.elimelt.pmqueue.consumer.DefaultMessageConsumer

stop() - Method in interface io.github.elimelt.pmqueue.consumer.MessageConsumer

Stops consuming messages.

V

valueOf(String) - Static method in enum io.github.elimelt.pmqueue.QueueFactory.QueuePreset

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.github.elimelt.pmqueue.QueueFactory.QueuePreset

Returns an array containing the constants of this enum type, in the order they are declared.

W

withBatchThreshold(int) - Method in class io.github.elimelt.pmqueue.QueueFactory.CustomQueueBuilder

Sets the batch threshold for the queue.

withChecksumEnabled(boolean) - Method in class io.github.elimelt.pmqueue.QueueFactory.CustomQueueBuilder

Enables or disables checksums.

withDebugEnabled(boolean) - Method in class io.github.elimelt.pmqueue.QueueFactory.CustomQueueBuilder

Enables or disables debug mode.

withDefaultBufferSize(int) - Method in class io.github.elimelt.pmqueue.QueueFactory.CustomQueueBuilder

Sets the initial file size for the queue.

withFilePath(String) - Method in class io.github.elimelt.pmqueue.QueueFactory.CustomQueueBuilder

Sets the file path for the queue.

withMaxBufferSize(int) - Method in class io.github.elimelt.pmqueue.QueueFactory.CustomQueueBuilder

Sets the maximum buffer size for the queue.

withMaxFileSize(long) - Method in class io.github.elimelt.pmqueue.QueueFactory.CustomQueueBuilder

Sets the maximum file size for the queue.

B C D F G H I L M O P Q S V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form