Index (bppmq 1.0.0-SNAPSHOT API)

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

A

andMatches(String[], List<String>, boolean) - Method in class net.blakez.bppmq.infra.data.couchdb.SearchToolCouchDB

B

batchSize() - Method in record class net.blakez.bppmq.rest.model.PullBatchResponse: Returns the value of the batchSize record component.
BIG_DECIMAL_FORMAT_ERROR - Static variable in class net.blakez.bppmq.core.CoreError: Error type indicating an invalid format when parsing or handling BigDecimal values.
build() - Method in class net.blakez.bppmq.infra.data.couchdb.CouchDBBuilder
build(Properties) - Method in class net.blakez.bppmq.infra.data.couchdb.CouchDBBuilder

C

clearBefore(String, long) - Method in class net.blakez.bppmq.core.queue.PushPullQueueCore: Clears messages in the specified topic before the given index.
clearBefore(String, long) - Method in class net.blakez.bppmq.rest.Queue: Clears messages before a specific index.
configImport(Properties) - Static method in class net.blakez.bppmq.infra.data.couchdb.CouchDBBuilder
configMap(Config) - Static method in class net.blakez.bppmq.infra.data.InfraConfigTool
configProd(Properties) - Static method in class net.blakez.bppmq.infra.data.couchdb.CouchDBBuilder
CoreError - Class in net.blakez.bppmq.core
CoreError() - Constructor for class net.blakez.bppmq.core.CoreError
CouchDBBuilder - Class in net.blakez.bppmq.infra.data.couchdb
CouchDBBuilder() - Constructor for class net.blakez.bppmq.infra.data.couchdb.CouchDBBuilder
CouchMessageRecordRepository - Class in net.blakez.bppmq.infra.data.queue: CouchDB implementation of MessageRecordRepository.
CouchMessageRecordRepository(AttainCouchDB2) - Constructor for class net.blakez.bppmq.infra.data.queue.CouchMessageRecordRepository
count() - Method in record class net.blakez.bppmq.core.queue.MetaRecord: Returns the value of the count record component.
count() - Method in record class net.blakez.bppmq.rest.model.CountFromResponse: Returns the value of the count record component.
count() - Method in record class net.blakez.bppmq.rest.model.MetaResponse: Returns the value of the count record component.
count() - Method in record class net.blakez.bppmq.rest.model.PushBatchResponse: Returns the value of the count record component.
COUNT - Static variable in class net.blakez.bppmq.infra.data.queue.DBMessageConst
countFrom(String, long) - Method in class net.blakez.bppmq.core.queue.PushPullQueueCore: Counts the number of messages available from a specific index onwards.
countFrom(String, long) - Method in class net.blakez.bppmq.rest.Queue: Gets the count of messages from a specific index onwards.
CountFromResponse - Record Class in net.blakez.bppmq.rest.model
CountFromResponse(String, long, long) - Constructor for record class net.blakez.bppmq.rest.model.CountFromResponse: Creates an instance of a CountFromResponse record class.
createQueueCore() - Method in class net.blakez.bppmq.core.queue.QueueCoreProducer
createRepository() - Method in class net.blakez.bppmq.infra.RepositoryProducer

D

DBMessageConst - Class in net.blakez.bppmq.infra.data.queue: Database field constants for MessageRecord and MetaRecord entities.
DBMessageConst() - Constructor for class net.blakez.bppmq.infra.data.queue.DBMessageConst
delete(String, long) - Method in interface net.blakez.bppmq.core.queue.MessageRecordRepository: Deletes a message by topic and index.
delete(String, long) - Method in class net.blakez.bppmq.infra.data.queue.CouchMessageRecordRepository
deleteID(UUID) - Method in interface net.blakez.bppmq.core.queue.MessageRecordRepository: Deletes a message by its UUID.
deleteID(UUID) - Method in class net.blakez.bppmq.infra.data.queue.CouchMessageRecordRepository
deserialize(JsonParser, DeserializationContext) - Method in class net.blakez.bppmq.infra.data.queue.MessageRecordDeserializer
deserialize(JsonParser, DeserializationContext) - Method in class net.blakez.bppmq.infra.data.queue.MetaRecordDeserializer

