Index

A B C D E F G H I J M O P R S T W
All Classes and Interfaces|All Packages|Serialized Form

A

acknowledge() - Method in interface io.keldysh.messaging.Message

acknowledge() - Method in class io.keldysh.messaging.Message.Plain

acknowledge() - Method in class io.keldysh.messaging.MessageFlow

ActiveMQArtemisTestContainerExtension - Class in io.keldysh.messaging.artemis.artemis_test_support

ActiveMQArtemisTestContainerExtension() - Constructor for class io.keldysh.messaging.artemis.artemis_test_support.ActiveMQArtemisTestContainerExtension

addressModel() - Method in record class io.keldysh.messaging.configuration_support.AddressModelConfiguration

Returns the value of the addressModel record component.

AddressModelConfiguration - Record Class in io.keldysh.messaging.configuration_support

AddressModelConfiguration(Map<String, List<String>>) - Constructor for record class io.keldysh.messaging.configuration_support.AddressModelConfiguration

Creates an instance of a AddressModelConfiguration record class.

afterAll(ExtensionContext) - Method in class io.keldysh.messaging.artemis.artemis_test_support.ActiveMQArtemisTestContainerExtension

afterEach(ExtensionContext) - Method in class io.keldysh.messaging.artemis.artemis_test_support.ActiveMQArtemisTestContainerExtension

apply(MessageFlow<PAYLOAD>) - Method in interface io.keldysh.messaging.MessageSink

ArtemisClient - Class in io.keldysh.messaging.artemis

ArtemisClient(ArtemisConfigurationProperties) - Constructor for class io.keldysh.messaging.artemis.ArtemisClient

ArtemisClient(ServerLocator, ArtemisConfigurationProperties) - Constructor for class io.keldysh.messaging.artemis.ArtemisClient

ArtemisConfigurationProperties - Class in io.keldysh.messaging.artemis.configuration_support

ArtemisConfigurationProperties() - Constructor for class io.keldysh.messaging.artemis.configuration_support.ArtemisConfigurationProperties

artemisTestContainer - Variable in class io.keldysh.messaging.artemis.artemis_test_support.ActiveMQArtemisTestContainerExtension

ArtemisTestContainer<SELF extends ArtemisTestContainer<SELF>> - Class in io.keldysh.messaging.artemis.artemis_test_support

ArtemisTestContainer() - Constructor for class io.keldysh.messaging.artemis.artemis_test_support.ArtemisTestContainer

B

backoffRetry(long, long) - Static method in class io.keldysh.messaging.MessageFlow

batchFixed(int, Function<? super MessageFlow<T>, ? extends MessageFlow<U>>) - Method in class io.keldysh.messaging.MessageFlow

batchInterval(int, Function<? super MessageFlow<T>, ? extends MessageFlow<U>>) - Method in class io.keldysh.messaging.MessageFlow

batchSamplingInterval(int, Function<? super MessageFlow<T>, ? extends MessageFlow<U>>) - Method in class io.keldysh.messaging.MessageFlow

beforeAll(ExtensionContext) - Method in class io.keldysh.messaging.artemis.artemis_test_support.ActiveMQArtemisTestContainerExtension

beforeEach(ExtensionContext) - Method in class io.keldysh.messaging.artemis.artemis_test_support.ActiveMQArtemisTestContainerExtension

blockLast() - Method in class io.keldysh.messaging.MessageFlow

blockLastRetry() - Method in class io.keldysh.messaging.MessageFlow

blockLastRetry(Retry) - Method in class io.keldysh.messaging.MessageFlow

broker() - Method in record class io.keldysh.messaging.in_memory.InMemoryBrokerClient

Returns the value of the broker record component.

ByteBufParser<PAYLOAD> - Interface in io.keldysh.messaging.parsing

C

close() - Method in class io.keldysh.messaging.artemis.ArtemisClient

close() - Method in record class io.keldysh.messaging.in_memory.InMemoryBrokerClient

closeAsync() - Method in interface io.keldysh.messaging.general.ReactiveResource

collect(Collector<T, A, R>) - Method in class io.keldysh.messaging.MessageFlow