E

equals(Object) - Method in record class net.blakez.bppmq.core.Error: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class net.blakez.bppmq.core.queue.MessageRecord: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class net.blakez.bppmq.core.queue.MetaRecord: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class net.blakez.bppmq.rest.model.CountFromResponse: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class net.blakez.bppmq.rest.model.MetaResponse: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class net.blakez.bppmq.rest.model.PullBatchResponse: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class net.blakez.bppmq.rest.model.PullResponse: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class net.blakez.bppmq.rest.model.PushBatchResponse: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class net.blakez.bppmq.rest.model.PushResponse: Indicates whether some other object is "equal to" this one.
Error - Record Class in net.blakez.bppmq.core: Represents an error with a type and message.
Error(String, String) - Constructor for record class net.blakez.bppmq.core.Error: Creates an instance of a Error record class.
errorMsg() - Method in record class net.blakez.bppmq.core.Error: Returns the value of the errorMsg record component.
errors() - Method in class net.blakez.bppmq.core.Result: Gets the list of errors associated with a failed operation.
errorType() - Method in record class net.blakez.bppmq.core.Error: Returns the value of the errorType record component.

F

fail(List<Error>) - Static method in class net.blakez.bppmq.core.Result: Creates a failed Result with a list of errors.
fail(Optional<T>, List<Error>) - Static method in class net.blakez.bppmq.core.Result: Creates a failed Result with a list of errors and potentially a partial value.
fail(Optional<T>, Error) - Static method in class net.blakez.bppmq.core.Result: Creates a failed Result with a single error and potentially a partial value.
fail(Error) - Static method in class net.blakez.bppmq.core.Result: Creates a failed Result with a single error.
from() - Method in record class net.blakez.bppmq.rest.model.CountFromResponse: Returns the value of the from record component.
fromConfig() - Static method in class net.blakez.bppmq.infra.data.couchdb.CouchDBBuilder

G

getConfigValue(String, String, Config) - Static method in class net.blakez.bppmq.infra.data.InfraConfigTool
getLowerCaseNotEmptyValues(String[], JsonObject) - Method in class net.blakez.bppmq.infra.data.couchdb.SearchToolCouchDB
getObjectMapper() - Static method in class net.blakez.bppmq.infra.data.couchdb.JsonConversionTool: Creates a Jackson ObjectMapper instance for JSON operations.
gsonToJackson(JsonObject) - Static method in class net.blakez.bppmq.infra.data.couchdb.JsonConversionTool: Converts a Gson JsonObject to Jackson JsonNode.

H

hashCode() - Method in record class net.blakez.bppmq.core.Error: Returns a hash code value for this object.
hashCode() - Method in record class net.blakez.bppmq.core.queue.MessageRecord: Returns a hash code value for this object.
hashCode() - Method in record class net.blakez.bppmq.core.queue.MetaRecord: Returns a hash code value for this object.
hashCode() - Method in record class net.blakez.bppmq.rest.model.CountFromResponse: Returns a hash code value for this object.
hashCode() - Method in record class net.blakez.bppmq.rest.model.MetaResponse: Returns a hash code value for this object.
hashCode() - Method in record class net.blakez.bppmq.rest.model.PullBatchResponse: Returns a hash code value for this object.
hashCode() - Method in record class net.blakez.bppmq.rest.model.PullResponse: Returns a hash code value for this object.
hashCode() - Method in record class net.blakez.bppmq.rest.model.PushBatchResponse: Returns a hash code value for this object.
hashCode() - Method in record class net.blakez.bppmq.rest.model.PushResponse: Returns a hash code value for this object.

I

index() - Method in record class net.blakez.bppmq.core.queue.MessageRecord: Returns the value of the index record component.
index() - Method in record class net.blakez.bppmq.rest.model.PullBatchResponse: Returns the value of the index record component.
index() - Method in record class net.blakez.bppmq.rest.model.PullResponse: Returns the value of the index record component.
index() - Method in record class net.blakez.bppmq.rest.model.PushResponse: Returns the value of the index record component.
INDEX - Static variable in class net.blakez.bppmq.infra.data.queue.DBMessageConst
InfraConfigTool - Class in net.blakez.bppmq.infra.data
InfraConfigTool() - Constructor for class net.blakez.bppmq.infra.data.InfraConfigTool
instance() - Static method in class net.blakez.bppmq.infra.data.couchdb.SearchToolCouchDB
INVALID_INPUT - Static variable in class net.blakez.bppmq.core.CoreError: Error type for invalid input parameters or data.
is(String) - Method in record class net.blakez.bppmq.core.Error: Checks if the error type matches the provided string.
isSuccess() - Method in class net.blakez.bppmq.core.Result: Checks if the operation was successful.

J

jacksonToGson(JsonNode) - Static method in class net.blakez.bppmq.infra.data.couchdb.JsonConversionTool: Converts a Jackson JsonNode to Gson JsonObject.
JsonConversionTool - Class in net.blakez.bppmq.infra.data.couchdb: Utility class to handle conversions between Gson and Jackson JSON types.
JsonConversionTool() - Constructor for class net.blakez.bppmq.infra.data.couchdb.JsonConversionTool

L

list(String, long, long) - Method in interface net.blakez.bppmq.core.queue.MessageRecordRepository: Lists messages for a topic starting from a specific index.
list(String, long, long) - Method in class net.blakez.bppmq.infra.data.queue.CouchMessageRecordRepository
lookupID(UUID) - Method in interface net.blakez.bppmq.core.queue.MessageRecordRepository: Reads a message by its UUID.
lookupID(UUID) - Method in class net.blakez.bppmq.infra.data.queue.CouchMessageRecordRepository

M

MessageRecord - Record Class in net.blakez.bppmq.core.queue: Represents a message within the messaging system.
MessageRecord(long, UUID, long, String, String) - Constructor for record class net.blakez.bppmq.core.queue.MessageRecord: Creates an instance of a MessageRecord record class.
MessageRecord(UUID, long, String, String) - Constructor for record class net.blakez.bppmq.core.queue.MessageRecord: Constructor that automatically sets the timestamp.
MessageRecordDeserializer - Class in net.blakez.bppmq.infra.data.queue: Jackson deserializer for MessageRecord entities from CouchDB JSON format.
MessageRecordDeserializer() - Constructor for class net.blakez.bppmq.infra.data.queue.MessageRecordDeserializer
MessageRecordDeserializer(Class<?>) - Constructor for class net.blakez.bppmq.infra.data.queue.MessageRecordDeserializer
MessageRecordRepository - Interface in net.blakez.bppmq.core.queue: Interface defining operations for managing MessageRecords.
MessageRecordSerializer - Class in net.blakez.bppmq.infra.data.queue: Jackson serializer for MessageRecord entities to CouchDB JSON format.
MessageRecordSerializer() - Constructor for class net.blakez.bppmq.infra.data.queue.MessageRecordSerializer
MessageRecordSerializer(Class<MessageRecord>) - Constructor for class net.blakez.bppmq.infra.data.queue.MessageRecordSerializer
MESSAGES - Static variable in class net.blakez.bppmq.infra.data.queue.DBMessageConst
meta(String) - Method in interface net.blakez.bppmq.core.queue.MessageRecordRepository: Retrieves metadata for a given topic.
meta(String) - Method in class net.blakez.bppmq.core.queue.PushPullQueueCore: Retrieves metadata information for the specified topic.
meta(String) - Method in class net.blakez.bppmq.infra.data.queue.CouchMessageRecordRepository
meta(String) - Method in class net.blakez.bppmq.rest.Queue: Gets metadata for a topic.
META - Static variable in class net.blakez.bppmq.infra.data.queue.DBMessageConst
MetaRecord - Record Class in net.blakez.bppmq.core.queue: Represents metadata about messages in a topic.
MetaRecord(String, long, long) - Constructor for record class net.blakez.bppmq.core.queue.MetaRecord: Constructor that automatically generates a metadata ID based on topic.
MetaRecord(String, String, long, long) - Constructor for record class net.blakez.bppmq.core.queue.MetaRecord: Creates an instance of a MetaRecord record class.
MetaRecordDeserializer - Class in net.blakez.bppmq.infra.data.queue: Jackson deserializer for MetaRecord entities from CouchDB JSON format.
MetaRecordDeserializer() - Constructor for class net.blakez.bppmq.infra.data.queue.MetaRecordDeserializer
MetaRecordDeserializer(Class<?>) - Constructor for class net.blakez.bppmq.infra.data.queue.MetaRecordDeserializer
MetaRecordSerializer - Class in net.blakez.bppmq.infra.data.queue: Jackson serializer for MetaRecord entities to CouchDB JSON format.
MetaRecordSerializer() - Constructor for class net.blakez.bppmq.infra.data.queue.MetaRecordSerializer
MetaRecordSerializer(Class<MetaRecord>) - Constructor for class net.blakez.bppmq.infra.data.queue.MetaRecordSerializer
MetaResponse - Record Class in net.blakez.bppmq.rest.model: Response model for metadata operations.
MetaResponse(String, long, long) - Constructor for record class net.blakez.bppmq.rest.model.MetaResponse: Creates an instance of a MetaResponse record class.
msg() - Method in record class net.blakez.bppmq.rest.model.PullResponse: Returns the value of the msg record component.
msgs() - Method in record class net.blakez.bppmq.rest.model.PullBatchResponse: Returns the value of the msgs record component.