concatMap(Function<? super T, ? extends Publisher<? extends U>>) - Method in class io.keldysh.messaging.MessageFlow

concatWith(Publisher<? extends Message<T>>) - Method in class io.keldysh.messaging.MessageFlow

connect(Function<? super MessageFlow<T>, ? extends Publisher<? extends Message<U>>>) - Method in class io.keldysh.messaging.MessageFlow

consume(Function<? super T, ? extends Publisher<Void>>) - Method in class io.keldysh.messaging.MessageFlow

consume(Function<? super T, ? extends Publisher<Void>>, int) - Method in class io.keldysh.messaging.MessageFlow

createMulticast(String) - Method in class io.keldysh.messaging.in_memory.InMemoryBroker

Equal to InMemoryBroker.createMulticast(String, String), with equal identifier for inbound and outbound.

createMulticast(String, String) - Method in class io.keldysh.messaging.in_memory.InMemoryBroker

If not already existing, create a new inbound address to receive published messages, and route received messages to any consumer subscribed to provided outbound queue.

credentials - Static variable in class io.keldysh.messaging.artemis.artemis_test_support.ActiveMQArtemisTestContainerExtension

Credentials - Class in io.keldysh.messaging.artemis.configuration_support

Credentials() - Constructor for class io.keldysh.messaging.artemis.configuration_support.Credentials

D

DEFAULT_RETRY_STRATEGY - Static variable in class io.keldysh.messaging.MessageFlow

doFinally(Consumer<SignalType>) - Method in class io.keldysh.messaging.MessageFlow

doOnEach(Consumer<? super Signal<T>>) - Method in class io.keldysh.messaging.MessageFlow

doOnError(Class<E>, Consumer<? super E>) - Method in class io.keldysh.messaging.MessageFlow

doOnError(Consumer<? super Throwable>) - Method in class io.keldysh.messaging.MessageFlow

doOnError(Predicate<? super Throwable>, Consumer<? super Throwable>) - Method in class io.keldysh.messaging.MessageFlow

doOnNext(Consumer<? super T>) - Method in class io.keldysh.messaging.MessageFlow

E

empty() - Static method in class io.keldysh.messaging.MessageFlow

empty() - Static method in interface io.keldysh.messaging.MessageFlow.Handler

equals(Object) - Method in record class io.keldysh.messaging.configuration_support.AddressModelConfiguration

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class io.keldysh.messaging.in_memory.InMemoryBrokerClient

Indicates whether some other object is "equal to" this one.

error(Throwable) - Static method in class io.keldysh.messaging.MessageFlow

F

factory - Variable in class io.keldysh.messaging.artemis.artemis_test_support.ActiveMQArtemisTestContainerExtension

fan(Function<? super MessageFlow<T>, ? extends Publisher<? extends Message<U>>>...) - Method in class io.keldysh.messaging.MessageFlow

filter(Predicate<? super T>) - Method in class io.keldysh.messaging.MessageFlow

flatMap(Function<? super T, ? extends Publisher<? extends U>>) - Method in class io.keldysh.messaging.MessageFlow

flatMap(Function<? super T, ? extends Publisher<? extends U>>, int) - Method in class io.keldysh.messaging.MessageFlow

flow() - Method in interface io.keldysh.messaging.MessageSource

forClass(Class<T>) - Static method in interface io.keldysh.messaging.parsing.PayloadParserFactory

Deprecated.

forType(Type) - Static method in interface io.keldysh.messaging.parsing.PayloadParserFactory

G

generateBrokerXml(AddressModelConfiguration) - Static method in interface io.keldysh.messaging.configuration_support.MessagingConfigurationUtility

get() - Method in interface io.keldysh.messaging.MessageSource

getBrokerHttpPort() - Method in class io.keldysh.messaging.artemis.artemis_test_support.ArtemisTestContainer

getBrokerPort() - Method in class io.keldysh.messaging.artemis.artemis_test_support.ArtemisTestContainer

getBrokerURL() - Method in class io.keldysh.messaging.artemis.artemis_test_support.ArtemisTestContainer