N

net.blakez.bppmq.core - package net.blakez.bppmq.core
net.blakez.bppmq.core.queue - package net.blakez.bppmq.core.queue
net.blakez.bppmq.infra - package net.blakez.bppmq.infra
net.blakez.bppmq.infra.data - package net.blakez.bppmq.infra.data
net.blakez.bppmq.infra.data.couchdb - package net.blakez.bppmq.infra.data.couchdb
net.blakez.bppmq.infra.data.queue - package net.blakez.bppmq.infra.data.queue
net.blakez.bppmq.rest - package net.blakez.bppmq.rest
net.blakez.bppmq.rest.model - package net.blakez.bppmq.rest.model
NOT_FOUND - Static variable in class net.blakez.bppmq.core.CoreError: Error type when requested resource or data is not found.

P

primaryError() - Method in class net.blakez.bppmq.core.Result: Gets the primary error from the list of errors.
pull(String, long) - Method in class net.blakez.bppmq.core.queue.PushPullQueueCore: Pulls a single message from the specified topic at the given index.
pull(String, long) - Method in class net.blakez.bppmq.rest.Queue: Pulls a single message by topic and index.
pullBatch(String, long, long) - Method in class net.blakez.bppmq.core.queue.PushPullQueueCore: Pulls a batch of messages from the specified topic starting at the given index.
pullBatch(String, long, long) - Method in class net.blakez.bppmq.rest.Queue: Pulls a batch of messages starting from an index.
PullBatchResponse - Record Class in net.blakez.bppmq.rest.model
PullBatchResponse(String, long, long, List<String>) - Constructor for record class net.blakez.bppmq.rest.model.PullBatchResponse: Creates an instance of a PullBatchResponse record class.
pullFrom(String, long, long) - Method in class net.blakez.bppmq.core.queue.PushPullQueueCore: Pulls messages from the specified topic starting from the given index.
pullFrom(String, long, long) - Method in class net.blakez.bppmq.rest.Queue: Pulls messages from a specific index with batch size limit.
PullResponse - Record Class in net.blakez.bppmq.rest.model: Response model for single message pull operations.
PullResponse(String, long, String) - Constructor for record class net.blakez.bppmq.rest.model.PullResponse: Creates an instance of a PullResponse record class.
push(String, String) - Method in class net.blakez.bppmq.core.queue.PushPullQueueCore: Pushes a single message to the specified topic.
push(String, String) - Method in class net.blakez.bppmq.rest.Queue: Pushes a single message to a topic.
pushBatch(String, List<String>) - Method in class net.blakez.bppmq.core.queue.PushPullQueueCore: Pushes a batch of messages to the specified topic.
pushBatch(String, List<String>) - Method in class net.blakez.bppmq.rest.Queue: Pushes multiple messages to a topic.
PushBatchResponse - Record Class in net.blakez.bppmq.rest.model: Response model for push batch operations.
PushBatchResponse(String, int, int, long) - Constructor for record class net.blakez.bppmq.rest.model.PushBatchResponse: Creates an instance of a PushBatchResponse record class.
pushedCount() - Method in record class net.blakez.bppmq.rest.model.PushBatchResponse: Returns the value of the pushedCount record component.
PushPullQueueCore - Class in net.blakez.bppmq.core.queue: Core domain object for push-pull queue operations.
PushPullQueueCore(MessageRecordRepository) - Constructor for class net.blakez.bppmq.core.queue.PushPullQueueCore: Constructor for PushPullQueueCore.
PushResponse - Record Class in net.blakez.bppmq.rest.model: Response model for push operations.
PushResponse(String, long, UUID) - Constructor for record class net.blakez.bppmq.rest.model.PushResponse: Creates an instance of a PushResponse record class.