GracefulShutdownException - Exception in io.keldysh.messaging.exceptions

GracefulShutdownException() - Constructor for exception io.keldysh.messaging.exceptions.GracefulShutdownException

GracefulShutdownException(String) - Constructor for exception io.keldysh.messaging.exceptions.GracefulShutdownException

GracefulShutdownException(String, Throwable) - Constructor for exception io.keldysh.messaging.exceptions.GracefulShutdownException

GracefulShutdownException(Throwable) - Constructor for exception io.keldysh.messaging.exceptions.GracefulShutdownException

group(Function<T, K>, Function<K, Function<? super MessageFlow<T>, ? extends Publisher<Message<U>>>>) - Method in class io.keldysh.messaging.MessageFlow

group(Function<T, K>, Function<K, Function<? super MessageFlow<T>, ? extends Publisher<Message<U>>>>, int) - Method in class io.keldysh.messaging.MessageFlow

H

handle(BiConsumer<? super T, SynchronousSink<U>>) - Method in class io.keldysh.messaging.MessageFlow

handle(Function<PAYLOAD, ? extends Publisher<T>>) - Method in interface io.keldysh.messaging.Message

hashCode() - Method in record class io.keldysh.messaging.configuration_support.AddressModelConfiguration

Returns a hash code value for this object.

hashCode() - Method in record class io.keldysh.messaging.in_memory.InMemoryBrokerClient

Returns a hash code value for this object.

host() - Method in class io.keldysh.messaging.artemis.artemis_test_support.ArtemisTestContainer

I

identity() - Static method in interface io.keldysh.messaging.parsing.Parser

InMemoryBroker - Class in io.keldysh.messaging.in_memory

InMemoryBroker() - Constructor for class io.keldysh.messaging.in_memory.InMemoryBroker

InMemoryBrokerClient - Record Class in io.keldysh.messaging.in_memory

InMemoryBrokerClient(InMemoryBroker) - Constructor for record class io.keldysh.messaging.in_memory.InMemoryBrokerClient

Creates an instance of a InMemoryBrokerClient record class.

io.keldysh.messaging - package io.keldysh.messaging

io.keldysh.messaging.artemis - package io.keldysh.messaging.artemis

io.keldysh.messaging.artemis.artemis_test_support - package io.keldysh.messaging.artemis.artemis_test_support

io.keldysh.messaging.artemis.configuration_support - package io.keldysh.messaging.artemis.configuration_support

io.keldysh.messaging.configuration_support - package io.keldysh.messaging.configuration_support

io.keldysh.messaging.exceptions - package io.keldysh.messaging.exceptions

io.keldysh.messaging.general - package io.keldysh.messaging.general

io.keldysh.messaging.in_memory - package io.keldysh.messaging.in_memory

io.keldysh.messaging.parsing - package io.keldysh.messaging.parsing

J

just(Message<T>...) - Static method in class io.keldysh.messaging.MessageFlow

M

map(Function<? super T, ? extends U>) - Method in class io.keldysh.messaging.MessageFlow

map(Function<PAYLOAD, T>) - Method in interface io.keldysh.messaging.Message

Message<PAYLOAD> - Interface in io.keldysh.messaging

Message.Handler<S,T> - Interface in io.keldysh.messaging

Message.Mapper<S,T> - Interface in io.keldysh.messaging

Message.Outbound<PAYLOAD> - Interface in io.keldysh.messaging

Message.Outbound.Plain<PAYLOAD> - Class in io.keldysh.messaging

Message.Plain<PAYLOAD> - Class in io.keldysh.messaging

MessageClient - Interface in io.keldysh.messaging

MessageFlow<T> - Class in io.keldysh.messaging

MessageFlow() - Constructor for class io.keldysh.messaging.MessageFlow

MessageFlow.Handler<T,U> - Interface in io.keldysh.messaging

MessageSink<PAYLOAD> - Interface in io.keldysh.messaging

MessageSource<T> - Interface in io.keldysh.messaging

MessagingConfigurationUtility - Interface in io.keldysh.messaging.configuration_support

O

objectMapper - Static variable in interface io.keldysh.messaging.parsing.PayloadParserFactory

of(Message<P>, String) - Static method in interface io.keldysh.messaging.Message.Outbound

of(Function<? super MessageFlow<T>, ? extends Publisher<? extends Message<U>>>) - Static method in interface io.keldysh.messaging.MessageFlow.Handler

of(Function<? super S, ? extends Publisher<? extends T>>) - Static method in interface io.keldysh.messaging.Message.Handler

of(Function<? super S, ? extends T>) - Static method in interface io.keldysh.messaging.Message.Mapper

of(Publisher<? extends Message<T>>) - Static method in class io.keldysh.messaging.MessageFlow

of(Publisher<? extends Message<U>>) - Static method in interface io.keldysh.messaging.MessageSource

of(PAYLOAD) - Static method in interface io.keldysh.messaging.Message

of(PAYLOAD, Mono<Void>) - Static method in interface io.keldysh.messaging.Message

P

Parser<PAYLOAD,RECEIVE_MESSAGE,PUBLISH_MESSAGE> - Interface in io.keldysh.messaging.parsing

Parser.Reader<RECEIVE_MESSAGE,PAYLOAD> - Interface in io.keldysh.messaging.parsing

Parser.Writer<PAYLOAD,PUBLISH_MESSAGE> - Interface in io.keldysh.messaging.parsing

ParsingException - Exception in io.keldysh.messaging.exceptions

ParsingException(String) - Constructor for exception io.keldysh.messaging.exceptions.ParsingException

ParsingException(String, Throwable) - Constructor for exception io.keldysh.messaging.exceptions.ParsingException

ParsingException(Throwable) - Constructor for exception io.keldysh.messaging.exceptions.ParsingException

payload() - Method in interface io.keldysh.messaging.Message

payload() - Method in class io.keldysh.messaging.Message.Plain

PayloadParser<PAYLOAD> - Interface in io.keldysh.messaging.parsing

PayloadParser.Reader<PAYLOAD> - Interface in io.keldysh.messaging.parsing

PayloadParser.Writer<PAYLOAD> - Interface in io.keldysh.messaging.parsing

PayloadParserFactory - Interface in io.keldysh.messaging.parsing

port() - Method in class io.keldysh.messaging.artemis.artemis_test_support.ArtemisTestContainer

publish(Publisher<Message<PAYLOAD>>) - Method in interface io.keldysh.messaging.MessageSink

R

ReactiveResource - Interface in io.keldysh.messaging.general

read(RECEIVE_MESSAGE) - Method in interface io.keldysh.messaging.parsing.Parser

read(RECEIVE_MESSAGE) - Method in interface io.keldysh.messaging.parsing.Parser.Reader

reader() - Method in interface io.keldysh.messaging.parsing.Parser

reader() - Method in interface io.keldysh.messaging.parsing.PayloadParser

reduce(BinaryOperator<T>) - Method in class io.keldysh.messaging.MessageFlow

resolveParameter(ParameterContext, ExtensionContext) - Method in class io.keldysh.messaging.artemis.artemis_test_support.ActiveMQArtemisTestContainerExtension

retry() - Method in class io.keldysh.messaging.MessageFlow

retry(Retry) - Method in class io.keldysh.messaging.MessageFlow

S

serverLocator - Variable in class io.keldysh.messaging.artemis.artemis_test_support.ActiveMQArtemisTestContainerExtension

ServerLocatorProperties - Class in io.keldysh.messaging.artemis.configuration_support

See class org.apache.activemq.artemis.api.config.ServerLocatorConfig for details and defaults.

ServerLocatorProperties() - Constructor for class io.keldysh.messaging.artemis.configuration_support.ServerLocatorProperties

session - Variable in class io.keldysh.messaging.artemis.artemis_test_support.ActiveMQArtemisTestContainerExtension

session(ClientSessionFactory) - Static method in class io.keldysh.messaging.artemis.artemis_test_support.ActiveMQArtemisTestContainerExtension

sessions - Static variable in class io.keldysh.messaging.artemis.artemis_test_support.ActiveMQArtemisTestContainerExtension