Q

Queue - Class in net.blakez.bppmq.rest: REST endpoints for Push Pull Queue operations.
Queue() - Constructor for class net.blakez.bppmq.rest.Queue
QueueCoreProducer - Class in net.blakez.bppmq.core.queue: CDI Producer for PushPullQueueCore.
QueueCoreProducer() - Constructor for class net.blakez.bppmq.core.queue.QueueCoreProducer

R

read(String, long) - Method in interface net.blakez.bppmq.core.queue.MessageRecordRepository: Reads a specific message by topic and index.
read(String, long) - Method in class net.blakez.bppmq.infra.data.queue.CouchMessageRecordRepository
REPOSITORY_ERROR - Static variable in class net.blakez.bppmq.core.CoreError: Error type for repository-level database or persistence errors.
RepositoryProducer - Class in net.blakez.bppmq.infra: CDI Producer for MessageRecordRepository implementations.
RepositoryProducer() - Constructor for class net.blakez.bppmq.infra.RepositoryProducer
requireConfigValue(String, Config) - Static method in class net.blakez.bppmq.infra.data.InfraConfigTool
Result<T> - Class in net.blakez.bppmq.core
Result(boolean, Optional<T>, List<Error>) - Constructor for class net.blakez.bppmq.core.Result: Protected constructor to create a Result instance.

S

saveMeta(MetaRecord) - Method in interface net.blakez.bppmq.core.queue.MessageRecordRepository: Saves or updates metadata for a topic.
saveMeta(MetaRecord) - Method in class net.blakez.bppmq.infra.data.queue.CouchMessageRecordRepository
SearchToolCouchDB - Class in net.blakez.bppmq.infra.data.couchdb
SearchToolCouchDB() - Constructor for class net.blakez.bppmq.infra.data.couchdb.SearchToolCouchDB
serialize(MessageRecord, JsonGenerator, SerializerProvider) - Method in class net.blakez.bppmq.infra.data.queue.MessageRecordSerializer
serialize(MetaRecord, JsonGenerator, SerializerProvider) - Method in class net.blakez.bppmq.infra.data.queue.MetaRecordSerializer
start() - Method in record class net.blakez.bppmq.core.queue.MetaRecord: Returns the value of the start record component.
start() - Method in record class net.blakez.bppmq.rest.model.MetaResponse: Returns the value of the start record component.
START - Static variable in class net.blakez.bppmq.infra.data.queue.DBMessageConst
success(Optional<T>) - Static method in class net.blakez.bppmq.core.Result: Creates a successful Result.
SYSTEM_ERROR - Static variable in class net.blakez.bppmq.core.CoreError: Error type for system-level errors.

T

topic() - Method in record class net.blakez.bppmq.core.queue.MessageRecord: Returns the value of the topic record component.
topic() - Method in record class net.blakez.bppmq.core.queue.MetaRecord: Returns the value of the topic record component.
topic() - Method in record class net.blakez.bppmq.rest.model.CountFromResponse: Returns the value of the topic record component.
topic() - Method in record class net.blakez.bppmq.rest.model.MetaResponse: Returns the value of the topic record component.
topic() - Method in record class net.blakez.bppmq.rest.model.PullBatchResponse: Returns the value of the topic record component.
topic() - Method in record class net.blakez.bppmq.rest.model.PullResponse: Returns the value of the topic record component.
topic() - Method in record class net.blakez.bppmq.rest.model.PushBatchResponse: Returns the value of the topic record component.
topic() - Method in record class net.blakez.bppmq.rest.model.PushResponse: Returns the value of the topic record component.
TOPIC - Static variable in class net.blakez.bppmq.infra.data.queue.DBMessageConst
topics() - Method in interface net.blakez.bppmq.core.queue.MessageRecordRepository: Retrieves a list of all available topic names.
topics() - Method in class net.blakez.bppmq.infra.data.queue.CouchMessageRecordRepository
toString() - Method in record class net.blakez.bppmq.core.Error: Returns a string representation of this record class.
toString() - Method in record class net.blakez.bppmq.core.queue.MessageRecord: Returns a string representation of this record class.
toString() - Method in record class net.blakez.bppmq.core.queue.MetaRecord: Returns a string representation of this record class.
toString() - Method in record class net.blakez.bppmq.rest.model.CountFromResponse: Returns a string representation of this record class.
toString() - Method in record class net.blakez.bppmq.rest.model.MetaResponse: Returns a string representation of this record class.
toString() - Method in record class net.blakez.bppmq.rest.model.PullBatchResponse: Returns a string representation of this record class.
toString() - Method in record class net.blakez.bppmq.rest.model.PullResponse: Returns a string representation of this record class.
toString() - Method in record class net.blakez.bppmq.rest.model.PushBatchResponse: Returns a string representation of this record class.
toString() - Method in record class net.blakez.bppmq.rest.model.PushResponse: Returns a string representation of this record class.
totalCount() - Method in record class net.blakez.bppmq.rest.model.PushBatchResponse: Returns the value of the totalCount record component.
ts() - Method in record class net.blakez.bppmq.core.queue.MessageRecord: Returns the value of the ts record component.
TS - Static variable in class net.blakez.bppmq.infra.data.queue.DBMessageConst
TYPE - Static variable in class net.blakez.bppmq.infra.data.queue.DBMessageConst

U

UNKNOWN_ERROR - Static variable in class net.blakez.bppmq.core.CoreError: Generic error type for unknown or unexpected errors.

V

value() - Method in record class net.blakez.bppmq.core.queue.MessageRecord: Returns the value of the value record component.
value() - Method in class net.blakez.bppmq.core.Result: Gets the value associated with the result.
VALUE - Static variable in class net.blakez.bppmq.infra.data.queue.DBMessageConst

W

write(MessageRecord) - Method in interface net.blakez.bppmq.core.queue.MessageRecordRepository: Writes a new message record.
write(MessageRecord) - Method in class net.blakez.bppmq.infra.data.queue.CouchMessageRecordRepository

_

_id() - Method in record class net.blakez.bppmq.core.queue.MessageRecord: Returns the value of the _id record component.
_id() - Method in record class net.blakez.bppmq.core.queue.MetaRecord: Returns the value of the _id record component.
_id() - Method in record class net.blakez.bppmq.rest.model.PushResponse: Returns the value of the _id record component.
_ID - Static variable in class net.blakez.bppmq.infra.data.queue.DBMessageConst

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