setupArtemisBroker(ClientSessionFactory, AddressModelConfiguration) - Static method in interface io.keldysh.messaging.configuration_support.MessagingConfigurationUtility

setupArtemisBroker(ClientSessionFactory, AddressModelConfiguration, String) - Static method in interface io.keldysh.messaging.configuration_support.MessagingConfigurationUtility

setupMockBroker(InMemoryBroker, AddressModelConfiguration) - Static method in interface io.keldysh.messaging.configuration_support.MessagingConfigurationUtility

sink(String, PayloadParser.Writer<PAYLOAD>) - Method in class io.keldysh.messaging.artemis.ArtemisClient

sink(String, PayloadParser.Writer<PAYLOAD>) - Method in record class io.keldysh.messaging.in_memory.InMemoryBrokerClient

sink(String, PayloadParser.Writer<PAYLOAD>) - Method in interface io.keldysh.messaging.MessageClient

sink(String, PayloadParser<PAYLOAD>) - Method in interface io.keldysh.messaging.MessageClient

sink(String, Type) - Method in interface io.keldysh.messaging.MessageClient

source(String, PayloadParser.Reader<PAYLOAD>) - Method in class io.keldysh.messaging.artemis.ArtemisClient

source(String, PayloadParser.Reader<PAYLOAD>) - Method in record class io.keldysh.messaging.in_memory.InMemoryBrokerClient

source(String, PayloadParser.Reader<PAYLOAD>) - Method in interface io.keldysh.messaging.MessageClient

source(String, PayloadParser<PAYLOAD>) - Method in interface io.keldysh.messaging.MessageClient

source(String, Type) - Method in interface io.keldysh.messaging.MessageClient

subscribe() - Method in class io.keldysh.messaging.MessageFlow

subscribe(Subscriber<? super Message<T>>) - Method in class io.keldysh.messaging.MessageFlow

subscribeRetry() - Method in class io.keldysh.messaging.MessageFlow

subscribeRetry(Retry) - Method in class io.keldysh.messaging.MessageFlow

supportsParameter(ParameterContext, ExtensionContext) - Method in class io.keldysh.messaging.artemis.artemis_test_support.ActiveMQArtemisTestContainerExtension

T

take(long) - Method in class io.keldysh.messaging.MessageFlow

take(Duration) - Method in class io.keldysh.messaging.MessageFlow

takeUntilOther(Publisher<?>) - Method in class io.keldysh.messaging.MessageFlow

to() - Method in class io.keldysh.messaging.Message.Outbound.Plain

to() - Method in interface io.keldysh.messaging.Message.Outbound

to(String) - Method in class io.keldysh.messaging.Message.Outbound.Plain

to(String) - Method in interface io.keldysh.messaging.Message

to(Function<T, String>) - Method in class io.keldysh.messaging.MessageFlow

toString() - Method in record class io.keldysh.messaging.configuration_support.AddressModelConfiguration

Returns a string representation of this record class.

toString() - Method in record class io.keldysh.messaging.in_memory.InMemoryBrokerClient

Returns a string representation of this record class.

toString() - Method in class io.keldysh.messaging.Message.Outbound.Plain

toString() - Method in class io.keldysh.messaging.Message.Plain

toVoid(Function<? super S, ? extends Publisher<Void>>) - Static method in interface io.keldysh.messaging.Message.Handler

W

withMessages(Function<? super Flux<Message<T>>, ? extends Publisher<Message<U>>>) - Method in class io.keldysh.messaging.MessageFlow

wrap(Publisher<U>) - Static method in interface io.keldysh.messaging.MessageSource

write(PUBLISH_MESSAGE, PAYLOAD) - Method in interface io.keldysh.messaging.parsing.Parser

write(PUBLISH_MESSAGE, PAYLOAD) - Method in interface io.keldysh.messaging.parsing.Parser.Writer

writer() - Method in interface io.keldysh.messaging.parsing.Parser

writer() - Method in interface io.keldysh.messaging.parsing.PayloadParser

A B C D E F G H I J M O P R S T W
All Classes and Interfaces|All Packages|Serialized Form