A B C D E F G H I J K L M N O P Q R S T U V W _

A

AbstractMatsTest<Z> - Class in io.mats3.test.abstractunit

Base class containing common code for Rule_Mats and Extension_Mats located in the following modules: mats-test-junit mats-test-jupiter This class sets up an in-vm Active MQ broker through the use of MatsTestBroker which is again utilized to create the MatsFactory which can be utilized to create unit tests which rely on testing functionality utilizing MATS.

AbstractMatsTest(MatsSerializer<Z>) - Constructor for class io.mats3.test.abstractunit.AbstractMatsTest

AbstractMatsTest(MatsSerializer<Z>, DataSource) - Constructor for class io.mats3.test.abstractunit.AbstractMatsTest

AbstractMatsTestEndpoint<R,I> - Class in io.mats3.test.abstractunit

Common base class which consolidates the common logic utilized by both Rule_MatsEndpoint and Extension_MatsEndpoint.

AbstractMatsTestEndpoint(String, Class<R>, Class<I>) - Constructor for class io.mats3.test.abstractunit.AbstractMatsTestEndpoint

Base constructor for AbstractMatsTestEndpoint, takes all values needed to setup the test endpoint.

actualConnectionWasRetrieved(DeferredConnectionProxyDataSourceWrapper.DeferredConnectionProxy, Connection) - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper

Override if you want to know when the actual Connection was retrieved.

add(String, String) - Method in class io.mats3.util.TraceId

add(String, long) - Method in class io.mats3.util.TraceId

addBytes(String, byte[]) - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsEditableOutgoingMessage

Add byte[] sideload to outgoing message.

addBytes(String, byte[]) - Method in class io.mats3.impl.jms.JmsMatsMessage

addBytes(String, byte[]) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

addBytes(String, byte[]) - Method in interface io.mats3.MatsEndpoint.ProcessContext

Attaches a binary payload ("sideload") to the next outgoing message, being it a request or a reply.

addBytes(String, byte[]) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

addBytes(String, byte[]) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Adds a binary payload to the outgoing request message, e.g.

addBytes(String, byte[]) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

addGotoCall(String, String, Z, Z) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

addGotoCall(String, String, Z, Z) - Method in interface io.mats3.serial.MatsTrace

addInitiationInterceptor(MatsInitiateInterceptor) - Method in interface io.mats3.api.intercept.MatsInterceptable

addInitiationInterceptor(MatsInitiateInterceptor) - Method in class io.mats3.impl.jms.JmsMatsFactory

addInitiationInterceptor(MatsInitiateInterceptor) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

addNextCall(String, String, Z, Z) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

addNextCall(String, String, Z, Z) - Method in interface io.mats3.serial.MatsTrace

Adds a NEXT Call, which is a "skip call" to the next stage in a multistage service, as opposed to the normal request out to a service expecting a reply.

addReplyCall(String, Z) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

addReplyCall(String, Z) - Method in interface io.mats3.serial.MatsTrace

Adds a REPLY Call, which happens when a requested service is finished with its processing and have some Reply to return.

addRequestCall(String, String, MatsTrace.Call.MessagingModel, String, MatsTrace.Call.MessagingModel, Z, Z, Z) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

addRequestCall(String, String, MatsTrace.Call.MessagingModel, String, MatsTrace.Call.MessagingModel, Z, Z, Z) - Method in interface io.mats3.serial.MatsTrace

Adds a REQUEST Call, which is an invocation of a service where one expects a Reply from this service to go to a specified endpoint, typically the next stage in a multi-stage endpoint: Envision a normal invocation of some method that returns a value.

addSendCall(String, String, MatsTrace.Call.MessagingModel, Z, Z) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

addSendCall(String, String, MatsTrace.Call.MessagingModel, Z, Z) - Method in interface io.mats3.serial.MatsTrace

Adds a SEND Call, meaning a "request" which do not expect a Reply: Envision an invocation of a void-method.

addStageInterceptor(MatsStageInterceptor) - Method in interface io.mats3.api.intercept.MatsInterceptable

addStageInterceptor(MatsStageInterceptor) - Method in class io.mats3.impl.jms.JmsMatsFactory

addStageInterceptor(MatsStageInterceptor) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

addString(String, String) - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsEditableOutgoingMessage

Add String sideload to outgoing message.

addString(String, String) - Method in class io.mats3.impl.jms.JmsMatsMessage

addString(String, String) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

addString(String, String) - Method in interface io.mats3.MatsEndpoint.ProcessContext

Attaches a String payload ("sideload") to the next outgoing message, being it a request or a reply.

addString(String, String) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

addString(String, String) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Adds a String payload to the outgoing request message, e.g.

addString(String, String) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

adjustStreamReadConstraints(ObjectMapper) - Method in class io.mats3.serial.json.MatsSerializerJson

after() - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint

Shutdown and remove the endpoint from the MatsFactory after test and remove reference to endpoint from field.

afterAll() - Method in class io.mats3.test.abstractunit.AbstractMatsTest

Tear down method, stopping all MatsFactory created during a test setup and close the AMQ broker.

afterAll(ExtensionContext) - Method in class io.mats3.test.jupiter.Extension_Mats

Executed by Jupiter after all test methods have been executed.

afterAll(ExtensionContext) - Method in class io.mats3.test.jupiter.Extension_MatsGeneric

Executed by Jupiter after all test methods have been executed.

afterEach(ExtensionContext) - Method in class io.mats3.test.jupiter.Extension_MatsEndpoint

apply(Class<?>, String[]) - Method in class io.mats3.impl.jms.JmsMatsContextLocalCallback

apply(Statement, Description) - Method in class io.mats3.test.junit.Rule_Mats

Note: Shamelessly inspired from: How to combine @Rule and @ClassRule in JUnit 4.12

apply(Statement, Description) - Method in class io.mats3.test.junit.Rule_MatsEndpoint

Note: Shamelessly inspired from: How to combine @Rule and @ClassRule in JUnit 4.12

apply(Statement, Description) - Method in class io.mats3.test.junit.Rule_MatsGeneric

Note: Shamelessly inspired from: How to combine @Rule and @ClassRule in JUnit 4.12

assertBigToSmallLockOrder() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.ConnectionWithSessionPool

B

batchId(String) - Method in class io.mats3.util.TraceId

batchId(long) - Method in class io.mats3.util.TraceId

before() - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint

Registers a MatsEndpoint with the provided MatsFactory, notice that the MatsFactory is not set or provided directly through this class through the use of the constructor or a method.

beforeAll() - Method in class io.mats3.test.abstractunit.AbstractMatsTest

Creates an in-vm ActiveMQ Broker which again is utilized to create a JmsMatsFactory.

beforeAll(ExtensionContext) - Method in class io.mats3.test.jupiter.Extension_Mats

Executed by Jupiter before any test method is executed.

beforeAll(ExtensionContext) - Method in class io.mats3.test.jupiter.Extension_MatsGeneric

Executed by Jupiter before any test method is executed.

beforeEach(ExtensionContext) - Method in class io.mats3.test.jupiter.Extension_MatsEndpoint

bindResource(Object, Object) - Static method in class io.mats3.impl.jms.JmsMatsContextLocalCallback

Binds a ThreadLocal resource.

build() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer

SOFT DEPRECATED, use ScenarioConnectionFactoryProducer.createConnectionFactory()!

C

cancelOutgoingMessage(String) - Method in interface io.mats3.api.intercept.CommonInterceptOutgoingMessagesContext

To remove an outgoing message, you may invoke this method, providing the unique MatsMessageId.

CannotInstantiateClassException(String, Throwable) - Constructor for exception io.mats3.impl.jms.JmsMatsFactory.CannotInstantiateClassException

checkCorrectSetup() - Method in class io.mats3.test.MatsTestBrokerInterface.MatsTestBrokerInterface_JmsMatsFactory

cleanDatabase() - Method in class io.mats3.test.TestH2DataSource

Cleans the test database: Runs SQL "DROP ALL OBJECTS DELETE FILES".

cleanDatabase(boolean) - Method in class io.mats3.test.TestH2DataSource

Cleans the test database: Runs SQL "DROP ALL OBJECTS DELETE FILES", and optionally invokes TestH2DataSource.createDataTable().

cleanMatsFactories() - Method in class io.mats3.test.abstractunit.AbstractMatsTest

Loops through all the MatsFactory's contained in this Rule (default + any specifically created), and removes all endpoints from each of them, this ensures that all factories are "clean".

cleanMatsFactory() - Method in class io.mats3.test.abstractunit.AbstractMatsTest

Deprecated.

use AbstractMatsTest.cleanMatsFactories().

clone() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

cloneForNewCall() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

Takes into account the KeepMatsTrace value.

close() - Method in class io.mats3.impl.jms.JmsMatsFactory

Method for Spring's default lifecycle - directly invokes stop(30_000).

close() - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler.JmsSessionHolder

Employed by StageProcessors: This physically closes the JMS Session, and removes it from the pool-Connection, and when all Sessions for a given pool-Connection is closed, the pool-Connection is closed.

close() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl

close() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple

close() - Method in interface io.mats3.MatsFactory

Convenience method, particularly for Spring's default destroy mechanism: Default implemented to invoke stop(30 seconds).

close() - Method in interface io.mats3.MatsInitiator

Closes any underlying backend resource.

close() - Method in interface io.mats3.test.broker.MatsTestBroker

Stops the created in-vm broker, if it was created (read MatsTestBroker.SYSPROP_MATS_TEST_BROKERURL).

close() - Method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_ActiveMq

close() - Method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_Artemis

close() - Method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_InVmActiveMq

close() - Method in class io.mats3.test.TestH2DataSource

Closes the database IF it is a random in-memory URL (as created by TestH2DataSource.createInMemoryRandom(), note: this method will be picked up by Spring as a destroy-method if the instance is made available as a Bean.

close() - Method in class io.mats3.util.MatsFuturizer

Closes the MatsFuturizer.

closeAllAvailableSessions() - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler

Closes all Available Session, does not touch Employed.

closeAllAvailableSessions() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling

closeAllAvailableSessions() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple

closeBroker(BrokerService) - Static method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_InVmActiveMq

closeJmsConnection() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.ConnectionWithSessionPool

CommonCompletedContext - Interface in io.mats3.api.intercept

Common part of the interface of MatsInitiateInterceptor.InitiateCompletedContext and MatsStageInterceptor.StageCompletedContext.

CommonCompletedContext.MatsMeasurement - Interface in io.mats3.api.intercept

CommonCompletedContext.MatsTimingMeasurement - Interface in io.mats3.api.intercept

CommonInterceptOutgoingMessagesContext - Interface in io.mats3.api.intercept

Common elements of intercepting messages for both Initiate and Stage.

commonStageAndInitiateCompleted(CommonCompletedContext, String, String, String, String, boolean, String, Logger, List<MatsOutgoingMessage.MatsSentOutgoingMessage>, String, String, long, Map<String, String>) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

commonStageAndInitiateCompleted_inner(CommonCompletedContext, String, String, String, String, boolean, String, String, long, List<MatsOutgoingMessage.MatsSentOutgoingMessage>, MatsMetricsLoggingInterceptor.Level, Logger, Throwable, String, Map<String, String>) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

compareTo(LocalStatsMatsInterceptor.IncomingMessageRepresentation) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.IncomingMessageRepresentationImpl

compareTo(LocalStatsMatsInterceptor.OutgoingMessageRepresentation) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl

compareTo(MatsFuturizer.Promise<?>) - Method in class io.mats3.util.MatsFuturizer.Promise

ComponentScanExcludingConfigurationForTest - Annotation Type in io.mats3.spring

A simple convenience replacement for @ComponentScan which excludes any configuration classes employing the special @ConfigurationForTest annotation instead of the standard @Configuration annotation.

compress(byte[]) - Method in class io.mats3.serial.json.MatsSerializerJson

concat(String, String, String) - Static method in class io.mats3.util.TraceId

concat(String, String, String, String) - Static method in class io.mats3.util.TraceId

concat(String) - Method in class io.mats3.util.TraceId

ConfigurableScenarioDecider - Class in io.mats3.spring.jms.factories

Configurable ScenarioConnectionFactoryWrapper.ScenarioDecider, whose defaults implements the logic described in ScenarioConnectionFactoryProducer and handles all the Spring Profiles specified in MatsProfiles.

ConfigurableScenarioDecider(ConfigurableScenarioDecider.SpecificScenarioDecider, ConfigurableScenarioDecider.SpecificScenarioDecider, ConfigurableScenarioDecider.SpecificScenarioDecider, Supplier<MatsScenario>) - Constructor for class io.mats3.spring.jms.factories.ConfigurableScenarioDecider

Takes a ConfigurableScenarioDecider.SpecificScenarioDecider for each of the MatsScenarios, and a default Supplier of MatsScenario if none of the SpecificScenarioDeciders kicks in - notice that it makes sense that the default instead of providing a MatsScenario instead throws an e.g.

ConfigurableScenarioDecider() - Constructor for class io.mats3.spring.jms.factories.ConfigurableScenarioDecider

No-args constructor - must set all the ConfigurableScenarioDecider.SpecificScenarioDecider and default MatsScenario by setters.

ConfigurableScenarioDecider.SpecificScenarioDecider - Interface in io.mats3.spring.jms.factories

An implementation of this interface can decide whether a specific Mats Scenario is active.

ConfigurableScenarioDecider.StandardSpecificScenarioDecider - Class in io.mats3.spring.jms.factories

Standard implementation of ConfigurableScenarioDecider.SpecificScenarioDecider used in the default configuration of ConfigurableScenarioDecider, which takes a set of profile-or-properties names and checks whether they are present as a Spring Profile, or (with the "-" replaced by ".") whether it exists as a property in the Spring Environment.

ConfigurationForTest - Annotation Type in io.mats3.spring

An "alias" for the @Configuration annotation which is meant to be used on tests' configuration classes - which then is excluded from component scanning if the component scan is using ComponentScanExcludingConfigurationForTest instead of the ordinary ComponentScan.

configure(Meter.Id, DistributionStatisticConfig) - Method in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor.SuggestedTimingHistogramsMeterFilter

ConnectionFactoryWithStartStopWrapper - Class in io.mats3.spring.jms.factories

A abstract ConnectionFactoryWrapper recognized by ScenarioConnectionFactoryProducer, which has a start() and stop() method, which can be used if you need to fire up a local MQ Broker: This class is meant to be extended to provide such functionality.

ConnectionFactoryWithStartStopWrapper() - Constructor for class io.mats3.spring.jms.factories.ConnectionFactoryWithStartStopWrapper

ConnectionFactoryWrapper - Class in io.mats3.util.wrappers

A base Wrapper for a JMS ConnectionFactory, which simply implements ConnectionFactory, takes a ConnectionFactory instance and forwards all calls to that.

ConnectionFactoryWrapper(ConnectionFactory) - Constructor for class io.mats3.util.wrappers.ConnectionFactoryWrapper

Standard constructor, taking the wrapped ConnectionFactory instance.

ConnectionFactoryWrapper() - Constructor for class io.mats3.util.wrappers.ConnectionFactoryWrapper

No-args constructor, which implies that you either need to invoke ConnectionFactoryWrapper.setWrappee(ConnectionFactory) before publishing the instance (making it available for other threads), or override ConnectionFactoryWrapper.unwrap() to provide the desired ConnectionFactory instance.

context - Variable in class io.mats3.util.MatsFuturizer.Reply

CONTEXT_LOCAL_KEY_CONNECTION_EMPLOYED_STATE_SUPPLIER - Static variable in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx

A Supplier<Boolean> bound to MatsFactory.ContextLocal when inside a Mats-transactional demarcation.

ContextLocal() - Constructor for class io.mats3.MatsFactory.ContextLocal

CouldNotGetConnectionFactoryFromProviderException(String, Throwable) - Constructor for exception io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper.CouldNotGetConnectionFactoryFromProviderException

CouldNotStartConnectionFactoryWithStartStopWrapperException(String, Throwable) - Constructor for exception io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper.CouldNotStartConnectionFactoryWithStartStopWrapperException

CouldNotStopConnectionFactoryWithStartStopWrapperException(String, Throwable) - Constructor for exception io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper.CouldNotStopConnectionFactoryWithStartStopWrapperException

crashed(Throwable) - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler.JmsSessionHolder

Notifies that a Session (or "downstream" consumer or producer) raised some exception - probably due to some connectivity issues experienced as a JMSException while interacting with the JMS API, or because the JmsMatsJmsSessionHandler.JmsSessionHolder.isSessionOk() returned false.

crashed(Throwable) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl

crashed(Throwable) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple

create(ConnectionFactory) - Static method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling

Returns a JmsMatsJmsSessionHandler which uses the INITIATOR pooling key for Intitiators (i.e.

create(ConnectionFactory, JmsMatsJmsSessionHandler_Pooling.PoolingKeyInitiator, JmsMatsJmsSessionHandler_Pooling.PoolingKeyStageProcessor) - Static method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling

Returns a JmsMatsJmsSessionHandler which have specific pooling derivation.

create(ConnectionFactory) - Static method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple

create() - Static method in class io.mats3.impl.jms.JmsMatsTransactionManager_Jms

create(DataSource) - Static method in class io.mats3.impl.jms.JmsMatsTransactionManager_JmsAndJdbc

create(MatsFactory) - Static method in interface io.mats3.localinspect.LocalHtmlInspectForMatsFactory

Creates the standard implementation of this interface.

create(MatsFactory) - Static method in class io.mats3.localinspect.LocalHtmlInspectForMatsFactoryImpl

create() - Static method in class io.mats3.serial.json.MatsSerializerJson

Constructs a MatsSerializer, using the MatsSerializerJson.DEFAULT_COMPRESSION_LEVEL (which is Deflater.BEST_SPEED, which is 1).

create(int) - Static method in class io.mats3.serial.json.MatsSerializerJson

Constructs a MatsSerializer, using the specified Compression Level - refer to Deflater's constants and levels.

create(DataSource) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx

Simplest, recommended if you do not need the PlatformTransactionManager in your Spring context! - However, if you need the PlatformTransaction manager in the Spring context, then make it externally (typically using a @Bean annotated method, and make sure to wrap the contained DataSource first with JmsMatsTransactionManager_JmsAndSpringManagedSqlTx.wrapLazyConnectionDatasource(DataSource)), and use the factory method JmsMatsTransactionManager_JmsAndSpringManagedSqlTx.create(PlatformTransactionManager) (it will find the DataSource from the PlatformTransactionManager by introspection).

create(DataSource, Function<JmsMatsTransactionManager.JmsMatsTxContextKey, DefaultTransactionDefinition>) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx

Creates an internal DataSourceTransactionManager for this created JmsMatsTransactionManager, and ensures that the supplied DataSource is wrapped using the JmsMatsTransactionManager_JmsAndSpringManagedSqlTx.wrapLazyConnectionDatasource(DataSource) method.

create(PlatformTransactionManager) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx

Next simplest, recommended if you also need the PlatformTransactionManager in your Spring context! (otherwise, use the JmsMatsTransactionManager_JmsAndSpringManagedSqlTx.create(DataSource) factory method).

create(PlatformTransactionManager, Function<JmsMatsTransactionManager.JmsMatsTxContextKey, DefaultTransactionDefinition>) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx

Creates an instance of this class from a provided PlatformTransactionManager (of a type which manages a DataSource), where the supplied instance is introspected to find a method getDataSource() from where to get the underlying DataSource.

create(PlatformTransactionManager, DataSource) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx

Creates a JmsMatsTransactionManager_JmsAndSpringManagedSqlTx from a provided PlatformTransactionManager (of a type which manages a DataSource) - Do note that you should preferably have the DataSource within the PlatformTransactionManager wrapped using the JmsMatsTransactionManager_JmsAndSpringManagedSqlTx.wrapLazyConnectionDatasource(DataSource) method.

create(PlatformTransactionManager, DataSource, Function<JmsMatsTransactionManager.JmsMatsTxContextKey, DefaultTransactionDefinition>) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx

Creates a JmsMatsTransactionManager_JmsAndSpringManagedSqlTx from a provided PlatformTransactionManager (of a type which manages a DataSource) - Do note that you should preferably have the DataSource within the PlatformTransactionManager wrapped using the JmsMatsTransactionManager_JmsAndSpringManagedSqlTx.wrapLazyConnectionDatasource(DataSource) method.

create() - Static method in interface io.mats3.test.broker.MatsTestBroker

create() - Static method in class io.mats3.test.junit.Rule_Mats

Creates a Rule_Mats utilizing the Mats default serializer

create(MatsSerializer<String>) - Static method in class io.mats3.test.junit.Rule_Mats

Creates a Rule_Mats utilizing the user provided MatsSerializer which serializes to the type of String.

create(String, Class<R>, Class<I>) - Static method in class io.mats3.test.junit.Rule_MatsEndpoint

Creates a JUnit Rule for a single-staged endpoint whose processor is not defined at start.

create(Rule_Mats, String, Class<R>, Class<I>) - Static method in class io.mats3.test.junit.Rule_MatsEndpoint

Convenience variant of create(endpointId, replyClass, incomingClass) taking a Rule_Mats as first argument for fetching the MatsFactory, for use in "pure Java" environments (read as: non-Spring).

create(MatsSerializer<Z>) - Static method in class io.mats3.test.junit.Rule_MatsGeneric

create() - Static method in class io.mats3.test.jupiter.Extension_Mats

Creates an Extension_Mats utilizing the MATS default serializer

create(MatsSerializer<String>) - Static method in class io.mats3.test.jupiter.Extension_Mats

Creates an Extension_Mats utilizing the user provided MatsSerializer which serializes to the type of String.

create(String, Class<R>, Class<I>) - Static method in class io.mats3.test.jupiter.Extension_MatsEndpoint

Creates a Jupiter Extension for a single-staged endpoint whose processor is not defined at start.

create(Extension_Mats, String, Class<R>, Class<I>) - Static method in class io.mats3.test.jupiter.Extension_MatsEndpoint

Convenience variant of create(endpointId, replyClass, incomingClass) taking a Extension_Mats as first argument for fetching the MatsFactory, for use in "pure Java" environments (read as: non-Spring).

create(MatsSerializer<Z>) - Static method in class io.mats3.test.jupiter.Extension_MatsGeneric

Creates an Extension_MatsGeneric utilizing the user provided MatsSerializer.

create(ConnectionFactory, MatsFactory) - Static method in interface io.mats3.test.MatsTestBrokerInterface

If you have both the JMS ConnectionFactory and a JmsMatsFactory available from start, then you can create a working instance right away.

create(String) - Static method in class io.mats3.test.TestH2DataSource

Creates a TestH2DataSource using the supplied URL.

create(String, String) - Static method in class io.mats3.util.TraceId

create(String, String, String) - Static method in class io.mats3.util.TraceId

createActiveMQConnectionFactory(String) - Static method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_InVmActiveMq

createArtemisBroker(String) - Static method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_Artemis

createArtemisBroker_Should_Be_Individual_DLQs_But_Does_Not_Work(String) - Static method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_Artemis

This is an attempt to get Artemis to use the "separate DLQ per queue" solution.

createConnection() - Method in class io.mats3.util.wrappers.ConnectionFactoryWrapper

createConnection(String, String) - Method in class io.mats3.util.wrappers.ConnectionFactoryWrapper

createConnectionFactory() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer

Creates the appropriate ConnectionFactory, which is a wrapper integrating with Spring - the decision between the configured scenarios is done after all Spring beans are defined.

createDataTable() - Method in class io.mats3.test.TestH2DataSource

Creates a test "datatable", runs SQL "CREATE TABLE datatable ( data VARCHAR )", using a SQL Connection from this DataSource.

createDataTable(Connection) - Static method in class io.mats3.test.TestH2DataSource

Creates a test "datatable", runs SQL "CREATE TABLE datatable ( data VARCHAR )", using the provided SQL Connection.

createDefaultScenarioDecider() - Static method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider

Configures a ScenarioConnectionFactoryWrapper.ScenarioDecider that implements the logic described in ScenarioConnectionFactoryProducer and handles all the Spring Profiles specified in MatsProfiles.

createEndpointReport(Appendable, MatsEndpoint<?, ?>, boolean) - Method in interface io.mats3.localinspect.LocalHtmlInspectForMatsFactory

Creates the report of a single endpoint.

createEndpointReport(Appendable, MatsEndpoint<?, ?>, boolean) - Method in class io.mats3.localinspect.LocalHtmlInspectForMatsFactoryImpl

createFactoryReport(Appendable, boolean, boolean, boolean) - Method in interface io.mats3.localinspect.LocalHtmlInspectForMatsFactory

Creates the full MatsFactory HTML report.

createFactoryReport(Appendable, boolean, boolean, boolean) - Method in class io.mats3.localinspect.LocalHtmlInspectForMatsFactoryImpl

createFactorySummary(Appendable, boolean, boolean) - Method in interface io.mats3.localinspect.LocalHtmlInspectForMatsFactory

Creates the "Summary table" which is a part of the factory report - it may be interesting to embed on a different page without the entire factory report.

createFactorySummary(Appendable, boolean, boolean) - Method in class io.mats3.localinspect.LocalHtmlInspectForMatsFactoryImpl

createFileBased() - Static method in class io.mats3.test.TestH2DataSource

Creates a TestH2DataSource using the URL TestH2DataSource.FILE_BASED_TEST_H2_DATABASE_URL, which is "jdbc:h2:./matsTestH2DB;AUTO_SERVER=TRUE".

createFlowId(long) - Method in interface io.mats3.impl.jms.JmsMatsStatics

createForLaterPopulation() - Static method in interface io.mats3.test.MatsTestBrokerInterface

Special factory variant, where the needed parameters must be supplied by MatsTestBrokerInterface._latePopulate(ConnectionFactory, MatsFactory), which typically will be handled by the SpringJmsMatsFactoryWrapper.

createInitiatorReport(Appendable, MatsInitiator) - Method in interface io.mats3.localinspect.LocalHtmlInspectForMatsFactory

Creates the report of a single initiator.

createInitiatorReport(Appendable, MatsInitiator) - Method in class io.mats3.localinspect.LocalHtmlInspectForMatsFactoryImpl

createInMemoryRandom() - Static method in class io.mats3.test.TestH2DataSource

Creates a unique (random) TestH2DataSource using the URL TestH2DataSource.IN_MEMORY_TEST_H2_DATABASE_URL, which is "jdbc:h2:mem:matsTestH2DB_[randomness];DB_CLOSE_DELAY=-1".

createInVmActiveMqBroker() - Static method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_InVmActiveMq

createJmsTxOnlyMatsFactory(String, String, MatsSerializer<?>, ConnectionFactory) - Static method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryProducer

If you need a MatsFactory that only handles the JMS transactions, this is your factory method - but if you DO make any database calls within any Mats endpoint lambda, you will now have no or poor transactional demarcation, use createSpringDataSourceTxMatsFactory(..) instead.

createJmsTxOnlyTestMatsFactory(int, MatsSerializer<?>) - Static method in class io.mats3.spring.test.TestSpringMatsFactoryProvider

If you need a MatsFactory that only handles the JMS transactions, this is your factory method - but if you DO make any database calls within any Mats endpoint lambda, you will now have no or poor transactional demarcation, use createSpringDataSourceTxTestMatsFactory(..) instead.

createJmsTxOnlyTestMatsFactory(MatsSerializer<?>) - Static method in class io.mats3.spring.test.TestSpringMatsFactoryProvider

Convenience variant of TestSpringMatsFactoryProvider.createJmsTxOnlyTestMatsFactory(int, MatsSerializer) where concurrency is 2, which should be adequate for most testing - unless you explicitly want to test concurrency.

createMatsFactory(String, String, JmsMatsJmsSessionHandler, JmsMatsTransactionManager, MatsSerializer<Z>) - Static method in class io.mats3.impl.jms.JmsMatsFactory

createMatsFactory() - Method in class io.mats3.test.abstractunit.AbstractMatsTest

You should probably NOT use this method, but instead the AbstractMatsTest.getMatsFactory()!.

createMatsFactory_JmsAndJdbcTransactions(String, String, JmsMatsJmsSessionHandler, DataSource, MatsSerializer<Z>) - Static method in class io.mats3.impl.jms.JmsMatsFactory

createMatsFactory_JmsOnlyTransactions(String, String, JmsMatsJmsSessionHandler, MatsSerializer<Z>) - Static method in class io.mats3.impl.jms.JmsMatsFactory

createMatsFuturizer(MatsFactory) - Static method in class io.mats3.util.MatsFuturizer

Creates a MatsFuturizer, and you should only need one per MatsFactory (which again mostly means one per application or micro-service or JVM).

createMatsFuturizer(MatsFactory, String) - Static method in class io.mats3.util.MatsFuturizer

Creates a MatsFuturizer, and you should only need one per MatsFactory (which again mostly means one per application or micro-service or JVM).

createMatsFuturizer(MatsFactory, String, int, int, int) - Static method in class io.mats3.util.MatsFuturizer

Creates a MatsFuturizer, and you should only need one per MatsFactory (which again mostly means one per application or micro-service or JVM).

createNew(String, String, MatsTrace.KeepMatsTrace, boolean, boolean, long, boolean) - Static method in class io.mats3.serial.json.MatsTraceStringImpl

Creates a new MatsTrace.

createNewMatsTrace(String, String, MatsTrace.KeepMatsTrace, boolean, boolean, long, boolean) - Method in class io.mats3.serial.json.MatsSerializerJson

createNewMatsTrace(String, String, MatsTrace.KeepMatsTrace, boolean, boolean, long, boolean) - Method in interface io.mats3.serial.MatsSerializer

Used when initiating a new Mats flow.

createSpringDataSourceTxMatsFactory(String, String, MatsSerializer<?>, ConnectionFactory, DataSource) - Static method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryProducer

If you need a MatsFactory employing Spring's DataSourceTransactionManager (which you probably do in a Spring environment utilizing SQL), this is your factory method.

createSpringDataSourceTxTestMatsFactory(int, DataSource, MatsSerializer<?>) - Static method in class io.mats3.spring.test.TestSpringMatsFactoryProvider

If you need a MatsFactory employing Spring's DataSourceTransactionManager (which you probably do in a Spring environment utilizing SQL), this is your factory method.

createSpringDataSourceTxTestMatsFactory(DataSource, MatsSerializer<?>) - Static method in class io.mats3.spring.test.TestSpringMatsFactoryProvider

Convenience variant of TestSpringMatsFactoryProvider.createSpringDataSourceTxTestMatsFactory(int, DataSource, MatsSerializer) where concurrency is 1, which should be adequate for most testing - unless you explicitly want to test concurrency.

createSpringDataSourceTxTestMatsFactory(int, PlatformTransactionManager, MatsSerializer<?>) - Static method in class io.mats3.spring.test.TestSpringMatsFactoryProvider

If you need a MatsFactory, but you need to make your own PlatformTransactionManager, this is your factory method - please note that the contained DataSource should have been wrapped using the static method JmsMatsTransactionManager_JmsAndSpringManagedSqlTx.wrapLazyConnectionDatasource(DataSource).

createSpringDataSourceTxTestMatsFactory(PlatformTransactionManager, MatsSerializer<?>) - Static method in class io.mats3.spring.test.TestSpringMatsFactoryProvider

Convenience variant of TestSpringMatsFactoryProvider.createSpringDataSourceTxTestMatsFactory(int, PlatformTransactionManager, MatsSerializer) where concurrency is 2, which should be adequate for most testing - unless you explicitly want to test concurrency.

createSpringPlatformTransactionManagerTxMatsFactory(String, String, MatsSerializer<?>, ConnectionFactory, PlatformTransactionManager) - Static method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryProducer

If you need a MatsFactory employing a PlatformTransactionManager of your choosing, which you quite possibly want in a Spring environment using e.g.

createStageReport(Appendable, MatsStage<?, ?, ?>) - Method in interface io.mats3.localinspect.LocalHtmlInspectForMatsFactory

Creates the report of a single stage.

createStageReport(Appendable, MatsStage<?, ?, ?>) - Method in class io.mats3.localinspect.LocalHtmlInspectForMatsFactoryImpl

createStandard() - Static method in class io.mats3.test.TestH2DataSource

Creates an in-memory TestH2DataSource as specified by the URL TestH2DataSource.IN_MEMORY_TEST_H2_DATABASE_URL, which is "jdbc:h2:mem:matsTestH2DB_[randomness];DB_CLOSE_DELAY=-1", unless the System Property TestH2DataSource.SYSPROP_MATS_TEST_H2 ("mats.test.h2") is directly set to a different URL to use, with the special case that if it is TestH2DataSource.SYSPROP_VALUE_FILE_BASED ("file"), in which case TestH2DataSource.FILE_BASED_TEST_H2_DATABASE_URL ("jdbc:h2:./matsTestH2DB;AUTO_SERVER=TRUE) is used as URL.

createTargetConnectionFactoryBasedOnScenarioDecider() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

createUniqueInVmActiveMq() - Static method in interface io.mats3.test.broker.MatsTestBroker

This is a special factory method, which creates a unique (randomly named) in-vm ActiveMQ instance, no matter what the system properties says.

createWithDb() - Static method in class io.mats3.test.junit.Rule_Mats

createWithDb(MatsSerializer<String>) - Static method in class io.mats3.test.junit.Rule_Mats

createWithDb(MatsSerializer<Z>) - Static method in class io.mats3.test.junit.Rule_MatsGeneric

createWithDb() - Static method in class io.mats3.test.jupiter.Extension_Mats

createWithDb(MatsSerializer<String>) - Static method in class io.mats3.test.jupiter.Extension_Mats

createWithDb(MatsSerializer<Z>) - Static method in class io.mats3.test.jupiter.Extension_MatsGeneric

D

DataSourceWrapper - Class in io.mats3.util.wrappers

A base Wrapper for a JDBC DataSource, which simply implements DataSource, takes a DataSource instance and forwards all calls to that.

DataSourceWrapper(DataSource) - Constructor for class io.mats3.util.wrappers.DataSourceWrapper

Standard constructor, taking the wrapped DataSource instance.

DataSourceWrapper() - Constructor for class io.mats3.util.wrappers.DataSourceWrapper

No-args constructor, which implies that you either need to invoke DataSourceWrapper.setWrappee(DataSource) before publishing the instance (making it available for other threads), or override DataSourceWrapper.unwrap() to provide the desired DataSource instance.

decision(Environment) - Method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider

decision(Environment) - Method in interface io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper.ScenarioDecider

decompress(byte[], int, int, int) - Method in class io.mats3.serial.json.MatsSerializerJson

DEFAULT_COMPRESSION_LEVEL - Static variable in class io.mats3.serial.json.MatsSerializerJson

The default compression level - which I chose to be Deflater.BEST_SPEED (compression level 1), since I assume that the rather small incremental reduction in size does not outweigh the pretty large increase in time, as one hopefully runs on a pretty fast network (and that the MQ backing store is fast).

DEFAULT_NUM_SAMPLES - Static variable in class io.mats3.localinspect.LocalStatsMatsInterceptor

DeferredConnectionProxyDataSourceWrapper - Class in io.mats3.util.wrappers

DataSource wrapper which returns thin Connection proxies (currently employing Java's "dynamic proxy" functionality) which do not actually fetch a Connection until it is needed.

DeferredConnectionProxyDataSourceWrapper() - Constructor for class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper

DeferredConnectionProxyDataSourceWrapper(DataSource) - Constructor for class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper

DeferredConnectionProxyDataSourceWrapper.DeferredConnectionProxy - Interface in io.mats3.util.wrappers

Provides a method to query whether the Connection actually was gotten.

DeferredConnectionProxyDataSourceWrapper.DeferredFetchInvocationHandler - Class in io.mats3.util.wrappers

Implementation of Java's "dynamic proxy" InvocationHandler for deferring fetching of actual Connection until necessary.

DeferredConnectionProxyDataSourceWrapper_InfrastructureProxy(DataSource) - Constructor for class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx.DeferredConnectionProxyDataSourceWrapper_InfrastructureProxy

DeferredFetchInvocationHandler() - Constructor for class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper.DeferredFetchInvocationHandler

DeferredFetchInvocationHandler(String, String) - Constructor for class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper.DeferredFetchInvocationHandler

derivePoolingKey(JmsMatsTransactionManager.JmsMatsTxContextKey) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling

deserializeMatsTrace(byte[], String) - Method in class io.mats3.serial.json.MatsSerializerJson

deserializeMatsTrace(byte[], int, int, String) - Method in class io.mats3.serial.json.MatsSerializerJson

deserializeMatsTrace(byte[], int, int, String) - Method in interface io.mats3.serial.MatsSerializer

Used for deserializing a byte array into a MatsTrace - this includes offset and length.

deserializeMatsTrace(byte[], String) - Method in interface io.mats3.serial.MatsSerializer

Used for deserializing a byte array into a MatsTrace - this uses the entire byte array.

deserializeObject(String, Class<T>) - Method in class io.mats3.serial.json.MatsSerializerJson

deserializeObject(Z, Class<T>) - Method in interface io.mats3.serial.MatsSerializer

Used for deserializing type Z (typically String) to STOs and DTOs.

doAfterCommit(Runnable) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

doAfterCommit(Runnable) - Method in interface io.mats3.MatsEndpoint.ProcessContext

The Runnable will be performed after messaging and external resources (DB) have been committed.

doAfterCommit(Runnable) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

doTransaction(JmsMatsInternalExecutionContext, JmsMatsTransactionManager.ProcessingLambda) - Method in interface io.mats3.impl.jms.JmsMatsTransactionManager.TransactionContext

Shall open relevant transactions (that are not already opened by means of JMS's "always in transaction" for transactional Connections), perform the provided lambda, and then commit the transactions (including the JMS Session).

doTransaction(JmsMatsInternalExecutionContext, JmsMatsTransactionManager.ProcessingLambda) - Method in class io.mats3.impl.jms.JmsMatsTransactionManager_Jms.TransactionalContext_Jms

doTransaction(JmsMatsInternalExecutionContext, JmsMatsTransactionManager.ProcessingLambda) - Method in class io.mats3.impl.jms.JmsMatsTransactionManager_JmsAndJdbc.TransactionalContext_JmsAndJdbc

Dto - Annotation Type in io.mats3.spring

Specifies that the annotated method parameter is an incoming Data Transfer Object.

E

EnableMats - Annotation Type in io.mats3.spring

Enables Mats "SpringConfig", which is bean-scanning for methods on Spring beans annotated with MatsMapping, MatsClassMapping and MatsEndpointSetup, conceptually inspired by the @EnableWebMvc annotation.

endpoint() - Static method in class io.mats3.test.MatsTestHelp

endpoint(String) - Static method in class io.mats3.test.MatsTestHelp

equals(Object) - Method in class io.mats3.impl.jms.JmsMatsEndpoint

equals(Object) - Method in class io.mats3.impl.jms.JmsMatsFactory

equals(Object) - Method in class io.mats3.impl.jms.JmsMatsMessage

equals(Object) - Method in class io.mats3.impl.jms.JmsMatsStage

equals(Object) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.IncomingMessageRepresentationImpl

equals(Object) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl

equals(Object) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

Extension_Mats - Class in io.mats3.test.jupiter

Provides a full MATS harness for unit testing by creating MatsFactory utilizing an in-vm Active MQ broker, and optionally a TestH2DataSource for database tests.

Extension_Mats(MatsSerializer<String>) - Constructor for class io.mats3.test.jupiter.Extension_Mats

Extension_Mats(MatsSerializer<String>, DataSource) - Constructor for class io.mats3.test.jupiter.Extension_Mats

Extension_MatsEndpoint<R,I> - Class in io.mats3.test.jupiter

Extension to create a single staged endpoint whose reply/processor can be changed throughout its life, i.e.

Extension_MatsGeneric<Z> - Class in io.mats3.test.jupiter

Similar to Extension_Mats, provides a full MATS harness for unit testing by creating MatsFactory utilizing an in-vm Active MQ broker.

Extension_MatsGeneric(MatsSerializer<Z>) - Constructor for class io.mats3.test.jupiter.Extension_MatsGeneric

Extension_MatsGeneric(MatsSerializer<Z>, DataSource) - Constructor for class io.mats3.test.jupiter.Extension_MatsGeneric

EXTRA_GRACE_MILLIS - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

Number of milliseconds to "extra wait" after timeoutMillis or gracefulShutdownMillis is gone.

EXTRA_STATE_ENDPOINT_ENTER_NANOS - Static variable in class io.mats3.localinspect.LocalStatsMatsInterceptor

EXTRA_STATE_ENDPOINT_ENTER_NODENAME - Static variable in class io.mats3.localinspect.LocalStatsMatsInterceptor

EXTRA_STATE_OR_SIDELOAD_INITIATOR_NANOS - Static variable in class io.mats3.localinspect.LocalStatsMatsInterceptor

EXTRA_STATE_OR_SIDELOAD_INITIATOR_NODENAME - Static variable in class io.mats3.localinspect.LocalStatsMatsInterceptor

EXTRA_STATE_REQUEST_NANOS - Static variable in class io.mats3.localinspect.LocalStatsMatsInterceptor

EXTRA_STATE_REQUEST_NODENAME - Static variable in class io.mats3.localinspect.LocalStatsMatsInterceptor

extraConfigureObjectMapper(ObjectMapper) - Method in class io.mats3.serial.json.MatsSerializerJson

Override if you want to change the Jackson ObjectMapper.

F

FILE_BASED_TEST_H2_DATABASE_URL - Static variable in class io.mats3.test.TestH2DataSource

findFields(Class<?>, String) - Static method in class io.mats3.spring.test.SpringInjectRulesAndExtensions.SpringInjectRulesAndExtensionsTestExecutionListener

Find all fields in class with given annotation.

finishSetup() - Method in class io.mats3.impl.jms.JmsMatsEndpoint

finishSetup() - Method in interface io.mats3.MatsEndpoint

Should be invoked when all stages has been added.

fork(String, String, String) - Static method in class io.mats3.util.TraceId

fork(String, String, String, String) - Static method in class io.mats3.util.TraceId

fork(String) - Method in class io.mats3.util.TraceId

from(String) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Sets the originating/initiating "synthetic endpoint Id" - only used for statistics/tracing/debugging.

from(String) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

from() - Static method in class io.mats3.test.MatsTestHelp

from(String) - Static method in class io.mats3.test.MatsTestHelp

futurize(String, String, String, int, TimeUnit, Class<T>, Object, MatsInitiator.InitiateLambda) - Method in class io.mats3.util.MatsFuturizer

The generic form of initiating a request-message that returns a CompletableFuture, which enables you to tailor all properties.

futurize(String, String, String, Class<T>, Object, MatsInitiator.InitiateLambda) - Method in class io.mats3.util.MatsFuturizer

Convenience-variant of the generic futurize(..) form, where the timeout is set to 2.5 minutes.

futurizeNonessential(String, String, String, Class<T>, Object) - Method in class io.mats3.util.MatsFuturizer

NOTICE: This variant must only be used for "GET-style" Requests where none of the endpoints the call flow passes will add, remove or alter any state of the system, and where it doesn't matter all that much if a message (and hence the Mats flow) is lost!

The goal of this method is to be able to get hold of e.g.

G

get(Environment) - Method in interface io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider

getAppName() - Method in interface io.mats3.MatsFactory.FactoryConfig

getAppVersion() - Method in interface io.mats3.MatsFactory.FactoryConfig

getAttribute(Class<T>, String...) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getAttribute(String) - Method in interface io.mats3.MatsConfig

getAttribute(Class<T>, String...) - Method in interface io.mats3.MatsEndpoint.ProcessContext

Provides a way to get hold of (optional) attributes/objects from the Mats implementation, either specific to the Mats implementation in use, or configured into this instance of the Mats implementation.

getAttribute(Class<T>, String...) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getAttribute(Class<T>, String...) - Static method in class io.mats3.MatsFactory.ContextLocal

Provides a ThreadLocal-accessible variant of the ProcessContext.getAttribute(..) and MatsInitiate.getAttribute(..) methods: If the executing thread is within a Mats initiation, or is currently processing a MatsStage, the return value will be the same as if the relevant getAttribute(..) method was invoked.

getAttribute(Class<T>, String...) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Provides a way to get hold of (optional) attributes/objects from the Mats implementation, either specific to the Mats implementation in use, or configured into this instance of the Mats implementation.

getAttribute(Class<T>, String...) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

getAutoCommitFromWrappedDataSource() - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper

getBaseUnit() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsMeasurement

getBetweenStagesTimeNanos() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.StageStats

Note: Not present for the LocalStatsMatsInterceptor.StageStats.isInitial() stage, as there is no "between" for the initial stage.

getBytes(String) - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getBytes(String) - Method in class io.mats3.impl.jms.JmsMatsMessage

getBytes(String) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getBytes(String) - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

Get binary "sideloads" from the incoming message.

getBytes(String) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getBytesKeys() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getBytesKeys() - Method in class io.mats3.impl.jms.JmsMatsMessage

getBytesKeys() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getBytesKeys() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

getBytesKeys() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getCalledTimestamp() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

getCalledTimestamp() - Method in interface io.mats3.serial.MatsTrace.Call

getCallFlow() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getCallFlow() - Method in interface io.mats3.serial.MatsTrace

getCallingAppName() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

getCallingAppName() - Method in interface io.mats3.serial.MatsTrace.Call

getCallingAppVersion() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

getCallingAppVersion() - Method in interface io.mats3.serial.MatsTrace.Call

getCallingHost() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

getCallingHost() - Method in interface io.mats3.serial.MatsTrace.Call

getCallNumber() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getCallNumber() - Method in interface io.mats3.serial.MatsTrace

getCallType() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

getCallType() - Method in interface io.mats3.serial.MatsTrace.Call

getChildrenStartStoppable() - Method in class io.mats3.impl.jms.JmsMatsEndpoint

getChildrenStartStoppable() - Method in class io.mats3.impl.jms.JmsMatsFactory

getChildrenStartStoppable() - Method in class io.mats3.impl.jms.JmsMatsStage

getChildrenStartStoppable() - Method in interface io.mats3.impl.jms.JmsMatsStartStoppable

Must be implemented to provide your children.

getClassLogger() - Static method in class io.mats3.test.MatsTestHelp

getCompleterThreadPool() - Method in class io.mats3.util.MatsFuturizer

getConcurrency() - Method in interface io.mats3.MatsConfig

Returns the concurrency set up for this factory, or endpoint, or stage.

getConnection() - Method in class io.mats3.test.TestH2DataSource

getConnection(String, String) - Method in class io.mats3.test.TestH2DataSource

getConnection() - Method in class io.mats3.util.wrappers.DataSourceWrapper

getConnection(String, String) - Method in class io.mats3.util.wrappers.DataSourceWrapper

getConnection() - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper

getConnection(String, String) - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper

getConnectionFactory() - Method in interface io.mats3.test.broker.MatsTestBroker

getConnectionFactory() - Method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_ActiveMq

getConnectionFactory() - Method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_Artemis

getConnectionFactory() - Method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_InVmActiveMq

getContext() - Method in interface io.mats3.test.MatsTestLatch.Result

getContext() - Method in class io.mats3.util.MatsFuturizer.Reply

getCurrentCall() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getCurrentCall() - Method in interface io.mats3.serial.MatsTrace

getCurrentSpanId() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getCurrentSpanId() - Method in interface io.mats3.serial.MatsTrace

getCurrentState() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getCurrentState() - Method in interface io.mats3.serial.MatsTrace

Returns the MatsTrace.StackState for the MatsTrace.getCurrentCall(), if present.

getData() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getData() - Method in class io.mats3.impl.jms.JmsMatsMessage

getData() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

getData() - Method in interface io.mats3.serial.MatsTrace.Call

getData() - Method in interface io.mats3.test.MatsTestLatch.Result

getDataAndStateDeserializationNanos() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

getDataFromDataTable() - Method in class io.mats3.test.TestH2DataSource

getDataFromDataTable(Connection) - Static method in class io.mats3.test.TestH2DataSource

getDataSerializedSize() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage

getDataSerializedSize() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

getDataSerializedSize() - Method in class io.mats3.impl.jms.JmsMatsMessage

getDataSource() - Method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx

getDataSource() - Method in class io.mats3.test.abstractunit.AbstractMatsTest

getDataSource() - Method in class io.mats3.test.junit.Rule_Mats

getDataSource() - Method in class io.mats3.test.junit.Rule_MatsGeneric

getDataSource() - Method in class io.mats3.test.jupiter.Extension_MatsGeneric

getDataSourceUnwrapped() - Method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx

getDbCommitNanos() - Method in interface io.mats3.api.intercept.CommonCompletedContext

getDbCommitNanos() - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext

getDebugInfo() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

getDebugInfo() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getDebugInfo() - Method in interface io.mats3.serial.MatsTrace.Call

getDebugInfo() - Method in interface io.mats3.serial.MatsTrace

getDefaultInitiator() - Method in class io.mats3.impl.jms.JmsMatsFactory

getDefaultInitiator() - Method in interface io.mats3.MatsFactory

Gets or creates the default Initiator (whose name is 'default') from which to initiate new Mats processes, i.e.

getDefaultInitiator() - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

getDefaultNoDestinationMessageProducer() - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler.JmsSessionHolder

getDefaultNoDestinationMessageProducer() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl

getDefaultNoDestinationMessageProducer() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple

getDescription() - Method in class io.mats3.test.TestH2DataSource

Get the current description.

getDispatchType() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getDispatchType() - Method in class io.mats3.impl.jms.JmsMatsMessage

getDlqMessage(String) - Method in interface io.mats3.test.MatsTestBrokerInterface

Waits a couple of seconds for a message to appear on the Dead Letter Queue for the provided endpoint- or stageId (Queue name "DLQ."+matsendpointPrefix+endpointOrStageId) - and also checks the standard common ActiveMQ DLQ (Queue name "ActiveMQ.DLQ") in case the broker is not configured with specific DLQs per Queue, which is relevant if you fire up an unmodified ActiveMQ distribution on the command line, check the MatsTestBroker class JavaDoc for how to use an external MQ instead of the in-VM which otherwise is fired up.

getDlqMessage(String) - Method in class io.mats3.test.MatsTestBrokerInterface.MatsTestBrokerInterface_JmsMatsFactory

Waits a couple of seconds for a message to appear on the Dead Letter Queue for the provided endpoint- or stageId (Queue name "DLQ."+matsendpointPrefix+endpointOrStageId) - and also checks the standard common ActiveMQ DLQ (Queue name "ActiveMQ.DLQ") in case the broker is not configured with specific DLQs per Queue, which is relevant if you fire up an unmodified ActiveMQ distribution on the command line, check the MatsTestBroker class JavaDoc for how to use an external MQ instead of the in-VM which otherwise is fired up.

getEndpoint(String) - Method in class io.mats3.impl.jms.JmsMatsFactory

getEndpoint(String) - Method in interface io.mats3.MatsFactory

getEndpoint(String) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

getEndpointConfig() - Method in class io.mats3.impl.jms.JmsMatsEndpoint

getEndpointConfig() - Method in interface io.mats3.MatsEndpoint

getEndpointEnteredTimestamp() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

Returns the timestamp when the initial stage of the Endpoint which this Stage belongs to, was entered.

getEndpointId() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getEndpointId() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

getEndpointId() - Method in interface io.mats3.MatsEndpoint.EndpointConfig

getEndpointId() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getEndpoints() - Method in class io.mats3.impl.jms.JmsMatsFactory

getEndpoints() - Method in interface io.mats3.MatsFactory

getEndpoints() - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

getEndpointStats(MatsEndpoint<?, ?>) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor

getEnvelopeCompressionNanos() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage

getEnvelopeCompressionNanos() - Method in class io.mats3.impl.jms.JmsMatsMessage

getEnvelopeDecompressionNanos() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

getEnvelopeDeserializationNanos() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

getEnvelopeProduceNanos() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage

getEnvelopeProduceNanos() - Method in class io.mats3.impl.jms.JmsMatsMessage

getEnvelopeSerializationNanos() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage

getEnvelopeSerializationNanos() - Method in class io.mats3.impl.jms.JmsMatsMessage

getEnvelopeSerializedSize() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage

getEnvelopeSerializedSize() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

getEnvelopeSerializedSize() - Method in class io.mats3.impl.jms.JmsMatsMessage

getEnvelopeWireSize() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage

getEnvelopeWireSize() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

getEnvelopeWireSize() - Method in class io.mats3.impl.jms.JmsMatsMessage

getExtraState(String) - Method in interface io.mats3.serial.MatsTrace.StackState

Retrieves "extra state" on this StackState.

getFactory() - Method in interface io.mats3.impl.jms.JmsMatsTransactionManager.JmsMatsTxContextKey

getFactoryConfig() - Method in class io.mats3.impl.jms.JmsMatsFactory

getFactoryConfig() - Method in interface io.mats3.MatsFactory

getFactoryConfig() - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

getFlowId() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getFlowId() - Method in class io.mats3.impl.jms.JmsMatsMessage

getFlowId() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getFlowId() - Method in interface io.mats3.serial.MatsTrace

getFrom() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

Note: For messages out of an initiator, this method and MatsOutgoingMessage.getInitiatorId() returns the same value, i.e.

getFrom() - Method in class io.mats3.impl.jms.JmsMatsMessage

getFrom() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

getFrom() - Method in interface io.mats3.serial.MatsTrace.Call

getFrom() - Method in interface io.mats3.test.MatsTestBrokerInterface.MatsMessageRepresentation

getFromAppName() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getFromAppName() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.IncomingMessageRepresentation

getFromAppName() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.IncomingMessageRepresentationImpl

getFromAppName() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

getFromAppName() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getFromAppVersion() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getFromAppVersion() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

getFromAppVersion() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getFromStageId() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getFromStageId() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.IncomingMessageRepresentation

getFromStageId() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.IncomingMessageRepresentationImpl

getFromStageId() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

getFromStageId() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getFromTimestamp() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getFromTimestamp() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

getFromTimestamp() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getHeight() - Method in interface io.mats3.serial.MatsTrace.StackState

getId() - Method in interface io.mats3.serial.MatsTrace.Call.Channel

getIncomingClass() - Method in interface io.mats3.MatsEndpoint.EndpointConfig

getIncomingClass() - Method in interface io.mats3.MatsStage.StageConfig

getIncomingData() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

getIncomingMessage(Class<I>) - Method in interface io.mats3.test.MatsTestBrokerInterface.MatsMessageRepresentation

The message DTO that was provided to the Mats Endpoint which DLQed the message.

getIncomingMessageCounts() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.StageStats

getIncomingMessageType() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

getIncomingSameStackHeightExtraState(String, Class<T>) - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

getIncomingState() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

getIncomingState(Class<S>) - Method in interface io.mats3.test.MatsTestBrokerInterface.MatsMessageRepresentation

The state DTO that was provided to the Mats Endpoint which DLQed the message.

getIndex() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.StageStats

getInitializedTimestamp() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getInitializedTimestamp() - Method in interface io.mats3.serial.MatsTrace

getInitializingAppName() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getInitializingAppName() - Method in interface io.mats3.serial.MatsTrace

getInitializingAppVersion() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getInitializingAppVersion() - Method in interface io.mats3.serial.MatsTrace

getInitializingHost() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getInitializingHost() - Method in interface io.mats3.serial.MatsTrace

getInitialTargetState() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getInitialTargetState() - Method in class io.mats3.impl.jms.JmsMatsMessage

getInitiatingAppName() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getInitiatingAppName() - Method in class io.mats3.impl.jms.JmsMatsMessage

getInitiatingAppName() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getInitiatingAppName() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.IncomingMessageRepresentationImpl

getInitiatingAppName() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.MessageRepresentation

getInitiatingAppName() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl

getInitiatingAppName() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

getInitiatingAppName() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getInitiatingAppVersion() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getInitiatingAppVersion() - Method in class io.mats3.impl.jms.JmsMatsMessage

getInitiatingAppVersion() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getInitiatingAppVersion() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

getInitiatingAppVersion() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getInitiatingTimestamp() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getInitiatingTimestamp() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

getInitiatingTimestamp() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getInitiationInterceptor(Class<T>) - Method in interface io.mats3.api.intercept.MatsInterceptable

getInitiationInterceptor(Class<T>) - Method in class io.mats3.impl.jms.JmsMatsFactory

getInitiationInterceptor(Class<T>) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

getInitiationInterceptors() - Method in interface io.mats3.api.intercept.MatsInterceptable

getInitiationInterceptors() - Method in class io.mats3.impl.jms.JmsMatsFactory

getInitiationInterceptors() - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

getInitiationTimestamp() - Method in exception io.mats3.util.MatsFuturizer.MatsFuturizerTimeoutException

getInitiationTimestamp() - Method in class io.mats3.util.MatsFuturizer.Reply

getInitiator() - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor.InitiateInterceptContext

getInitiatorId() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

Note: For messages out of an initiator, this method and MatsOutgoingMessage.getFrom() returns the same value, i.e.

getInitiatorId() - Method in class io.mats3.impl.jms.JmsMatsMessage

getInitiatorId() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getInitiatorId() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.IncomingMessageRepresentationImpl

getInitiatorId() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.MessageRepresentation

getInitiatorId() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl

getInitiatorId() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

getInitiatorId() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getInitiatorId() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getInitiatorId() - Method in interface io.mats3.serial.MatsTrace

getInitiators() - Method in class io.mats3.impl.jms.JmsMatsFactory

getInitiators() - Method in interface io.mats3.MatsFactory

getInitiators() - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

getInitiatorStats(MatsInitiator) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor

getInitiatorToTerminatorTimeNanos() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStats

Only relevant for Endpoints that LocalStatsMatsInterceptor.EndpointStats.isTerminatorEndpoint(). Terminator endpoints have a special set of timings: Time taken from the start of initiation to the terminator receives it.

getInitiatorToTerminatorTimeNanos() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStatsImpl

getInteractiveConcurrency() - Method in interface io.mats3.MatsConfig

Returns the interactive concurrency set up for this factory, or endpoint, or stage.

getInterceptContextAttribute(String) - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

getInvocationPoint() - Method in interface io.mats3.impl.jms.JmsMatsStatics

Inspired from Stackoverflow - Denys Séguret.

getJavaScript(Appendable) - Method in interface io.mats3.localinspect.LocalHtmlInspectForMatsFactory

Note: The return from this method is static, and should only be included once per HTML page, no matter how many MatsFactories you display.

getJavaScript(Appendable) - Method in class io.mats3.localinspect.LocalHtmlInspectForMatsFactoryImpl

Note: The return from this method is static, and should only be included once per HTML page, no matter how many MatsFactories you display.

getJmsConnectionFactory() - Method in class io.mats3.test.abstractunit.AbstractMatsTest

getJmsMatsJmsSessionHandler() - Method in class io.mats3.impl.jms.JmsMatsFactory

getJmsMatsTransactionManager() - Method in class io.mats3.impl.jms.JmsMatsFactory

getJmsSessionHolder() - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext

getKeepTrace() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getKeepTrace() - Method in interface io.mats3.serial.MatsTrace

getLabelKeyValue() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsMeasurement

getLabelKeyValue() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsTimingMeasurement

getLoginTimeout() - Method in class io.mats3.test.TestH2DataSource

getLoginTimeout() - Method in class io.mats3.util.wrappers.DataSourceWrapper

getLogWriter() - Method in class io.mats3.test.TestH2DataSource

getLogWriter() - Method in class io.mats3.util.wrappers.DataSourceWrapper

getMatsDestinationPrefix() - Method in interface io.mats3.MatsFactory.FactoryConfig

getMatsFactory() - Method in class io.mats3.test.abstractunit.AbstractMatsTest

getMatsFuturizer() - Method in class io.mats3.test.abstractunit.AbstractMatsTest

getMatsImplementationName() - Method in interface io.mats3.MatsFactory.FactoryConfig

getMatsImplementationVersion() - Method in interface io.mats3.MatsFactory.FactoryConfig

getMatsInitiator() - Method in class io.mats3.test.abstractunit.AbstractMatsTest

getMatsInterceptableMatsFactory() - Method in class io.mats3.test.abstractunit.AbstractMatsTest

getMatsMessageId() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getMatsMessageId() - Method in class io.mats3.impl.jms.JmsMatsMessage

getMatsMessageId() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getMatsMessageId() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

getMatsMessageId() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getMatsMessageId() - Method in interface io.mats3.MatsInitiator.MessageReference

getMatsMessageId() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

getMatsMessageId() - Method in interface io.mats3.serial.MatsTrace.Call

getMatsMessageId() - Method in interface io.mats3.test.MatsTestBrokerInterface.MatsMessageRepresentation

getMatsScenarioUsedToMakeConnectionFactory() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

getMatsSerializer() - Method in class io.mats3.impl.jms.JmsMatsFactory

getMatsTestBrokerInterface() - Method in class io.mats3.test.abstractunit.AbstractMatsTest

getMatsTestLatch() - Method in class io.mats3.test.abstractunit.AbstractMatsTest

getMatsTrace() - Method in class io.mats3.impl.jms.JmsMatsMessage

getMatsTrace() - Method in interface io.mats3.serial.MatsSerializer.DeserializedMatsTrace

getMatsTraceBytes() - Method in interface io.mats3.serial.MatsSerializer.SerializedMatsTrace

getMatsTraceKey() - Method in interface io.mats3.MatsFactory.FactoryConfig

getMeasure() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsMeasurement

getMeasurements() - Method in interface io.mats3.api.intercept.CommonCompletedContext

getMessageClass() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentation

getMessageClass() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl

getMessageConsumer() - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext

getMessageSystemCommitNanos() - Method in interface io.mats3.api.intercept.CommonCompletedContext

getMessageSystemCommitNanos() - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext

getMessageSystemDeconstructNanos() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

getMessageSystemProduceAndSendNanos() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage

getMessageSystemProduceAndSendNanos() - Method in class io.mats3.impl.jms.JmsMatsMessage

getMessageSystemTotalWireSize() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage

getMessageSystemTotalWireSize() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

getMessageSystemTotalWireSize() - Method in class io.mats3.impl.jms.JmsMatsMessage

getMessageType() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getMessageType() - Method in class io.mats3.impl.jms.JmsMatsMessage

getMessageType() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.IncomingMessageRepresentationImpl

getMessageType() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.MessageRepresentation

getMessageType() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl

getMessagingModel() - Method in interface io.mats3.serial.MatsTrace.Call.Channel

getMeta() - Method in interface io.mats3.serial.MatsSerializer.SerializedMatsTrace

getMetricDescription() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsMeasurement

getMetricDescription() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsTimingMeasurement

getMetricId() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsMeasurement

getMetricId() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsTimingMeasurement

getName() - Method in interface io.mats3.MatsFactory.FactoryConfig

getName() - Method in interface io.mats3.MatsInitiator

getNanos() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsTimingMeasurement

getNanosCompression() - Method in interface io.mats3.serial.MatsSerializer.SerializedMatsTrace

getNanosDecompression() - Method in interface io.mats3.serial.MatsSerializer.DeserializedMatsTrace

getNanosDeserialization() - Method in interface io.mats3.serial.MatsSerializer.DeserializedMatsTrace

getNanosSerialization() - Method in interface io.mats3.serial.MatsSerializer.SerializedMatsTrace

getNextStage() - Method in class io.mats3.impl.jms.JmsMatsStage

getNodename() - Method in interface io.mats3.MatsFactory.FactoryConfig

Returns a node-specific identifier, that is, a name which is different between different instances of the same app running of different nodes.

getNumberOfCpus() - Method in interface io.mats3.MatsFactory.FactoryConfig

getOrCreateInitiator(String) - Method in class io.mats3.impl.jms.JmsMatsFactory

getOrCreateInitiator(String) - Method in interface io.mats3.MatsFactory

Gets or creates a new Initiator from which to initiate new Mats processes, i.e.

getOrCreateInitiator(String) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

getOrCreateInitiator_internal(String) - Method in class io.mats3.impl.jms.JmsMatsFactory

getOrigin() - Method in interface io.mats3.MatsEndpoint.EndpointConfig

getOrigin() - Method in interface io.mats3.MatsStage.StageConfig

getOrWaitForPoolJmsConnection() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.ConnectionWithSessionPool

getOutgoingMessageCounts() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.InitiatorStats

getOutgoingMessageCounts() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.StageStats

getOutgoingMessages() - Method in interface io.mats3.api.intercept.CommonCompletedContext

getOutgoingMessages() - Method in interface io.mats3.api.intercept.CommonInterceptOutgoingMessagesContext

getOutstandingPromiseCount() - Method in class io.mats3.util.MatsFuturizer

getParentEndpoint() - Method in class io.mats3.impl.jms.JmsMatsStage

getParentEndpoint() - Method in interface io.mats3.MatsStage

getParentFactory() - Method in class io.mats3.impl.jms.JmsMatsEndpoint

getParentFactory() - Method in interface io.mats3.MatsEndpoint

getParentFactory() - Method in interface io.mats3.MatsInitiator

getParentLogger() - Method in class io.mats3.test.TestH2DataSource

getParentLogger() - Method in class io.mats3.util.wrappers.DataSourceWrapper

getParentMatsMessageId() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getParentMatsMessageId() - Method in interface io.mats3.serial.MatsTrace

If this is a child flow of an existing flow, this should return the MatsMessageId of the message whose processing spawned this new flow.

getPassword() - Method in class io.mats3.test.TestH2DataSource

Get the current password.

getPhase() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

getPlatformTransactionManager() - Method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx

getPooledConnection() - Method in class io.mats3.test.TestH2DataSource

getPooledConnection(String, String) - Method in class io.mats3.test.TestH2DataSource

getPrecedingSameStackHeightOutgoingTimestamp() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

Returns the timestamp of the preceding outgoing message on the same stack height as this stage.

getProcessContext() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

getProcessContext() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageInterceptOutgoingMessageContext

getProcessContext() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageInterceptUserLambdaContext

getProcessContext() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageReceivedContext

getProcessResult() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext

getProcessResultCounts() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.StageStats

getReadOnlyFromWrappedDataSource() - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper

getReply() - Method in class io.mats3.util.MatsFuturizer.Reply

getReplyClass() - Method in interface io.mats3.MatsEndpoint.EndpointConfig

getReplyFromSpanId() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

getReplyFromSpanId() - Method in interface io.mats3.serial.MatsTrace.Call

getReplyStack() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

getReplyStack() - Method in interface io.mats3.serial.MatsTrace.Call

getReplyStackHeight() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

getReplyStackHeight() - Method in interface io.mats3.serial.MatsTrace.Call

getReplyTo() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getReplyTo() - Method in class io.mats3.impl.jms.JmsMatsMessage

getResource(Object) - Static method in class io.mats3.impl.jms.JmsMatsContextLocalCallback

Retrieves a ThreadLocal-bound resource, bound with JmsMatsContextLocalCallback.bindResource(Object, Object).

getRunningStageProcessors() - Method in interface io.mats3.MatsStage.StageConfig

getSameHeightEndpointEnteredTimestamp() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getSameHeightEndpointEnteredTimestamp() - Method in interface io.mats3.serial.MatsTrace

getSameHeightOutgoingTimestamp() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getSameHeightOutgoingTimestamp() - Method in interface io.mats3.serial.MatsTrace

getSameStackHeightState() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getSameStackHeightState() - Method in class io.mats3.impl.jms.JmsMatsMessage

getSession() - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler.JmsSessionHolder

getSession() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl

getSession() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple

getSessionHolder(JmsMatsInitiator<?>) - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler

Will be invoked every time an Initiator wants to send a message - it will be returned after the message(s) is sent.

getSessionHolder(JmsMatsStageProcessor<?, ?, ?, ?>) - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler

Will be invoked before the StageProcessor goes into its consumer loop - it will be closed once the Stage is stopped, or if the Session "crashes", i.e.

getSessionHolder(JmsMatsInitiator<?>) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling

getSessionHolder(JmsMatsStageProcessor<?, ?, ?, ?>) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling

getSessionHolder(JmsMatsInitiator<?>) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple

getSessionHolder(JmsMatsStageProcessor<?, ?, ?, ?>) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple

getSessionHolder_internal(JmsMatsTransactionManager.JmsMatsTxContextKey) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling

getSessionHolder_internal(JmsMatsTransactionManager.JmsMatsTxContextKey) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple

getSizeCompressed() - Method in interface io.mats3.serial.MatsSerializer.SerializedMatsTrace

getSizeDecompressed() - Method in interface io.mats3.serial.MatsSerializer.DeserializedMatsTrace

getSizeIncoming() - Method in interface io.mats3.serial.MatsSerializer.DeserializedMatsTrace

getSizeUncompressed() - Method in interface io.mats3.serial.MatsSerializer.SerializedMatsTrace

getSpentQueueTimeNanos() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.StageStats

Note: Only has millisecond resolution, AND is susceptible to time skews between nodes (uses System.currentTimeMillis() on the sending and receiving node).

getStage() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageInterceptContext

getStage() - Method in interface io.mats3.impl.jms.JmsMatsTransactionManager.JmsMatsTxContextKey

getStageConfig() - Method in class io.mats3.impl.jms.JmsMatsStage

getStageConfig() - Method in interface io.mats3.MatsStage

getStageId() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getStageId() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

getStageId() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getStageId() - Method in interface io.mats3.MatsStage.StageConfig

getStageIndex() - Method in interface io.mats3.MatsStage.StageConfig

getStageInitiatedMessages() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext

getStageInterceptor(Class<T>) - Method in interface io.mats3.api.intercept.MatsInterceptable

getStageInterceptor(Class<T>) - Method in class io.mats3.impl.jms.JmsMatsFactory

getStageInterceptor(Class<T>) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

getStageInterceptors() - Method in interface io.mats3.api.intercept.MatsInterceptable

getStageInterceptors() - Method in class io.mats3.impl.jms.JmsMatsFactory

getStageInterceptors() - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

getStagePreprocessAndDeserializeError() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext

getStageRequestMessages() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext

getStageResultMessage() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext

getStages() - Method in class io.mats3.impl.jms.JmsMatsEndpoint

getStages() - Method in interface io.mats3.MatsEndpoint

getStagesMap() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStatsImpl

getStagesStats() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStats

getStagesStats() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStatsImpl

getStageStats(MatsStage<?, ?, ?>) - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStats

getStageStats(MatsStage<?, ?, ?>) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStatsImpl

getStageStats(MatsStage<?, ?, ?>) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor

getStageTotalExecutionTimeNanos() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.StageStats

getStandardTransactionDefinitionFunctionFor(Class<? extends PlatformTransactionManager>) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx

Returns the standard TransactionDefinition Function for the supplied PlatformTransactionManager.

getStartedInstant() - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor.InitiateInterceptContext

getStartedInstant() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageInterceptContext

getStartedNanoTime() - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor.InitiateInterceptContext

getStartedNanoTime() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageInterceptContext

getState() - Method in interface io.mats3.serial.MatsTrace.StackState

getState() - Method in interface io.mats3.test.MatsTestLatch.Result

getStateClass() - Method in interface io.mats3.MatsEndpoint.EndpointConfig

getStateFlow() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getStateFlow() - Method in interface io.mats3.serial.MatsTrace

getStateSerializedSize() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

getStateStack() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getStateStack() - Method in interface io.mats3.serial.MatsTrace

getStateStack_internal() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getString(String) - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getString(String) - Method in class io.mats3.impl.jms.JmsMatsMessage

getString(String) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getString(String) - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

Get String "sideloads" from the incoming message.

getString(String) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getStringKeys() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getStringKeys() - Method in class io.mats3.impl.jms.JmsMatsMessage

getStringKeys() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getStringKeys() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

getStringKeys() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getStyleSheet(Appendable) - Method in interface io.mats3.localinspect.LocalHtmlInspectForMatsFactory

Note: The return from this method is static, and should only be included once per HTML page, no matter how many MatsFactories you display.

getStyleSheet(Appendable) - Method in class io.mats3.localinspect.LocalHtmlInspectForMatsFactoryImpl

Note: The return from this method is static, and should only be included once per HTML page, no matter how many MatsFactories you display.

getSumEnvelopeSerializationAndCompressionNanos() - Method in interface io.mats3.api.intercept.CommonCompletedContext

getSumMessageSystemProductionAndSendNanos() - Method in interface io.mats3.api.intercept.CommonCompletedContext

getSystemMessageId() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage

getSystemMessageId() - Method in class io.mats3.impl.jms.JmsMatsMessage

getSystemMessageId() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getSystemMessageId() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

getSystemMessageId() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getThrowable() - Method in interface io.mats3.api.intercept.CommonCompletedContext

getThrowable() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext

getTimeToLive() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getTimeToLive() - Method in class io.mats3.impl.jms.JmsMatsMessage

getTimeToLive() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getTimeToLive() - Method in interface io.mats3.serial.MatsTrace

getTimingMeasurements() - Method in interface io.mats3.api.intercept.CommonCompletedContext

getTo() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getTo() - Method in class io.mats3.impl.jms.JmsMatsMessage

getTo() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentation

getTo() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl

getTo() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

getTo() - Method in interface io.mats3.serial.MatsTrace.Call

getTo() - Method in interface io.mats3.test.MatsTestBrokerInterface.MatsMessageRepresentation

getTotalCallNumber() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getTotalCallNumber() - Method in interface io.mats3.serial.MatsTrace

"Stack overflow protection" mechanism.

getTotalEndpointProcessingTimeNanos() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStats

getTotalEndpointProcessingTimeNanos() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStatsImpl

getTotalExecutionNanos() - Method in interface io.mats3.api.intercept.CommonCompletedContext

getTotalExecutionTimeNanos() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.InitiatorStats

getTotalPreprocessAndDeserializeNanos() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

getTraceId() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getTraceId() - Method in class io.mats3.impl.jms.JmsMatsMessage

getTraceId() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getTraceId() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

getTraceId() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getTraceId() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getTraceId() - Method in interface io.mats3.serial.MatsTrace

getTraceId() - Method in interface io.mats3.test.MatsTestBrokerInterface.MatsMessageRepresentation

getTraceId() - Method in exception io.mats3.util.MatsFuturizer.MatsFuturizerTimeoutException

getTraceProperty(String, Class<T>) - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getTraceProperty(String, Class<T>) - Method in class io.mats3.impl.jms.JmsMatsMessage

getTraceProperty(String, Class<T>) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

getTraceProperty(String, Class<T>) - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

Retrieves the Mats Trace property with the specified name, deserializing the value to the specified class, using the active MATS serializer.

getTraceProperty(String, Class<T>) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

getTraceProperty(String) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getTraceProperty(String) - Method in interface io.mats3.serial.MatsTrace

Retrieves a property value set by MatsTrace.setTraceProperty(String, Object), refer to ProcessContext.getTraceProperty(String, Class).

getTracePropertyKeys() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

getTracePropertyKeys() - Method in class io.mats3.impl.jms.JmsMatsMessage

getTracePropertyKeys() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

getTracePropertyKeys() - Method in interface io.mats3.serial.MatsTrace

getTransactionContext(JmsMatsTransactionManager.JmsMatsTxContextKey) - Method in interface io.mats3.impl.jms.JmsMatsTransactionManager

Provides an implementation of JmsMatsTransactionManager.TransactionContext.

getTransactionContext(JmsMatsTransactionManager.JmsMatsTxContextKey) - Method in class io.mats3.impl.jms.JmsMatsTransactionManager_Jms

getTransactionContext(JmsMatsTransactionManager.JmsMatsTxContextKey) - Method in class io.mats3.impl.jms.JmsMatsTransactionManager_JmsAndJdbc

getTransactionContext(JmsMatsTransactionManager.JmsMatsTxContextKey) - Method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx

getTransactionIsolationFromWrappedDataSource() - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper

getURL() - Method in class io.mats3.test.TestH2DataSource

Get the current URL.

getUrl() - Method in class io.mats3.test.TestH2DataSource

Get the current URL.

getUser() - Method in class io.mats3.test.TestH2DataSource

Get the current user name.

getUserLambdaNanos() - Method in interface io.mats3.api.intercept.CommonCompletedContext

getWhat() - Method in class io.mats3.impl.jms.JmsMatsMessage

getWrappedObject() - Method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx.DeferredConnectionProxyDataSourceWrapper_InfrastructureProxy

getXAConnection() - Method in class io.mats3.test.TestH2DataSource

getXAConnection(String, String) - Method in class io.mats3.test.TestH2DataSource

goTo(String, Object) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

goTo(String, Object, Object) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

goTo(String, Object) - Method in interface io.mats3.MatsEndpoint.ProcessContext

Sends a message which passes the current call stack over to another endpoint, so that when that endpoint replies, it will return to the endpoint which invoked this endpoint.

goTo(String, Object, Object) - Method in interface io.mats3.MatsEndpoint.ProcessContext

Variation of MatsEndpoint.ProcessContext.goTo(String, Object) method, where the incoming state is sent along.

goTo(String, Object) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

goTo(String, Object, Object) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

H

handleIncomingMessageMatsObject(MatsSerializer<Z>, Class<I>, Z) - Static method in interface io.mats3.impl.jms.JmsMatsStatics

handleIncomingState(MatsSerializer<Z>, Class<S>, MatsTrace.StackState<Z>) - Static method in interface io.mats3.impl.jms.JmsMatsStatics

handleMatsFactoryConcurrencyForTestAndDevelopment(boolean) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

handleMatsTestBrokerInterfacePopulation(boolean) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

handlesMeta(String) - Method in class io.mats3.serial.json.MatsSerializerJson

handlesMeta(String) - Method in interface io.mats3.serial.MatsSerializer

Whether this implementation of MatsSerializer handles the specified "meta".

hashCode() - Method in class io.mats3.impl.jms.JmsMatsEndpoint

hashCode() - Method in class io.mats3.impl.jms.JmsMatsFactory

hashCode() - Method in class io.mats3.impl.jms.JmsMatsMessage

hashCode() - Method in class io.mats3.impl.jms.JmsMatsStage

hashCode() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.IncomingMessageRepresentationImpl

hashCode() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl

hashCode() - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

holdEndpointsUntilFactoryIsStarted() - Method in class io.mats3.impl.jms.JmsMatsFactory

holdEndpointsUntilFactoryIsStarted() - Method in interface io.mats3.MatsFactory

If this method is invoked before any endpoint is created, the endpoints will not start even though MatsEndpoint.finishSetup() is invoked on them, but will wait till MatsFactory.start() is invoked on the factory. This feature should be employed in most setups where the MATS endpoints might use other services or components whose order of creation and initialization are difficult to fully control, e.g.

holdEndpointsUntilFactoryIsStarted() - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

I

id(String, Object) - Method in interface io.mats3.impl.jms.JmsMatsStatics

id(Object) - Method in interface io.mats3.impl.jms.JmsMatsStatics

id(Class<?>) - Method in class io.mats3.test.abstractunit.AbstractMatsTest

IDENTIFICATION - Static variable in class io.mats3.serial.json.MatsSerializerJson

idThis() - Method in class io.mats3.impl.jms.JmsMatsEndpoint

idThis() - Method in class io.mats3.impl.jms.JmsMatsFactory

idThis() - Method in class io.mats3.impl.jms.JmsMatsStage

idThis() - Method in interface io.mats3.impl.jms.JmsMatsStatics

idThis() - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint

ILLEGAL_CALL_FLOWS - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

Log prefix (after JmsMatsStatics.LOG_PREFIX) for flows that are illegal.

IN_MEMORY_TEST_H2_DATABASE_URL - Static variable in class io.mats3.test.TestH2DataSource

IncomingMessageRepresentationImpl(MatsOutgoingMessage.MessageType, String, String, String, String) - Constructor for class io.mats3.localinspect.LocalStatsMatsInterceptor.IncomingMessageRepresentationImpl

init() - Static method in class io.mats3.impl.jms.JmsMatsMessageBrokerSpecifics

INITIAL - Static variable in annotation type io.mats3.spring.MatsClassMapping.Stage

Constant for 0 (zero), the initial Stage's ordinal.

initialize(ConfigurableApplicationContext) - Method in class io.mats3.spring.test.MatsTestContext.MatsSimpleTestInfrastructureContextInitializer

initialize(ConfigurableApplicationContext) - Method in class io.mats3.spring.test.MatsTestDbContext.MatsSimpleTestInfrastructureDbContextInitializer

initiate(MatsInitiator.InitiateLambda) - Method in interface io.mats3.api.intercept.CommonInterceptOutgoingMessagesContext

To add a new message, you may initiate it here.

initiate(MatsInitiator.InitiateLambda) - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor.InitiateInterceptUserLambdaContext

initiate(MatsInitiator.InitiateLambda) - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor.InitiateStartedContext

initiate(MatsInitiator.InitiateLambda) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

initiate(MatsInitiator.InitiateLambda) - Method in interface io.mats3.MatsEndpoint.ProcessContext

Initiates a new message out to an endpoint.

initiate(MatsInitiator.InitiateLambda) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

initiate(MatsInitiator.InitiateLambda) - Method in interface io.mats3.MatsInitiator

Initiates a new message ("request" or "send") out to an endpoint: You provide a lambda which is supplied the MatsInitiator.MatsInitiate instance on which you invoke methods to construct and dispatch messages.

initiate(MatsInitiator.MatsInitiate) - Method in interface io.mats3.MatsInitiator.InitiateLambda

initiateCompleted(MatsInitiateInterceptor.InitiateCompletedContext) - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor

initiateCompleted(MatsInitiateInterceptor.InitiateCompletedContext) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

initiateCompleted(MatsInitiateInterceptor.InitiateCompletedContext) - Method in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

initiateCompleted(MatsInitiateInterceptor.InitiateCompletedContext) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor

initiateInterceptOutgoingMessages(MatsInitiateInterceptor.InitiateInterceptOutgoingMessagesContext) - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor.MatsInitiateInterceptOutgoingMessages

initiateInterceptOutgoingMessages(MatsInitiateInterceptor.InitiateInterceptOutgoingMessagesContext) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor

initiateInterceptUserLambda(MatsInitiateInterceptor.InitiateInterceptUserLambdaContext, MatsInitiator.InitiateLambda, MatsInitiator.MatsInitiate) - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor.MatsInitiateInterceptUserLambda

initiateStarted(MatsInitiateInterceptor.InitiateStartedContext) - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor

Invoked right before user lambda is invoked.

initiateUnchecked(MatsInitiator.InitiateLambda) - Method in interface io.mats3.MatsInitiator

Variant of MatsInitiator.initiate(InitiateLambda) where the two error conditions are raised as unchecked exceptions (But please understand the implications of MatsInitiator.MatsMessageSendRuntimeException!)

initiationTimestamp - Variable in class io.mats3.util.MatsFuturizer.Reply

INITIATOR_ID_WHEN_NO_OUTGOING_MESSAGES - Static variable in interface io.mats3.api.intercept.MatsInterceptable.MatsMetricsInterceptor

When measuring "initiate complete", and the initiation ends up sending no messages, there is no InitiatorId to include.

insertDataIntoDataTable(String) - Method in class io.mats3.test.TestH2DataSource

Inserts the provided 'data' into the SQL Table 'datatable', using a SQL Connection from this DataSource.

insertDataIntoDataTable(Connection, String) - Static method in class io.mats3.test.TestH2DataSource

Inserts the provided 'data' into the SQL Table 'datatable', using the provided SQL Connection.

instaDlqWithRollbackLambda(MessageConsumer, JmsMatsMessageBrokerSpecifics.JmsMatsJmsExceptionThrowingRunnable) - Static method in class io.mats3.impl.jms.JmsMatsMessageBrokerSpecifics

If the MessageConsumer is an ActiveMQMessageConsumer, then it should set it into "0 redeliveries" mode, and then run the provided lambda to rollback the current message, and then re-set the deliveries.

install(MatsInterceptable) - Static method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

Adds the singleton MatsMetricsLoggingInterceptor.INSTANCE as both Initiation and Stage interceptors.

install(MatsInterceptableMatsFactory, MeterRegistry, boolean) - Static method in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

Creates a MatsMicrometerInterceptor employing the provided MeterRegistry, and installs it as a singleton on the provided MatsInterceptableMatsFactory

install(MatsInterceptableMatsFactory) - Static method in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

Creates a MatsMicrometerInterceptor employing the provided globalRegistry, and installs it as a singleton on the provided MatsInterceptableMatsFactory

install(MatsInterceptable) - Static method in class io.mats3.localinspect.LocalStatsMatsInterceptor

Creates an instance of this interceptor and installs it on the provided MatsInterceptable (which most probably is a MatsFactory).

INSTANCE - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

instantiateNewObject(Class<T>) - Method in interface io.mats3.MatsFactory.FactoryConfig

This method is only relevant for tooling, and thus "hidden away" in this config class.

interactive() - Method in interface io.mats3.MatsInitiator.MatsInitiate

Prioritize this Mats flow! Hint to the underlying implementation that a human is actually waiting for the result of a request, and that the flow therefore should be prioritized.

interactive() - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

INTERCEPTOR_CLASS_MATS_LOGGING - Static variable in class io.mats3.impl.jms.JmsMatsFactory

INTERCEPTOR_CLASS_MATS_METRICS - Static variable in class io.mats3.impl.jms.JmsMatsFactory

internalCloseSession(JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.ConnectionWithSessionPool

invoke(Object, Method, Object[]) - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper.DeferredFetchInvocationHandler

io.mats3 - package io.mats3

API for Mats³: Message-based Asynchronous Transactional Staged Stateless Services.

io.mats3.api.intercept - package io.mats3.api.intercept

Extension to the Mats3 API which adds interception capabilities - all operations for initiation and stage processing can be intercepted.

io.mats3.impl.jms - package io.mats3.impl.jms

Java Message Service v1.1 (JMS v1.1) implementation of the Mats3 API and Mats3 Intercept API.

io.mats3.intercept.logging - package io.mats3.intercept.logging

Mats³ interceptor for structured logging over SLF4J, adding several data points using the SLF4J MDC for each initiation, message receive and message send - consists of a single class MatsMetricsLoggingInterceptor, for which the JMS implementation has special support in that if it resides on the classpath, it will autoinstall.

io.mats3.intercept.micrometer - package io.mats3.intercept.micrometer

Mats³ interceptor adding metrics gathering using Spring's Micrometer solution - consists of a single class MatsMicrometerInterceptor, for which the JMS implementation has special support in that if it resides on the classpath, it will autoinstall.

io.mats3.localinspect - package io.mats3.localinspect

Mats³ tool that can output an embeddable HTML describing a MatsFactory and all its endpoints, as well as "local statistics", gathered using a Mats Interceptor.

io.mats3.serial - package io.mats3.serial

Mats³ wire format solution called "MatsTrace", which defines a set of parameters and structures sufficient to represent an envelope carrying Mats messages, as well as a deser-interface "MatsSerializer" which defines methods between MatsTrace and byte arrays - Employed by the Mats³ JMS Implementation.

io.mats3.serial.impl - package io.mats3.serial.impl

An implementation of MatsTrace which uses short-named fields to carry all the needed information - meant to be field-serialized using for example Jackson.

io.mats3.serial.json - package io.mats3.serial.json

Mats³ MatsSerializer implementation using Jackson to serialize between MatsTraceStringImpl and byte arrays - Employed by the Mats³ JMS Implementation.

io.mats3.spring - package io.mats3.spring

Mats³ Spring integration ("SpringConfig"), supplying a set of annotations including @EnableMats to enable bean scanning for @MatsMapping and @MatsClassMapping annotations, simplifying use of Mats³ in a Spring context.

io.mats3.spring.jms.factories - package io.mats3.spring.jms.factories

Tooling for handling your application's configuration of a JMS ConnectionFactory in different scenarios (development, testing, staging, production) - best explained in the class doc of ScenarioConnectionFactoryProducer - do note that this should not be the first thing you delve into when trying out Mats!

io.mats3.spring.jms.tx - package io.mats3.spring.jms.tx

Implementation of JMS Mats's JmsMatsTransactionManager employing Spring's TransactionManager for the data source aspect.

io.mats3.spring.test - package io.mats3.spring.test

Mats³ Spring-specific testing tools, for quickly firing up a test-harness using either JUnit or Jupiter (JUnit 5) - read class doc of MatsTestContext and MatsTestInfrastructureConfiguration.

io.mats3.test - package io.mats3.test

Contains a set of helpful tools for testing: MatsTestBrokerInterface to get DLQ'ed messages, MatsTestHelp for creation of relevant ids, MatsTestLatch for a simple tool to synchronize between the test method and the async Mats endpoints, and TestH2DataSource which is a small wrapper around H2 to create a database with a test table - mainly used by the API Tests to verify SQL transactions.

io.mats3.test.abstractunit - package io.mats3.test.abstractunit

Common code for the modules 'mats-test-junit' and 'mats-test-jupiter' - These abstract classes should not be used directly, but rather utilized through the mentioned implementations.

io.mats3.test.broker - package io.mats3.test.broker

Tool for creating a MQ Broker to easily create a MatsFactory backed by an in-vm MQ Broker, employed by several of the other Mats testing tools - by default uses Apache ActiveMQ, but may be directed to use Apache Artemis instead, or to use an external ActiveMQ or Artemis broker.

io.mats3.test.junit - package io.mats3.test.junit

Mats³ testing tools for JUnit 4.

io.mats3.test.jupiter - package io.mats3.test.jupiter

Mats³ testing tools for Jupiter (JUnit 5).

io.mats3.util - package io.mats3.util

Mats³ Utilities - notably the MatsFuturizer, which provides a bridge from synchronous processes to the highly asynchronous Mats^3 services.

io.mats3.util.wrappers - package io.mats3.util.wrappers

Wrappers for JMS ConnectionFactory and JDBC DataSource - with a special "deferred connection proxy" wrapper which is smart to use as underlying DataSource for the SQL-oriented JmsMatsTransactionManagers, as it elides transactions if the connection is not actually employed within an initiation or stage processing.

isActualConnectionRetrieved() - Method in interface io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper.DeferredConnectionProxy

isAutoStartup() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

isConcurrencyDefault() - Method in interface io.mats3.MatsConfig

isConnectionLive(Connection) - Static method in class io.mats3.impl.jms.JmsMatsMessageBrokerSpecifics

For an ActiveMQ JMS Connection, this method throws JmsMatsException.JmsMatsJmsException if any of the following methods return true: jmsConnection.isClosing() jmsConnection.isClosed() jmsConnection.isTransportFailed()

isHoldEndpointsUntilFactoryIsStarted() - Method in class io.mats3.impl.jms.JmsMatsFactory

isInitial() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.StageStats

isInteractive() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

isInteractive() - Method in class io.mats3.impl.jms.JmsMatsMessage

isInteractive() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

isInteractive() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

This is relevant if stashing or otherwise when a stage is accessing an external system (e.g.

isInteractive() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

isInteractive() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

isInteractive() - Method in interface io.mats3.serial.MatsTrace

isInteractiveConcurrencyDefault() - Method in interface io.mats3.MatsConfig

isNoAudit() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

isNoAudit() - Method in class io.mats3.impl.jms.JmsMatsMessage

isNoAudit() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

isNoAudit() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

Hint to monitoring/logging/auditing systems that this call flow is not very valuable to fully audit, typically because it is just a "getter" of information for display to a user, or is health check request to see if the endpoint is up and answers in a timely manner.

isNoAudit() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

isNoAudit() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

isNoAudit() - Method in interface io.mats3.serial.MatsTrace

isNonPersistent() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

isNonPersistent() - Method in class io.mats3.impl.jms.JmsMatsMessage

isNonPersistent() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

isNonPersistent() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

This is relevant if stashing or otherwise when a stage is accessing an external system (e.g.

isNonPersistent() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

isNonPersistent() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

isNonPersistent() - Method in interface io.mats3.serial.MatsTrace

isProfileOrPropertyPresent(Environment, String...) - Static method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider.StandardSpecificScenarioDecider

isReplyToSubscription() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

isReplyToSubscription() - Method in class io.mats3.impl.jms.JmsMatsMessage

isRunning() - Method in interface io.mats3.MatsConfig

isRunning() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

isSessionOk() - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler.JmsSessionHolder

Shall be invoked at these points, with the action to perform if it raises JmsMatsException.JmsMatsJmsException.

isSessionOk() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl

isSessionOk() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple

isSubscription() - Method in interface io.mats3.MatsEndpoint.EndpointConfig

isTerminatorEndpoint() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStats

isTerminatorEndpoint() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStatsImpl

isToSubscription() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage

isToSubscription() - Method in class io.mats3.impl.jms.JmsMatsMessage

isUserLambdaExceptionLogged() - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext

isWrapperFor(Class<?>) - Method in class io.mats3.test.TestH2DataSource

isWrapperFor(Class<?>) - Method in class io.mats3.util.wrappers.DataSourceWrapper

J

JMS_MSG_PROP_AUDIT - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

JMS_MSG_PROP_DISPATCH_TYPE - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

JMS_MSG_PROP_FROM - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

JMS_MSG_PROP_INITIALIZING_APP - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

JMS_MSG_PROP_INITIATOR_ID - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

JMS_MSG_PROP_MATS_MESSAGE_ID - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

JMS_MSG_PROP_MESSAGE_TYPE - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

JMS_MSG_PROP_TO - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

JMS_MSG_PROP_TRACE_ID - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

JmsMatsContextLocalCallback - Class in io.mats3.impl.jms

JmsMatsContextLocalCallback() - Constructor for class io.mats3.impl.jms.JmsMatsContextLocalCallback

JmsMatsEndpoint<R,S,Z> - Class in io.mats3.impl.jms

The JMS implementation of MatsEndpoint.

JmsMatsException - Exception in io.mats3.impl.jms

Base class for Exceptions thrown around in the JMS implementation of Mats.

JmsMatsException(String) - Constructor for exception io.mats3.impl.jms.JmsMatsException

JmsMatsException(String, Throwable) - Constructor for exception io.mats3.impl.jms.JmsMatsException

JmsMatsException.JmsMatsJmsException - Exception in io.mats3.impl.jms

Thrown if anything goes haywire with the backend implementation, e.g.

JmsMatsException.JmsMatsOverflowRuntimeException - Exception in io.mats3.impl.jms

If we get "stack overflow" or "call overflow", then the sending method will throw this.

JmsMatsException.JmsMatsUndeclaredCheckedExceptionRaisedRuntimeException - Exception in io.mats3.impl.jms

Thrown if a undeclared checked exception propagates out of the user-supplied lambda.

JmsMatsFactory<Z> - Class in io.mats3.impl.jms

JmsMatsFactory.CannotInstantiateClassException - Exception in io.mats3.impl.jms

JmsMatsInternalExecutionContext - Class in io.mats3.impl.jms

This is an internal context object, for execution of initiations and stage processing in JMS-Mats - one instance is made per initiation and per message reception.

JmsMatsJmsException(String) - Constructor for exception io.mats3.impl.jms.JmsMatsException.JmsMatsJmsException

JmsMatsJmsSessionHandler - Interface in io.mats3.impl.jms

Interface for implementing JMS Connection and JMS Session handling.

JmsMatsJmsSessionHandler.JmsSessionHolder - Interface in io.mats3.impl.jms

A "sidecar object" for the JMS Session, so that additional stuff can be bound to it.

JmsMatsJmsSessionHandler_Pooling - Class in io.mats3.impl.jms

Pooling implementation of JmsMatsJmsSessionHandler - upon creation, you decide how Connections are shared for JmsMatsStageProcessors and MatsInitiators.

JmsMatsJmsSessionHandler_Pooling(ConnectionFactory, JmsMatsJmsSessionHandler_Pooling.PoolingKeyInitiator, JmsMatsJmsSessionHandler_Pooling.PoolingKeyStageProcessor) - Constructor for class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling

JmsMatsJmsSessionHandler_Pooling.ConnectionWithSessionPool - Class in io.mats3.impl.jms

JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl - Class in io.mats3.impl.jms

JmsMatsJmsSessionHandler_Pooling.PoolingKeyInitiator - Enum in io.mats3.impl.jms

What kind of sharing of JMS Connections to employ for a JmsMatsInitiator.

JmsMatsJmsSessionHandler_Pooling.PoolingKeyStageProcessor - Enum in io.mats3.impl.jms

What kind of sharing of JMS Connections to employ for a JmsMatsStageProcessor.

JmsMatsJmsSessionHandler_Simple - Class in io.mats3.impl.jms

A dead simple implementation of JmsMatsJmsSessionHandler which does nothing of pooling nor connection sharing.

JmsMatsJmsSessionHandler_Simple(ConnectionFactory) - Constructor for class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple

JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple - Class in io.mats3.impl.jms

JmsMatsMessage<Z> - Class in io.mats3.impl.jms

Holds the entire contents of a "Mats Message" - so that it can be sent later.

JmsMatsMessageBrokerSpecifics - Class in io.mats3.impl.jms

Some small specifics for the underlying JMS Implementation.

JmsMatsOverflowRuntimeException(String) - Constructor for exception io.mats3.impl.jms.JmsMatsException.JmsMatsOverflowRuntimeException

JmsMatsProcessContext<R,S,Z> - Class in io.mats3.impl.jms

The JMS Mats implementation of MatsEndpoint.ProcessContext.

JmsMatsStage<R,S,I,Z> - Class in io.mats3.impl.jms

The JMS implementation of MatsStage.

JmsMatsStage(JmsMatsEndpoint<R, S, Z>, int, String, boolean, Class<I>, Class<S>, MatsEndpoint.ProcessLambda<R, S, I>) - Constructor for class io.mats3.impl.jms.JmsMatsStage

JmsMatsStartStoppable - Interface in io.mats3.impl.jms

JmsMatsStatics - Interface in io.mats3.impl.jms

Common "static" stash, hacked up as an interface to be implemented if you need it.

JmsMatsTransactionManager - Interface in io.mats3.impl.jms

Transactional aspects of the JMS Mats implementation.

JmsMatsTransactionManager.JmsMatsTxContextKey - Interface in io.mats3.impl.jms

Provided to getTransactionContext(...) when a Mats-component fetches the TransactionContext implementation.

JmsMatsTransactionManager.ProcessingLambda - Interface in io.mats3.impl.jms

The lambda that is provided to the JmsMatsTransactionManager for it to provide transactional demarcation around.

JmsMatsTransactionManager.TransactionContext - Interface in io.mats3.impl.jms

Implementors shall do the transactional processing and handle any Throwable that comes out of the JmsMatsTransactionManager.ProcessingLambda by rolling back.

JmsMatsTransactionManager_Jms - Class in io.mats3.impl.jms

Implementation of JmsMatsTransactionManager handling only JMS (getting Connections, and creating Sessions), doing all transactional handling "native", i.e.

JmsMatsTransactionManager_Jms() - Constructor for class io.mats3.impl.jms.JmsMatsTransactionManager_Jms

JmsMatsTransactionManager_Jms.TransactionalContext_Jms - Class in io.mats3.impl.jms

The JmsMatsTransactionManager.TransactionContext implementation for JmsMatsTransactionManager_Jms.

JmsMatsTransactionManager_JmsAndJdbc - Class in io.mats3.impl.jms

Implementation of JmsMatsTransactionManager that in addition to the JMS transaction also handles a JDBC SQL Connection (using only pure java, i.e.

JmsMatsTransactionManager_JmsAndJdbc(DataSource) - Constructor for class io.mats3.impl.jms.JmsMatsTransactionManager_JmsAndJdbc

JmsMatsTransactionManager_JmsAndJdbc.TransactionalContext_JmsAndJdbc - Class in io.mats3.impl.jms

The TransactionContext-implementation for JmsMatsTransactionManager_Jms.

JmsMatsTransactionManager_JmsAndJdbc.TransactionalContext_JmsAndJdbc.MatsSqlCommitOrRollbackFailedException - Exception in io.mats3.impl.jms

Raised if commit or rollback of the SQL Connection failed.

JmsMatsTransactionManager_JmsAndSpringManagedSqlTx - Class in io.mats3.spring.jms.tx

Implementation of JmsMatsTransactionManager that in addition to the JMS transaction keeps a Spring PlatformTransactionManager employing a JDBC DataSource for which it keeps transaction demarcation along with the JMS transaction, by means of "Best Effort 1 Phase Commit".

JmsMatsTransactionManager_JmsAndSpringManagedSqlTx.DeferredConnectionProxyDataSourceWrapper_InfrastructureProxy - Class in io.mats3.spring.jms.tx

Extension of DeferredConnectionProxyDataSourceWrapper which implements InfrastructureProxy.

JmsMatsUndeclaredCheckedExceptionRaisedRuntimeException(String, Throwable) - Constructor for exception io.mats3.impl.jms.JmsMatsException.JmsMatsUndeclaredCheckedExceptionRaisedRuntimeException

JmsSessionHolder_Simple(Connection, Session, MessageProducer) - Constructor for class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple

JmsSessionHolderImpl(JmsMatsTransactionManager.JmsMatsTxContextKey, JmsMatsJmsSessionHandler_Pooling.ConnectionWithSessionPool, Session, MessageProducer) - Constructor for class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl

K

keepTrace(MatsInitiator.KeepTrace) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Hint to the underlying implementation to which level of call and state history the underlying protocol should retain.

keepTrace(MatsInitiator.KeepTrace) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

L

lastStage(Class<I>, MatsEndpoint.ProcessReturnLambda<R, S, I>) - Method in class io.mats3.impl.jms.JmsMatsEndpoint

lastStage(Class<I>, Consumer<? super MatsStage.StageConfig<R, S, I>>, MatsEndpoint.ProcessReturnLambda<R, S, I>) - Method in class io.mats3.impl.jms.JmsMatsEndpoint

lastStage(Class<I>, MatsEndpoint.ProcessReturnLambda<R, S, I>) - Method in interface io.mats3.MatsEndpoint

Adds the last stage to a multi-stage endpoint, which also finishes setup of the endpoint.

lastStage(Class<I>, Consumer<? super MatsStage.StageConfig<R, S, I>>, MatsEndpoint.ProcessReturnLambda<R, S, I>) - Method in interface io.mats3.MatsEndpoint

Variation of MatsEndpoint.lastStage(Class, ProcessReturnLambda) that can be configured "on the fly".

LATE_POPULATE_METHOD_NAME - Static variable in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

LocalHtmlInspectForMatsFactory - Interface in io.mats3.localinspect

Will produce an "embeddable" HTML interface - notice that there are CSS (LocalHtmlInspectForMatsFactory.getStyleSheet(Appendable)), JavaScript (LocalHtmlInspectForMatsFactory.getJavaScript(Appendable)) and HTML (createFactoryReport(Appendable,..)) to include.

LocalHtmlInspectForMatsFactoryImpl - Class in io.mats3.localinspect

Implementation of LocalHtmlInspectForMatsFactory.

LocalStatsMatsInterceptor - Class in io.mats3.localinspect

Interceptor that collects "local stats" for Initiators and Stages of Endpoints, which can be used in conjunction with a MatsFactory report generator, LocalHtmlInspectForMatsFactory.

LocalStatsMatsInterceptor.EndpointStats - Interface in io.mats3.localinspect

LocalStatsMatsInterceptor.EndpointStatsImpl - Class in io.mats3.localinspect

LocalStatsMatsInterceptor.IncomingMessageRepresentation - Interface in io.mats3.localinspect

LocalStatsMatsInterceptor.IncomingMessageRepresentationImpl - Class in io.mats3.localinspect

LocalStatsMatsInterceptor.InitiatorStats - Interface in io.mats3.localinspect

LocalStatsMatsInterceptor.MessageRepresentation - Interface in io.mats3.localinspect

LocalStatsMatsInterceptor.OutgoingMessageRepresentation - Interface in io.mats3.localinspect

LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl - Class in io.mats3.localinspect

LocalStatsMatsInterceptor.StageStats - Interface in io.mats3.localinspect

log - Static variable in class io.mats3.test.abstractunit.AbstractMatsTest

log_init - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

LOG_INIT_NAME - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

LOG_PREFIX - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

LOG_PREFIX - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

LOG_PREFIX - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

log_stage - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

LOG_STAGE_NAME - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

logMeasurement(String, String, String, double, String...) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

logMeasurement(String, String, String, double, String...) - Method in interface io.mats3.MatsEndpoint.ProcessContext

Adds a measurement of a described variable, in a base unit, for this Stage - be sure to understand that the three String parameters are constants for each measurement. To exemplify, you may measure five different things in a Stage, i.e.

logMeasurement(String, String, String, double, String...) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

logMeasurement(String, String, String, double, String...) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Adds a measurement of a described variable, in a base unit, for this Initiation - be sure to understand that the three String parameters are constants for each measurement. To exemplify, you may measure five different things in an Initiation, i.e.

logMeasurement(String, String, String, double, String...) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

logTimingMeasurement(String, String, long, String...) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

logTimingMeasurement(String, String, long, String...) - Method in interface io.mats3.MatsEndpoint.ProcessContext

Same as addMeasurement(..), but specifically for timings - Read that JavaDoc!

Note: It is illegal to use the same 'metricId' for more than one measurement for a given stage, and this also goes between timing measurements and measurements.

logTimingMeasurement(String, String, long, String...) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

logTimingMeasurement(String, String, long, String...) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Same as addMeasurement(..), but specifically for timings - Read that JavaDoc!

Note: It is illegal to use the same 'metricId' for more than one measurement for a given Initiation, and this also goes between timing measurements and measurements.

logTimingMeasurement(String, String, long, String...) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

M

MATS_TEST_BROKER_INTERFACE_CLASSNAME - Static variable in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

MatsBackendException(String) - Constructor for exception io.mats3.MatsInitiator.MatsBackendException

MatsBackendException(String, Throwable) - Constructor for exception io.mats3.MatsInitiator.MatsBackendException

MatsBackendRuntimeException(String) - Constructor for exception io.mats3.MatsInitiator.MatsBackendRuntimeException

MatsBackendRuntimeException(String, Throwable) - Constructor for exception io.mats3.MatsInitiator.MatsBackendRuntimeException

MatsClassMapping - Annotation Type in io.mats3.spring

A class annotated with this repeatable annotation will become a Mats Endpoint, where an instance of the class itself is the State (STO) object for the Endpoint, and each @Stage-annotated method on the class is a stage of the Endpoint.

MatsClassMapping.MatsClassMappings - Annotation Type in io.mats3.spring

MatsClassMapping.Stage - Annotation Type in io.mats3.spring

Each method in the class that shall correspond to a Stage on the Mats endpoint must be annotated with this @Stage annotation.

MatsConfig - Interface in io.mats3

All of MatsFactory, MatsEndpoint and MatsStage have some configurable elements, provided by a config instance, this is the top of that hierarchy.

MatsConfig.StartStoppable - Interface in io.mats3

All three of MatsFactory, MatsEndpoint and MatsStage implements this interface.

MatsEndpoint<R,S> - Interface in io.mats3

Represents a Mats Endpoint - you create instances from the MatsFactory (or use the Spring integration).

MatsEndpoint.DetachedProcessContext - Interface in io.mats3

The part of MatsEndpoint.ProcessContext that exposes the "getter" side of the context, which enables it to be exposed outside of the process lambda.

MatsEndpoint.EndpointConfig<R,S> - Interface in io.mats3

Provides for both configuring the endpoint (before it is started), and introspecting the configuration.

MatsEndpoint.MatsObject - Interface in io.mats3

For the incoming message type, this represents the equivalent of Java's Object - a "generic" incoming message whose type is not yet determined.

MatsEndpoint.MatsRefuseMessageException - Exception in io.mats3

Can be thrown by the MatsEndpoint.ProcessLambda of the MatsStages to denote that it would prefer this message to be instantly put on a Dead Letter Queue (the stage processing, including any database actions, will still be rolled back as with any other exception thrown out of a ProcessLambda).

MatsEndpoint.ProcessContext<R> - Interface in io.mats3

A way for the process stage to communicate with the library, providing methods to invoke a request, send a reply (for multi-stage endpoints, this provides a way to do a "early return"), initiate a new message etc.

MatsEndpoint.ProcessContextWrapper<R> - Class in io.mats3

A base Wrapper for MatsEndpoint.ProcessContext, which simply implements ProcessContext, takes a ProcessContext instance and forwards all calls to that.

MatsEndpoint.ProcessLambda<R,S,I> - Interface in io.mats3

The lambda that shall be provided by the developer for the process stage(s) for the endpoint - provides the context, state and incoming message DTO.

MatsEndpoint.ProcessReturnLambda<R,S,I> - Interface in io.mats3

Specialization of ProcessLambda that makes it possible to do a "return replyDto" at the end of the stage, which is just a convenient way to invoke MatsEndpoint.ProcessContext.reply(Object).

MatsEndpoint.ProcessSingleLambda<R,I> - Interface in io.mats3

Specialization of ProcessLambda which does not have a state, and have the same return-semantics as ProcessReturnLambda - used for single-stage endpoints as these does not have multiple stages to transfer state between.

MatsEndpoint.ProcessTerminatorLambda<S,I> - Interface in io.mats3

Specialization of ProcessLambda which does not have reply specified - used for terminator endpoints.

MatsEndpointSetup - Annotation Type in io.mats3.spring

A method annotated with this repeatable annotation specifies a method that shall set up a (usually) Multi-Staged Mats Endpoint.

MatsEndpointSetup.MatsEndpointSetups - Annotation Type in io.mats3.spring

MatsFactory - Interface in io.mats3

The start point for all interaction with Mats - you need to get hold of an instance of this interface to be able to code and configure Mats endpoints, and to perform initiations like sending a message, perform a request and publish a message.

MatsFactory.ContextLocal - Class in io.mats3

Provides ThreadLocal access to attributes from the MatsInitiator.MatsInitiate initiate context and MatsStage process context - currently MatsFactory.ContextLocal.getAttribute(Class, String...), which can provide you with the transactionally demarcated SQL Connection if the Mats implementation provides such.

MatsFactory.FactoryConfig - Interface in io.mats3

Provides for a way to configure factory-wide elements and defaults.

MatsFactory.MatsFactoryWrapper - Class in io.mats3

A base Wrapper for MatsFactory, which simply implements MatsFactory, takes a MatsFactory instance and forwards all calls to that.

MatsFactory.MatsWrapper<T> - Interface in io.mats3

Base Wrapper interface which Mats-specific Wrappers implements, defining four "wrappee" methods.

MatsFactoryWrapper(MatsFactory) - Constructor for class io.mats3.MatsFactory.MatsFactoryWrapper

Standard constructor, taking the wrapped MatsFactory instance.

MatsFactoryWrapper() - Constructor for class io.mats3.MatsFactory.MatsFactoryWrapper

No-args constructor, which implies that you either need to invoke MatsFactory.MatsFactoryWrapper.setWrappee(MatsFactory) before publishing the instance (making it available for other threads), or override MatsFactory.MatsFactoryWrapper.unwrap() to provide the desired MatsFactory instance.

MatsFuturizer - Class in io.mats3.util

An instance of this class acts as a bridge service between the synchronous world of e.g.

MatsFuturizer(MatsFactory, String, int, int, int) - Constructor for class io.mats3.util.MatsFuturizer

MatsFuturizer.MatsFuturizerTimeoutException - Exception in io.mats3.util

This exception is raised through the CompletableFuture if the timeout specified when getting the CompletableFuture is reached (to get yourself a future, use one of the futurizeXYZ(..) methods).

MatsFuturizer.Promise<T> - Class in io.mats3.util

MatsFuturizer.Reply<T> - Class in io.mats3.util

An instance of this class will be the return value of any CompletableFutures created with the MatsFuturizer.

MatsFuturizerTimeoutException(String, long, String) - Constructor for exception io.mats3.util.MatsFuturizer.MatsFuturizerTimeoutException

MatsInitiateInterceptor - Interface in io.mats3.api.intercept

Implement this interface to intercept Initiations, then register with MatsInterceptable.addInitiationInterceptor(MatsInitiateInterceptor).

MatsInitiateInterceptor.InitiateCompletedContext - Interface in io.mats3.api.intercept

MatsInitiateInterceptor.InitiateInterceptContext - Interface in io.mats3.api.intercept

MatsInitiateInterceptor.InitiateInterceptOutgoingMessagesContext - Interface in io.mats3.api.intercept

MatsInitiateInterceptor.InitiateInterceptUserLambdaContext - Interface in io.mats3.api.intercept

MatsInitiateInterceptor.InitiateStartedContext - Interface in io.mats3.api.intercept

MatsInitiateInterceptor.MatsInitiateInterceptOutgoingMessages - Interface in io.mats3.api.intercept

While still within the initiation context, this interception enables modifying outgoing messages from the user lambda, setting trace properties, adding "sideloads", deleting a message, or initiating additional messages.

MatsInitiateInterceptor.MatsInitiateInterceptUserLambda - Interface in io.mats3.api.intercept

Enables the intercepting of the invocation of the user lambda in an Initiation, with ability to wrap the MatsInitiator.MatsInitiate (and thus modify any request, send or publishes) - or even take over the entire initiation.

MatsInitiateWrapper(MatsInitiator.MatsInitiate) - Constructor for class io.mats3.MatsInitiator.MatsInitiateWrapper

Standard constructor, taking the wrapped MatsInitiator.MatsInitiate instance.

MatsInitiateWrapper() - Constructor for class io.mats3.MatsInitiator.MatsInitiateWrapper

No-args constructor, which implies that you either need to invoke #setWrappee(MatsInitiate) before publishing the instance (making it available for other threads), or override MatsInitiator.MatsInitiateWrapper.unwrap() to provide the desired MatsInitiator.MatsInitiate instance.

MatsInitiator - Interface in io.mats3

Provides the means to get hold of a MatsInitiator.MatsInitiate instance for initiating Mats message flows: You fetch an instance implementing this interface using typically MatsFactory.getDefaultInitiator(), and then invoke MatsInitiator.initiate(InitiateLambda), where the lambda will provide you with the necessary MatsInitiator.MatsInitiate instance on which you have methods to construct and dispatch e.g.

MatsInitiator.InitiateLambda - Interface in io.mats3

@FunctionalInterface for the "initiate lambda" - what you supply to the initiate method.

MatsInitiator.KeepTrace - Enum in io.mats3

A hint to the underlying implementation of how much historic debugging information for the call flow should be retained in the underlying protocol.

MatsInitiator.MatsBackendException - Exception in io.mats3

Will be thrown by the MatsInitiator.initiate(InitiateLambda)-method if it is not possible at this time to establish a connection to the underlying messaging system (e.g.

MatsInitiator.MatsBackendRuntimeException - Exception in io.mats3

Unchecked variant of the MatsInitiator.MatsBackendException, thrown from the MatsInitiator.initiateUnchecked(InitiateLambda) variant of initiate().

MatsInitiator.MatsInitiate - Interface in io.mats3

An implementation of this interface is given to you when you want to initiate a new Mats Flow.

MatsInitiator.MatsInitiateWrapper - Class in io.mats3

A base Wrapper for MatsInitiator.MatsInitiate, which simply implements MatsInitiate, takes a MatsInitiate instance and forwards all calls to that.

MatsInitiator.MatsMessageSendException - Exception in io.mats3

Will be thrown by the MatsInitiator.initiate(InitiateLambda)-method if Mats fails to send the messages after the MatsInitiator.InitiateLambda has been run, any external resource (typically DB) has been committed, and then some situation occurs that makes it impossible to send out messages.

MatsInitiator.MatsMessageSendRuntimeException - Exception in io.mats3

Unchecked variant of the MatsInitiator.MatsMessageSendException, thrown from the MatsInitiator.initiateUnchecked(InitiateLambda) variant of initiate().

MatsInitiator.MessageReference - Interface in io.mats3

Reference information about the outgoing message.

MatsInterceptable - Interface in io.mats3.api.intercept

Specifies methods that an interceptable MatsFactory must provide.

MatsInterceptable.MatsLoggingInterceptor - Interface in io.mats3.api.intercept

Marker interface to denote a logging interceptor.

MatsInterceptable.MatsMetricsInterceptor - Interface in io.mats3.api.intercept

Marker interface to denote a metrics interceptor.

MatsInterceptableMatsFactory - Interface in io.mats3.api.intercept

Combines the interfaces MatsInterceptable and MatsFactory.

MatsMapping - Annotation Type in io.mats3.spring

A method annotated with this repeatable annotation directly becomes a Mats Single-stage Endpoint or a Mats Terminator Endpoint, depending on whether the method specifies a return type, or is void.

MatsMapping.MatsMappings - Annotation Type in io.mats3.spring

MatsMessageSendException(String) - Constructor for exception io.mats3.MatsInitiator.MatsMessageSendException

MatsMessageSendException(String, Throwable) - Constructor for exception io.mats3.MatsInitiator.MatsMessageSendException

MatsMessageSendRuntimeException(String) - Constructor for exception io.mats3.MatsInitiator.MatsMessageSendRuntimeException

MatsMessageSendRuntimeException(String, Throwable) - Constructor for exception io.mats3.MatsInitiator.MatsMessageSendRuntimeException

MatsMetricsLoggingInterceptor - Class in io.mats3.intercept.logging

A logging interceptor that writes loglines to two SLF4J loggers, including multiple pieces of information on the MDC (initiatorId, endpointId and stageIds, and timings and sizes), so that it hopefully is easy to reason about and debug all Mats flows, and to be able to use the logging system (e.g.

MatsMetricsLoggingInterceptor() - Constructor for class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MatsMetricsLoggingInterceptor.Level - Enum in io.mats3.intercept.logging

MatsMicrometerInterceptor - Class in io.mats3.intercept.micrometer

An interceptor that instruments a MatsFactory with metrics using the (Spring) Micrometer framework.

MatsMicrometerInterceptor.SuggestedTimingHistogramsMeterFilter - Class in io.mats3.intercept.micrometer

A MeterFilter that applies a hopefully reasonable histogram to all timing meters.

MatsOutgoingMessage - Interface in io.mats3.api.intercept

Represents an Outgoing Mats Message.

MatsOutgoingMessage.DispatchType - Enum in io.mats3.api.intercept

MatsOutgoingMessage.MatsEditableOutgoingMessage - Interface in io.mats3.api.intercept

MatsOutgoingMessage.MatsSentOutgoingMessage - Interface in io.mats3.api.intercept

MatsOutgoingMessage.MessageType - Enum in io.mats3.api.intercept

MatsProfiles - Interface in io.mats3.spring.jms.factories

Specifies Spring Profiles (and also which Spring Environment variables) that are relevant for Mats when used with conjunction with ScenarioConnectionFactoryProducer and the default configuration of ConfigurableScenarioDecider.

MatsRefuseMessageException(String, Throwable) - Constructor for exception io.mats3.MatsEndpoint.MatsRefuseMessageException

MatsRefuseMessageException(String) - Constructor for exception io.mats3.MatsEndpoint.MatsRefuseMessageException

MatsScenario - Enum in io.mats3.spring.jms.factories

The three different Mats Scenarios that the ScenarioConnectionFactoryWrapper juggles between based on the results of a set of three ScenarioConnectionFactoryWrapper.ScenarioDeciders, with an optional default choice.

MatsSerializer<Z> - Interface in io.mats3.serial

Defines the operations needed serialize and deserialize MatsTraces to and from byte arrays (e.g.

MatsSerializer.DeserializedMatsTrace<Z> - Interface in io.mats3.serial

MatsSerializer.SerializationException - Exception in io.mats3.serial

The methods in this interface shall throw this RuntimeException if they encounter problems.

MatsSerializer.SerializedMatsTrace - Interface in io.mats3.serial

MatsSerializerJson - Class in io.mats3.serial.json

Implementation of MatsSerializer that employs Jackson JSON library for serialization and deserialization, and compress and decompress using Deflater and Inflater.

MatsSerializerJson(int) - Constructor for class io.mats3.serial.json.MatsSerializerJson

Constructs a MatsSerializer, using the specified Compression Level - refer to Deflater's constants and levels.

MatsSimpleTestInfrastructureContextInitializer() - Constructor for class io.mats3.spring.test.MatsTestContext.MatsSimpleTestInfrastructureContextInitializer

MatsSimpleTestInfrastructureDbContextInitializer() - Constructor for class io.mats3.spring.test.MatsTestDbContext.MatsSimpleTestInfrastructureDbContextInitializer

MatsSpringAnnotationRegistration - Class in io.mats3.spring

The BeanPostProcessor-class specified by the @EnableMats annotation.

MatsSpringAnnotationRegistration() - Constructor for class io.mats3.spring.MatsSpringAnnotationRegistration

MatsSpringAnnotationRegistration.MatsSpringConfigException - Exception in io.mats3.spring

Thrown if the setup of a Mats Spring endpoint fails.

MatsSpringAnnotationRegistration.MatsSpringInvocationTargetException - Exception in io.mats3.spring

Thrown if the invocation of a @MatsMapping or @MatsEndpointSetup annotated method raises InvocationTargetException and the underlying exception is not a RuntimeException.

MatsSpringConfigException(String, Throwable) - Constructor for exception io.mats3.spring.MatsSpringAnnotationRegistration.MatsSpringConfigException

MatsSpringConfigException(String) - Constructor for exception io.mats3.spring.MatsSpringAnnotationRegistration.MatsSpringConfigException

MatsSpringInvocationTargetException(String, Throwable) - Constructor for exception io.mats3.spring.MatsSpringAnnotationRegistration.MatsSpringInvocationTargetException

MatsSqlCommitOrRollbackFailedException(String, Throwable) - Constructor for exception io.mats3.impl.jms.JmsMatsTransactionManager_JmsAndJdbc.TransactionalContext_JmsAndJdbc.MatsSqlCommitOrRollbackFailedException

MatsStage<R,S,I> - Interface in io.mats3

A representation of a process stage of a MatsEndpoint.

MatsStage.StageConfig<R,S,I> - Interface in io.mats3

Provides for both configuring the stage (before it is started), and introspecting the configuration.

MatsStageInterceptor - Interface in io.mats3.api.intercept

Implement this interface to intercept Stage Processing, then register with MatsInterceptable.addStageInterceptor(MatsStageInterceptor).

MatsStageInterceptor.MatsStageInterceptOutgoingMessages - Interface in io.mats3.api.intercept

While still within the stage process context, this interception enables modifying outgoing messages from the user lambda, setting trace properties, adding "sideloads", deleting a message, or initiating additional messages.

MatsStageInterceptor.MatsStageInterceptUserLambda - Interface in io.mats3.api.intercept

Enables the intercepting of the invocation of the "user lambda" in a Stage, with ability to wrap the MatsEndpoint.ProcessContext (and thus modify any reply, request, next or initiations) and/or modifying state and message - or even take over the entire stage.

MatsStageInterceptor.StageCommonContext - Interface in io.mats3.api.intercept

Common context elements for stage interception, including all the incoming message/envelope data and metadata.

MatsStageInterceptor.StageCompletedContext - Interface in io.mats3.api.intercept

MatsStageInterceptor.StageCompletedContext.ProcessResult - Enum in io.mats3.api.intercept

The main result of the Stage Processing - if the stage also initiated messages, this will be known by MatsStageInterceptor.StageCompletedContext.getStageInitiatedMessages() being non-empty.

MatsStageInterceptor.StageInterceptContext - Interface in io.mats3.api.intercept

MatsStageInterceptor.StageInterceptOutgoingMessageContext - Interface in io.mats3.api.intercept

MatsStageInterceptor.StageInterceptUserLambdaContext - Interface in io.mats3.api.intercept

MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext - Interface in io.mats3.api.intercept

MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext.StagePreprocessAndDeserializeError - Enum in io.mats3.api.intercept

MatsStageInterceptor.StageReceivedContext - Interface in io.mats3.api.intercept

MatsTestBroker - Interface in io.mats3.test.broker

A special utility class utilized in tests and Mats test infrastructure providing a ConnectionFactory for the test (Jms)MatsFactory - and if relevant also fires up an embedded ("in-VM") ActiveMQ (default) or Artemis message broker.

MatsTestBroker.ActiveMq - Enum in io.mats3.test.broker

Feature flags for the method MatsTestBroker.newActiveMqBroker(ActiveMq...) - which you probably shouldn't do unless you are experimenting with the "mats-examples".

MatsTestBroker.MatsTestBroker_ActiveMq - Class in io.mats3.test.broker

Either creates an in-vm ActiveMQ, or an ActiveMQ ConnectionFactory to an external URL, based on system properties.

MatsTestBroker.MatsTestBroker_Artemis - Class in io.mats3.test.broker

Creates a connection to an Artemis broker.

MatsTestBroker.MatsTestBroker_InVmActiveMq - Class in io.mats3.test.broker

Creates an in-vm ActiveMQ no matter what the properties says.

MatsTestBrokerInterface - Interface in io.mats3.test

Tool that makes it possible to query the underlying broker of a test MatsFactory for messages, in particular "residual" messages and DLQs.

MatsTestBrokerInterface.MatsMessageRepresentation - Interface in io.mats3.test

Representation of the Mats message that sat on the DLQ.

MatsTestBrokerInterface.MatsTestBrokerInterface_JmsMatsFactory - Class in io.mats3.test

MatsTestContext - Annotation Type in io.mats3.spring.test

One-stop-shop for making simple Spring-based integration/unit tests of Mats endpoints (NOT utilizing SQL Connections), automatically importing the configuration .

MatsTestContext.MatsSimpleTestInfrastructureContextInitializer - Class in io.mats3.spring.test

The reason for this obscure way to add the MatsTestInfrastructureConfiguration (as opposed to just point to it with "classes=..") is as follows: Spring's testing integration has this feature where any static inner @Configuration class of the test class is automatically loaded.

MatsTestDbContext - Annotation Type in io.mats3.spring.test

Same as MatsTestContext, but includes a H2 DataSource, as configured by MatsTestInfrastructureDbConfiguration.

MatsTestDbContext.MatsSimpleTestInfrastructureDbContextInitializer - Class in io.mats3.spring.test

The reason for this obscure way to add the MatsTestInfrastructureDbConfiguration (as opposed to just point to it with "classes=..") is as follows: Spring's testing integration has this feature where any static inner @Configuration class of the test class is automatically loaded.

MatsTestH2DataSourceConfiguration() - Constructor for class io.mats3.spring.test.MatsTestInfrastructureDbConfiguration.MatsTestH2DataSourceConfiguration

MatsTestHelp - Class in io.mats3.test

Microscopic helper methods to create Loggers and Ids typically needed when making Mats tests.

MatsTestHelp() - Constructor for class io.mats3.test.MatsTestHelp

MatsTestInfrastructureConfiguration - Class in io.mats3.spring.test

Spring @Configuration class that cooks up the simple test infrastructure, employing a MatsSerializer from the Spring context if available, otherwise creates a default MatsSerializerJson.

MatsTestInfrastructureConfiguration() - Constructor for class io.mats3.spring.test.MatsTestInfrastructureConfiguration

MatsTestInfrastructureDbConfiguration - Class in io.mats3.spring.test

Same as MatsTestInfrastructureConfiguration, but includes a H2 DataSource, as configured by MatsTestInfrastructureDbConfiguration.MatsTestH2DataSourceConfiguration, which uses the TestH2DataSource.createStandard() convenience method.

MatsTestInfrastructureDbConfiguration() - Constructor for class io.mats3.spring.test.MatsTestInfrastructureDbConfiguration

MatsTestInfrastructureDbConfiguration.MatsTestH2DataSourceConfiguration - Class in io.mats3.spring.test

MatsTestLatch - Class in io.mats3.test

Test-utility: Gives a latch-functionality facilitating communication back from typically a Mats Terminator to the main-thread that sent a message to some processor, and is now waiting for the Terminator to get the result.

MatsTestLatch() - Constructor for class io.mats3.test.MatsTestLatch

MatsTestLatch.Result<S,I> - Interface in io.mats3.test

MatsTestProfile - Annotation Type in io.mats3.spring.test

The only thing this annotation does, is to meta-annotate the test class with @ActiveProfiles(MatsProfiles.PROFILE_MATS_TEST).

MatsTrace<Z> - Interface in io.mats3.serial

Together with the MatsSerializer, this interface describes one way to implement a wire-protocol for how Mats communicates.

MatsTrace.Call<Z> - Interface in io.mats3.serial

Represents an entry in the MatsTrace.

MatsTrace.Call.CallType - Enum in io.mats3.serial

Which type of Call this is.

MatsTrace.Call.Channel - Interface in io.mats3.serial

An encapsulation of the stageId/endpointId along with the MatsTrace.Call.MessagingModel the message should be delivered over.

MatsTrace.Call.MessagingModel - Enum in io.mats3.serial

Specifies what type of Messaging Model a 'to' and 'replyTo' is to go over: Queue or Topic.

MatsTrace.KeepMatsTrace - Enum in io.mats3.serial

Specifies how the MatsTrace will handle historic values that are present just for debugging.

MatsTrace.StackState<Z> - Interface in io.mats3.serial

The State instances (of type Z), along with the height of the stack the state relates to.

MatsTraceFieldImpl<Z> - Class in io.mats3.serial.impl

An implementation of MatsTrace which uses fields to hold all state necessary for a Mats flow, including "holders" for the serialization of DTOs and STOs, with type 'Z'.

MatsTraceFieldImpl() - Constructor for class io.mats3.serial.impl.MatsTraceFieldImpl

MatsTraceFieldImpl(String, String, MatsTrace.KeepMatsTrace, boolean, boolean, long, boolean) - Constructor for class io.mats3.serial.impl.MatsTraceFieldImpl

MatsTraceFieldImpl.CallImpl<Z> - Class in io.mats3.serial.impl

Represents an entry in the MatsTrace.

MatsTraceStringImpl - Class in io.mats3.serial.json

Extension of MatsTraceFieldImpl which uses String for Z, meant to use JSON to serialize the DTO and STO payloads.

MAX_NUMBER_OF_DYNAMIC_ENTRIES - Static variable in class io.mats3.localinspect.LocalStatsMatsInterceptor

This is an Out Of Memory avoidance in case of wrongly used initiatorIds.

MAX_NUMBER_OF_METRICS - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

This is a cardinality-explosion-avoidance limit in case of wrongly used initiatorIds.

MAX_STACK_HEIGHT - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

If an outgoing message has MatsTrace.Call.getReplyStackHeight() higher than this (25), the processing will be refused (i.e.

MAX_TOTAL_CALL_NUMBER - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

If an outgoing message has MatsTrace.getTotalCallNumber() higher than this (100), the processing will be refused (i.e.

MDC_INIT_OR_STAGE_ID - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_APP_NAME - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

MDC_MATS_APP_VERSION - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

MDC_MATS_AUDIT - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_CALL_NUMBER - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

MDC_MATS_COMPLETE_OPS_DESCRIPTION - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_COMPLETE_OPS_KEYNAME - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_COMPLETE_OPS_MEASURE_PREFIX - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_COMPLETE_OPS_TIMING_PREFIX - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_COMPLETE_QUANTITY_OUT - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_COMPLETE_SIZE_OUT_TOTAL_WIRE - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_COMPLETE_TIME_DB_COMMIT - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_COMPLETE_TIME_MSGSYS_COMMIT - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_COMPLETE_TIME_OUT - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_COMPLETE_TIME_TOTAL - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_COMPLETE_TIME_TOTAL_PREPROC_AND_DESERIAL - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_COMPLETE_TIME_USER_LAMBDA - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_DISPATCH_TYPE - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_ENDPOINT_COMPLETE_TIME_TOTAL - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_ENDPOINT_COMPLETED - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_FLOW_COMPLETE_TIME_TOTAL - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_FLOW_COMPLETED - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_IN_FROM_APP_NAME - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_IN_FROM_ID - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_IN_MATS_MESSAGE_ID - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_IN_MESSAGE_SYSTEM_ID - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

MDC_MATS_IN_MESSAGE_TYPE - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_IN_SIZE_DATA_SERIAL - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_IN_SIZE_ENVELOPE_SERIAL - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_IN_SIZE_ENVELOPE_WIRE - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_IN_SIZE_STATE_SERIAL - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_IN_SIZE_TOTAL_WIRE - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_IN_TIME_DATA_AND_STATE_DESERIAL - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_IN_TIME_ENVELOPE_DECOMPRESS - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_IN_TIME_ENVELOPE_DESERIAL - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_IN_TIME_MSGSYS_DECONSTRUCT - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_IN_TIME_SINCE_PRECEDING_ENDPOINT_STAGE - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_IN_TIME_SINCE_SENT - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_IN_TIME_TOTAL_PREPROC_AND_DESERIAL - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_INIT - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

MDC_MATS_INIT_APP - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_INIT_ID - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_INITIATE_COMPLETED - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_INTERACTIVE - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_MESSAGE_RECEIVED - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_MESSAGE_SENT - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_OUT_FROM_ID - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_OUT_MATS_MESSAGE_ID - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

MDC_MATS_OUT_MATS_MESSAGE_ID - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_OUT_MESSAGE_SYSTEM_ID - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_OUT_SIZE_DATA_SERIAL - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_OUT_SIZE_ENVELOPE_SERIAL - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_OUT_SIZE_ENVELOPE_WIRE - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_OUT_SIZE_TOTAL_WIRE - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_OUT_TIME_ENVELOPE_COMPRESS - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_OUT_TIME_ENVELOPE_PRODUCE - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_OUT_TIME_ENVELOPE_SERIAL - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_OUT_TIME_MSGSYS - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_OUT_TIME_TOTAL - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_OUT_TO_ID - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_PERSISTENT - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_PROCESS_RESULT - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_STAGE - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

MDC_MATS_STAGE_COMPLETED - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_MATS_STAGE_ID - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

MDC_MATS_STAGE_INDEX - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

MDC_MATS_VERSION - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MDC_TRACE_ID - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

MDC_TRACE_ID - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

MEASURE_EXEC_OP_PREFIX - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

META_KEY_POSTFIX - Static variable in interface io.mats3.serial.MatsSerializer

The key postfix that should be used for the "meta" key on which the meta value from MatsSerializer.serializeMatsTrace(MatsTrace) should be stored.

methodInvoked(boolean, DeferredConnectionProxyDataSourceWrapper.DeferredConnectionProxy, Connection, Method, Object[], Object) - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper

Override if you want to know about every method invoked on the DeferredConnectionProxyDataSourceWrapper.DeferredConnectionProxy, its arguments and its return value, and whether it was the proxy or the actual Connection that answered.

MQ_NAME_REPLACE_PATTERN - Static variable in class io.mats3.util.SanitizeMqNames

ms(long) - Static method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

Converts nanos to millis with a sane number of significant digits ("3.5" significant digits), but assuming that this is not used to measure things that take less than 0.001 milliseconds (in which case it will be "rounded" to 0.0001, 1e-4, as a special value).

ms(double) - Static method in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor.SuggestedTimingHistogramsMeterFilter

ms3(double) - Method in interface io.mats3.impl.jms.JmsMatsStatics

Truncate milliseconds to 3 decimals.

msgLog_AddMsgMdcs(MatsOutgoingMessage.MatsSentOutgoingMessage, Runnable) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

msgLog_CreateMsgLogLine(String, MatsOutgoingMessage.MatsSentOutgoingMessage) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

msS(long) - Static method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

N

newActiveMqBroker(MatsTestBroker.ActiveMq...) - Static method in interface io.mats3.test.broker.MatsTestBroker

Note: This is most probably not what you want to use in a testing scenario - for this you want to use the method MatsTestBroker class directly, using its MatsTestBroker.create() method.

This method is publicly available for examples and experiments, and provide a way to create an ActiveMQ broker with some Mats optimizations, with a single method call.

newInstance(Class<T>) - Method in class io.mats3.serial.json.MatsSerializerJson

newInstance(Class<T>) - Method in interface io.mats3.serial.MatsSerializer

Will return a new instance of the requested type.

next(Object) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

next(Object) - Method in interface io.mats3.MatsEndpoint.ProcessContext

Sends a message which passes the control to the next stage of a multi-stage endpoint.

next(Object) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

nextDirect(Object) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

nextDirect(Object) - Method in interface io.mats3.MatsEndpoint.ProcessContext

Specialized, less resource demanding, and faster "direct" variant of MatsEndpoint.ProcessContext.next(Object) which executes the next stage of a multi-stage endpoint within the same stage processor and transactional demarcation that this stage is in - that is, there is no actual message sent.

nextDirect(Object) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

NO_CONFIG - Static variable in interface io.mats3.MatsFactory

Simple Consumer<MatsConfig>-implementation that does nothing, for use where you e.g.

NO_INVOCATION_POINT - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

noAudit() - Method in interface io.mats3.MatsInitiator.MatsInitiate

Marks this Mats flow as not relevant for auditing.

noAudit() - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

nonPersistent() - Method in interface io.mats3.MatsInitiator.MatsInitiate

Enable unreliable, but fast, messaging! Hint to the underlying implementation that it does not matter that much if this message is lost.

nonPersistent(long) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Same as MatsInitiator.MatsInitiate.nonPersistent(), but you can set a time-to-live too.

nonPersistent() - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

nonPersistent(long) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

NULLED - Static variable in interface io.mats3.serial.MatsTrace

String employed as return value for "debug only" fields which may as well be null - by setting them to null, we conserve time and space in the serialization (For JSON, even the field itself is not serialized if the value is null).

NUMBER_OF_MILLIS_BETWEEN_SUPPRESSION_LOG - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

O

onContextClosedEvent(ContextClosedEvent) - Method in class io.mats3.spring.MatsSpringAnnotationRegistration

ContextClosedEvent runs pretty much as the first step in the Spring life cycle stopping process: Stop the MatsFactory, which will stop all MATS Endpoints, which will have them release their JMS resources - and then the MatsFactory will clean out the JmsMatsJmsSessionHandler.

onContextRefreshedEvent(ContextRefreshedEvent) - Method in class io.mats3.spring.MatsSpringAnnotationRegistration

ContextRefreshedEvent runs pretty much as the latest step in the Spring life cycle starting process: Processes all MatsMapping and MatsEndpointSetup annotations, then starts the MatsFactory, which will start any "hanging" MATS Endpoints, which will then start consuming messages.

OutgoingMessageRepresentationImpl(MatsOutgoingMessage.MessageType, String, Class<?>, String, String) - Constructor for class io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl

outputMeasurementLogline(Logger, String, String, String, String, String, String, String[]) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

outputMeasurementsLoglines(Logger, CommonCompletedContext) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

overrideInitializationTimestamp(long) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

NOTICE! This is NOT meant for public usage!

P

partTraceId() - Static method in class io.mats3.util.RandomString

performWithinTransaction() - Method in interface io.mats3.impl.jms.JmsMatsTransactionManager.ProcessingLambda

postConstruct() - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

If created as a @Bean, thus sitting directly in the Spring context, this class relies on Spring property injection and @PostConstruct being run.

postConstructForFactoryBean(Environment, ApplicationContext) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

If you construct this bean using a Spring FactoryBean (e.g.

postProcessAfterInitialization(Object, String) - Method in class io.mats3.spring.MatsSpringAnnotationRegistration

postProcessBeforeInitialization(Object, String) - Method in class io.mats3.spring.MatsSpringAnnotationRegistration

prepareTestInstance(TestContext) - Method in class io.mats3.spring.test.SpringInjectRulesAndExtensions.SpringInjectRulesAndExtensionsTestExecutionListener

Performs dependency injection on Rule and @RegisterExtension fields in test-class as supplied by testContext.

process(MatsEndpoint.ProcessContext<R>, S, I) - Method in interface io.mats3.MatsEndpoint.ProcessLambda

process(MatsEndpoint.ProcessContext<R>, S, I) - Method in interface io.mats3.MatsEndpoint.ProcessReturnLambda

process(MatsEndpoint.ProcessContext<R>, I) - Method in interface io.mats3.MatsEndpoint.ProcessSingleLambda

process(MatsEndpoint.ProcessContext<Void>, S, I) - Method in interface io.mats3.MatsEndpoint.ProcessTerminatorLambda

ProcessContextWrapper(MatsEndpoint.ProcessContext<R>) - Constructor for class io.mats3.MatsEndpoint.ProcessContextWrapper

Standard constructor, taking the wrapped MatsEndpoint.ProcessContext instance.

ProcessContextWrapper() - Constructor for class io.mats3.MatsEndpoint.ProcessContextWrapper

No-args constructor, which implies that you either need to invoke #setWrappee(ProcessContext) before publishing the instance (making it available for other threads), or override MatsEndpoint.ProcessContextWrapper.unwrap() to provide the desired MatsEndpoint.ProcessContext instance.

produceAndSendMsgSysMessages(Logger, JmsMatsJmsSessionHandler.JmsSessionHolder, JmsMatsFactory<Z>, List<JmsMatsMessage<Z>>) - Method in interface io.mats3.impl.jms.JmsMatsStatics

Send a bunch of JmsMatsMessages.

produceMessage(MatsOutgoingMessage.DispatchType, long, MatsSerializer<Z>, MatsTrace<Z>, Object, Object, Object, HashMap<String, Object>, HashMap<String, byte[]>, HashMap<String, String>) - Static method in class io.mats3.impl.jms.JmsMatsMessage

NOTE: The Maps are copied/cloned out, so invoker can do whatever he feels like with them afterwards.

PROFILE_MATS_LOCALHOST - Static variable in interface io.mats3.spring.jms.factories.MatsProfiles

If this Spring Profile ("mats-localhost") is active, the ConnectionFactory specified by ScenarioConnectionFactoryProducer#withLocalhostConnectionFactory(ConnectionFactoryProvider) will be used.

PROFILE_MATS_LOCALVM - Static variable in interface io.mats3.spring.jms.factories.MatsProfiles

If this Spring Profile ("mats-localvm") is active, the ConnectionFactory specified by ScenarioConnectionFactoryProducer#withLocalVmConnectionFactory(ConnectionFactoryProvider) will be used.

PROFILE_MATS_MOCKS - Static variable in interface io.mats3.spring.jms.factories.MatsProfiles

Suggested Profile name ("mats-mocks") (or Profile name prefix if you want to divide the mocks into sets) to use when you mock out project-external collaborator Mats Endpoints for use in the "LocalVM" scenario.

PROFILE_MATS_REGULAR - Static variable in interface io.mats3.spring.jms.factories.MatsProfiles

If this Spring Profile ("mats-regular") is active, the ConnectionFactory specified by ScenarioConnectionFactoryProducer#withRegularConnectionFactory(ConnectionFactoryProvider) will be used.

PROFILE_MATS_TEST - Static variable in interface io.mats3.spring.jms.factories.MatsProfiles

Profile name ("mats-test") that is a synonym to MatsProfiles.PROFILE_MATS_LOCALVM wrt.

PROFILE_PRODUCTION - Static variable in interface io.mats3.spring.jms.factories.MatsProfiles

Common Profile name ("production") that is a synonym to MatsProfiles.PROFILE_MATS_REGULAR wrt.

PROFILE_STAGING - Static variable in interface io.mats3.spring.jms.factories.MatsProfiles

Common Profile name ("staging") that is a synonym to MatsProfiles.PROFILE_MATS_REGULAR wrt.

Promise(String, String, String, String, long, long, Class<T>, CompletableFuture<MatsFuturizer.Reply<T>>) - Constructor for class io.mats3.util.MatsFuturizer.Promise

publish(Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Sends a message to a SubscriptionTerminator, employing the publish/subscribe pattern instead of message queues (topic in JMS terms).

publish(Object, Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Variation of the MatsInitiator.MatsInitiate.publish(Object) method, where the incoming state is sent along.

publish(Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

publish(Object, Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

putInterceptContextAttribute(String, Object) - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext

Set an attribute on this particular interception, which is shared between the different stages of interception, and also between all interceptors - use some namespacing to avoid accidental collisions.

Q

QUANTITY_EXEC_OUT_DESC - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

QUANTITY_EXEC_OUT_NAME - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

R

RANDOM_ALPHABET - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

randomCorrelationId() - Static method in class io.mats3.util.RandomString

According to the internet, there are ~7.5e18 grains of sand on all the beaches on earth.

randomId() - Static method in class io.mats3.test.MatsTestHelp

randomString(int) - Method in interface io.mats3.impl.jms.JmsMatsStatics

RandomString - Class in io.mats3.util

If you need a random string for a part of the traceId (Read NOTE about traceIds!), use this class instead of UUID, because UUID has low entropy density with only 4 bits per character, and dashes.

RandomString() - Constructor for class io.mats3.util.RandomString

randomString(int) - Static method in class io.mats3.util.RandomString

release() - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler.JmsSessionHolder

For Initiators: This returns the JmsSessionHolder to the Session Pool for the underlying Connection.

release() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl

release() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple

remove(int) - Method in class io.mats3.impl.jms.JmsMatsEndpoint

remove(MatsInterceptable) - Static method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

Removes the singleton MatsMetricsLoggingInterceptor.INSTANCE as both Initiation and Stage interceptors.

remove(int) - Method in interface io.mats3.MatsEndpoint

Should most probably only be used for testing!

First invokes stop(gracefulShutdownMillis), and if successful removes the endpoint from its MatsFactory.

removeInitiationInterceptor(MatsInitiateInterceptor) - Method in interface io.mats3.api.intercept.MatsInterceptable

removeInitiationInterceptor(MatsInitiateInterceptor) - Method in class io.mats3.impl.jms.JmsMatsFactory

removeInitiationInterceptor(MatsInitiateInterceptor) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

removeSessionHolderFromPool_And_DitchPoolIfEmpty(JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.ConnectionWithSessionPool

removeStageInterceptor(MatsStageInterceptor) - Method in interface io.mats3.api.intercept.MatsInterceptable

removeStageInterceptor(MatsStageInterceptor) - Method in class io.mats3.impl.jms.JmsMatsFactory

removeStageInterceptor(MatsStageInterceptor) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

reply(Object) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

reply(R) - Method in interface io.mats3.MatsEndpoint.ProcessContext

Sends a reply to the requesting service.

reply(R) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

Reply(MatsEndpoint.DetachedProcessContext, T, long) - Constructor for class io.mats3.util.MatsFuturizer.Reply

reply - Variable in class io.mats3.util.MatsFuturizer.Reply

replyTo(String, Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Specified which MATS Endpoint the reply of the invoked Endpoint should go to.

replyTo(String, Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

replyToSubscription(String, Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate

A "pub-sub" variant of replyTo, where the reply will go to the specified endpointId which must be a SubscriptionTerminator.

replyToSubscription(String, Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

request(String, Object) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

request(String, Object) - Method in interface io.mats3.MatsEndpoint.ProcessContext

Sends a request message, meaning that the specified endpoint will be invoked, with the reply-to endpointId set to the next stage in the multi-stage endpoint.

request(String, Object) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

request(Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate

The standard request initiation method: All of from, to and replyTo must be set.

request(Object, Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Variation of the request initiation method, where the incoming state is sent along.

request(Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

request(Object, Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

resolve(Object, Object) - Method in class io.mats3.test.MatsTestLatch

When this method is invoked, the waiting threads will be released - this variant does not take the ProcessContext, use the other one!

resolve(MatsEndpoint.DetachedProcessContext, Object, Object) - Method in class io.mats3.test.MatsTestLatch

When this method is invoked, the waiting threads will be released.

retrieveDefaultAutoCommitAndTransactionIsolationAndReadOnlyValues(Connection) - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper

Rule_Mats - Class in io.mats3.test.junit

ClassRule which provides a full Mats harness for unit testing by creating MatsFactory utilizing an in-vm Active MQ broker, and optionally a TestH2DataSource for database tests.

Rule_Mats(MatsSerializer<String>) - Constructor for class io.mats3.test.junit.Rule_Mats

Rule_Mats(MatsSerializer<String>, DataSource) - Constructor for class io.mats3.test.junit.Rule_Mats

Rule_MatsEndpoint<R,I> - Class in io.mats3.test.junit

Rule to create a single staged endpoint whose reply/processor can be changed throughout its life, i.e.

Rule_MatsGeneric<Z> - Class in io.mats3.test.junit

Similar to Rule_Mats, provides a full Mats harness for unit testing by creating MatsFactory utilizing an in-vm Active MQ broker.

Rule_MatsGeneric(MatsSerializer<Z>) - Constructor for class io.mats3.test.junit.Rule_MatsGeneric

Rule_MatsGeneric(MatsSerializer<Z>, DataSource) - Constructor for class io.mats3.test.junit.Rule_MatsGeneric

S

SanitizeMqNames - Class in io.mats3.util

Utility class for replacing dodgy characters from queue/topic names, and names in general, in the Message Broker world - it is quite restrictive, replacing any character not in [a-z,A-Z,0-9,.,_,-] (lower alpha, upper alpha, digits, dot, underscore, minus/dash) with '_'.

SanitizeMqNames() - Constructor for class io.mats3.util.SanitizeMqNames

sanitizeName(String) - Static method in class io.mats3.util.SanitizeMqNames

Sanitizes the input, only allowing [a-z,A-Z,0-9,.,-,_] (last being dot, minus, underscore)

scenarioActive(Environment) - Method in interface io.mats3.spring.jms.factories.ConfigurableScenarioDecider.SpecificScenarioDecider

Decides whether a specific Scenario is active.

scenarioActive(Environment) - Method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider.StandardSpecificScenarioDecider

ScenarioConnectionFactoryProducer - Class in io.mats3.spring.jms.factories

Provides a factory for a Spring-integrated Wrapper/Facade around a JMS ConnectionFactory, which in addition to supporting the production setup, also facilitates the development situation where you often want to run against either an in-vm MQ Broker or against a MQ Broker running on localhost, and also integrates with the "mats-spring-test" integration test library where when run with the MatsTestProfile you will most probably want an in-vm setup (typically mocking up the project-external Mats endpoints that the tested endpoints collaborate with).

ScenarioConnectionFactoryProducer() - Constructor for class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer

ScenarioConnectionFactoryWrapper - Class in io.mats3.spring.jms.factories

A ConnectionFactoryWrapper which lazily decides which of the three MatsScenarios are active, and produces the wrapper-target ConnectionFactory based on that - you most probably want to use ScenarioConnectionFactoryProducer to make an instance of this class, but you can configure it directly too.

ScenarioConnectionFactoryWrapper(ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider, ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider, ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider, ScenarioConnectionFactoryWrapper.ScenarioDecider) - Constructor for class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

Constructor taking ScenarioConnectionFactoryWrapper.ConnectionFactoryProviders for each of the three MatsScenarios and a ScenarioConnectionFactoryWrapper.ScenarioDecider to decide which of these to employ - you most probably want to use ScenarioConnectionFactoryProducer to make one of these.

ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider - Interface in io.mats3.spring.jms.factories

A ConnectionFactory provider which can throw Exceptions - if it returns a ConnectionFactoryWithStartStopWrapper, start() and stop() will be invoked on that, read more on its JavaDoc.

ScenarioConnectionFactoryWrapper.CouldNotGetConnectionFactoryFromProviderException - Exception in io.mats3.spring.jms.factories

ScenarioConnectionFactoryWrapper.CouldNotStartConnectionFactoryWithStartStopWrapperException - Exception in io.mats3.spring.jms.factories

ScenarioConnectionFactoryWrapper.CouldNotStopConnectionFactoryWithStartStopWrapperException - Exception in io.mats3.spring.jms.factories

ScenarioConnectionFactoryWrapper.ScenarioDecider - Interface in io.mats3.spring.jms.factories

We need a way to decide between the three different MatsScenarios.

send(Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Sends a message to an endpoint, without expecting any reply ("fire-and-forget").

send(Object, Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Variation of the MatsInitiator.MatsInitiate.send(Object) method, where the incoming state is sent along.

send(Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

send(Object, Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

SerializationException(String) - Constructor for exception io.mats3.serial.MatsSerializer.SerializationException

SerializationException(String, Throwable) - Constructor for exception io.mats3.serial.MatsSerializer.SerializationException

serializeMatsTrace(MatsTrace<String>) - Method in class io.mats3.serial.json.MatsSerializerJson

serializeMatsTrace(MatsTrace<Z>) - Method in interface io.mats3.serial.MatsSerializer

Used for serializing the MatsTrace to a byte array.

serializeObject(Object) - Method in class io.mats3.serial.json.MatsSerializerJson

serializeObject(Object) - Method in interface io.mats3.serial.MatsSerializer

Used for serializing STOs and DTOs into type Z, typically String.

setApplicationContext(ApplicationContext) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

setApplicationContext(ApplicationContext) - Method in class io.mats3.spring.MatsSpringAnnotationRegistration

setAttribute(String, Object) - Method in interface io.mats3.MatsConfig

Sets an attribute for this entity (factory, endpoint, stage) - can e.g.

setAttribute(String, Object) - Method in interface io.mats3.MatsEndpoint.EndpointConfig

setAttribute(String, Object) - Method in interface io.mats3.MatsFactory.FactoryConfig

setAttribute(String, Object) - Method in interface io.mats3.MatsStage.StageConfig

setBeanName(String) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

setConcurrency(int) - Method in interface io.mats3.MatsConfig

Changes the default concurrency of the Factory, or of the endpoint (which defaults to the concurrency of the MatsFactory), or of the process stage (which defaults to the concurrency of the MatsEndpoint).

setConcurrency(int) - Method in interface io.mats3.MatsEndpoint.EndpointConfig

setConcurrency(int) - Method in interface io.mats3.MatsFactory.FactoryConfig

setConcurrency(int) - Method in interface io.mats3.MatsStage.StageConfig

setConcurrencyWithLog(Logger, String, Supplier<Integer>, Supplier<Boolean>, Consumer<Integer>, int) - Method in interface io.mats3.impl.jms.JmsMatsStatics

Set concurrency on entity, printing log

setConnectionProxy(DeferredConnectionProxyDataSourceWrapper.DeferredConnectionProxy) - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper.DeferredFetchInvocationHandler

setCurrentContext(Object) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl

setDbCommitNanos(long) - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext

setDebugInfo(String, String, String, String) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

setDebugInfo(String, String, String, String) - Method in interface io.mats3.serial.MatsTrace.Call

Can only be set once.

setDefaultKeepTrace(MatsInitiator.KeepTrace) - Method in class io.mats3.impl.jms.JmsMatsFactory

Sets the default KeepTrace if the initiation doesn't set one itself.

setDefaultScenario(Supplier<MatsScenario>) - Method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider

setDescription(String) - Method in class io.mats3.test.TestH2DataSource

Set the description.

setEnvironment(Environment) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

setEnvironment(Environment) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

setExtraState(String, Z) - Method in interface io.mats3.serial.MatsTrace.StackState

Sets "extra state" on this StackState.

setInitiateTraceIdModifier(Function<String, String>) - Method in interface io.mats3.MatsFactory.FactoryConfig

Sets a Function that may modify the TraceId of Mats flows that are initiated "from the outside", i.e.

setInteractiveConcurrency(int) - Method in interface io.mats3.MatsConfig

Like MatsConfig.setConcurrency(int), but changes the "interactive concurrency" specifically - this is relevant for the Mats Flows that are initiated with the interactive flag set.

setInteractiveConcurrency(int) - Method in interface io.mats3.MatsEndpoint.EndpointConfig

setInteractiveConcurrency(int) - Method in interface io.mats3.MatsFactory.FactoryConfig

setInteractiveConcurrency(int) - Method in interface io.mats3.MatsStage.StageConfig

setLocalhostDecider(ConfigurableScenarioDecider.SpecificScenarioDecider) - Method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider

setLocalVmDecider(ConfigurableScenarioDecider.SpecificScenarioDecider) - Method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider

setLoginTimeout(int) - Method in class io.mats3.test.TestH2DataSource

setLoginTimeout(int) - Method in class io.mats3.util.wrappers.DataSourceWrapper

setLogWriter(PrintWriter) - Method in class io.mats3.test.TestH2DataSource

setLogWriter(PrintWriter) - Method in class io.mats3.util.wrappers.DataSourceWrapper

setMatsDestinationPrefix(String) - Method in interface io.mats3.MatsFactory.FactoryConfig

Sets the prefix that should be applied to the endpointIds to get queue or topic name in the underlying messaging system - the default is "mats.".

setMatsFactory(MatsFactory) - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint

Set the MatsFactory of this class AbstractMatsTestEndpoint._matsFactory.

setMatsFactory(MatsFactory) - Method in class io.mats3.test.junit.Rule_MatsEndpoint

Sets the internal MatsFactory to be utilized for the creation of this endpoint.

setMatsFactory(MatsFactory) - Method in class io.mats3.test.jupiter.Extension_MatsEndpoint

Sets the internal MatsFactory to be utilized for the creation of this endpoint.

setMatsTraceKey(String) - Method in interface io.mats3.MatsFactory.FactoryConfig

Sets the key name on which to store the "wire representation" of the Mats message if the underlying mechanism uses some kind of Map - the default is "mats:trace".

setMessageSystemCommitNanos(long) - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext

setName(String) - Method in interface io.mats3.MatsFactory.FactoryConfig

Sets the name of the MatsFactory, default is "" (empty string).

setNodename(String) - Method in interface io.mats3.MatsFactory.FactoryConfig

Sets the nodename that MatsFactory.FactoryConfig.getNodename() should return.

setOrigin(String) - Method in interface io.mats3.MatsEndpoint.EndpointConfig

Sets the origin for this Endpoint, i.e.

setOrigin(String) - Method in interface io.mats3.MatsStage.StageConfig

Sets the origin for this Stage, i.e.

setOutgoingTimestamp(long) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

setOutgoingTimestamp(long) - Method in interface io.mats3.serial.MatsTrace

Shall be invoked after adding the outgoing call, immediately before serializing the outgoing MatsTrace.

setPassword(String) - Method in class io.mats3.test.TestH2DataSource

Set the current password.

setPasswordChars(char[]) - Method in class io.mats3.test.TestH2DataSource

Set the current password in the form of a char array.

setProcessLambda(MatsEndpoint.ProcessSingleLambda<R, I>) - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint

Specify the processing lambda to be executed by the endpoint aka the endpoint logic.

setProcessLambda(MatsEndpoint.ProcessSingleLambda<R, I>) - Method in class io.mats3.test.junit.Rule_MatsEndpoint

setProcessLambda(MatsEndpoint.ProcessSingleLambda<R, I>) - Method in class io.mats3.test.jupiter.Extension_MatsEndpoint

setRegularDecider(ConfigurableScenarioDecider.SpecificScenarioDecider) - Method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider

setSameStackHeightExtraState(String, Object) - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsEditableOutgoingMessage

An interceptor might need to add state to an outgoing message which will be present on incoming message of the next stage of a multi-stage endpoint - i.e.

setSameStackHeightExtraState(String, Object) - Method in class io.mats3.impl.jms.JmsMatsMessage

setSqlTxConnectionSuppliers(Supplier<Connection>, Supplier<Boolean>) - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext

If the current JmsMatsTransactionManager is managing a SQL Connection, then it SHALL set a way to get the current transactional SQL Connection, and a way to determine whether the SQL Connection was actually employed (if this is not possible to determine, then return whether it was gotten).

setStageEnteredTimestamp(long) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

setStageEnteredTimestamp(long) - Method in interface io.mats3.serial.MatsTrace

Invoke this as early as possible on the reception of a message.

setTraceProperty(String, Object) - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsEditableOutgoingMessage

Set trace property.

setTraceProperty(String, Object) - Method in class io.mats3.impl.jms.JmsMatsMessage

setTraceProperty(String, Object) - Method in class io.mats3.impl.jms.JmsMatsProcessContext

setTraceProperty(String, Object) - Method in interface io.mats3.MatsEndpoint.ProcessContext

Adds a property that will "stick" with the Mats Trace from this call on out.

setTraceProperty(String, Object) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

setTraceProperty(String, Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Adds a property that will "stick" with the call flow from this call on out.

setTraceProperty(String, Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

setTraceProperty(String, Z) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

setTraceProperty(String, Z) - Method in interface io.mats3.serial.MatsTrace

Sets a trace property, refer to ProcessContext.setTraceProperty(String, Object).

setURL(String) - Method in class io.mats3.test.TestH2DataSource

Set the current URL.

setUrl(String) - Method in class io.mats3.test.TestH2DataSource

Set the current URL.

setUser(String) - Method in class io.mats3.test.TestH2DataSource

Set the current user name.

setUserLambdaExceptionLogged() - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext

setWrappee(MatsEndpoint.ProcessContext<R>) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

Sets the wrapped MatsEndpoint.ProcessContext, e.g.

setWrappee(MatsFactory) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

Sets the wrapped MatsFactory, e.g.

setWrappee(T) - Method in interface io.mats3.MatsFactory.MatsWrapper

setWrappee(MatsInitiator.MatsInitiate) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

Sets the wrapped MatsInitiator.MatsInitiate, e.g.

setWrappee(ConnectionFactory) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

setWrappee(ConnectionFactory) - Method in class io.mats3.util.wrappers.ConnectionFactoryWrapper

Sets the wrapped ConnectionFactory, e.g.

setWrappee(DataSource) - Method in class io.mats3.util.wrappers.DataSourceWrapper

Sets the wrapped DataSource, e.g.

shouldSuppressStageLogging(MatsStageInterceptor.StageCommonContext) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

single(String, Class<R>, Class<I>, MatsEndpoint.ProcessSingleLambda<R, I>) - Method in class io.mats3.impl.jms.JmsMatsFactory

single(String, Class<R>, Class<I>, Consumer<? super MatsEndpoint.EndpointConfig<R, Void>>, Consumer<? super MatsStage.StageConfig<R, Void, I>>, MatsEndpoint.ProcessSingleLambda<R, I>) - Method in class io.mats3.impl.jms.JmsMatsFactory

single(String, Class<R>, Class<I>, MatsEndpoint.ProcessSingleLambda<R, I>) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

single(String, Class<R>, Class<I>, Consumer<? super MatsEndpoint.EndpointConfig<R, Void>>, Consumer<? super MatsStage.StageConfig<R, Void, I>>, MatsEndpoint.ProcessSingleLambda<R, I>) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

single(String, Class<R>, Class<I>, MatsEndpoint.ProcessSingleLambda<R, I>) - Method in interface io.mats3.MatsFactory

Sets up a MatsEndpoint that just contains one stage, useful for simple "request the full person data for this/these personId(s)" scenarios.

single(String, Class<R>, Class<I>, Consumer<? super MatsEndpoint.EndpointConfig<R, Void>>, Consumer<? super MatsStage.StageConfig<R, Void, I>>, MatsEndpoint.ProcessSingleLambda<R, I>) - Method in interface io.mats3.MatsFactory

Variation of #single(String, Class, Class, ProcessSingleLambda) that can be configured "on the fly".

SIZE_OUT_ENVELOPE_DESC - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

SIZE_OUT_ENVELOPE_NAME - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

SIZE_OUT_WIRE_DESC - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

SIZE_OUT_WIRE_NAME - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

sizeOfSerialized(String) - Method in class io.mats3.serial.json.MatsSerializerJson

sizeOfSerialized(Z) - Method in interface io.mats3.serial.MatsSerializer

SpringInjectRulesAndExtensions - Annotation Type in io.mats3.spring.test

Use this Test Execution Listener to autowire JUnit Rules and Jupiter Extensions, i.e.

SpringInjectRulesAndExtensions.SpringInjectRulesAndExtensionsTestExecutionListener - Class in io.mats3.spring.test

This TestExecutionListener finds all fields in the test class instance which is annotated with JUnit Rule or JUnit 5 Jupiter RegisterExtension, and runs beanFactory.autowireBean(fieldValue) on them.

SpringInjectRulesAndExtensionsTestExecutionListener() - Constructor for class io.mats3.spring.test.SpringInjectRulesAndExtensions.SpringInjectRulesAndExtensionsTestExecutionListener

SpringJmsMatsFactoryProducer - Class in io.mats3.spring.jms.factories

Provides an easy way to get hold of the most probable JmsMatsFactory transaction manager configuration in the Spring world (using JmsMatsTransactionManager_JmsAndSpringManagedSqlTx, or only the JmsMatsTransactionManager_Jms if no DataSource is needed).

SpringJmsMatsFactoryProducer() - Constructor for class io.mats3.spring.jms.factories.SpringJmsMatsFactoryProducer

SpringJmsMatsFactoryWrapper - Class in io.mats3.spring.jms.factories

Wrapper that should be used for a JmsMatsFactory in a Spring context.

SpringJmsMatsFactoryWrapper(ConnectionFactory, MatsFactory) - Constructor for class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper

Note: The MatsFactory provided may be a MatsFactory.MatsFactoryWrapper, but it must resolve to a JmsMatsFactory via the MatsFactory.unwrapFully().

stage(Class<I>, MatsEndpoint.ProcessLambda<R, S, I>) - Method in class io.mats3.impl.jms.JmsMatsEndpoint

stage(Class<I>, Consumer<? super MatsStage.StageConfig<R, S, I>>, MatsEndpoint.ProcessLambda<R, S, I>) - Method in class io.mats3.impl.jms.JmsMatsEndpoint

stage(Class<I>, MatsEndpoint.ProcessLambda<R, S, I>) - Method in interface io.mats3.MatsEndpoint

Adds a new stage to a multi-stage endpoint.

stage(Class<I>, Consumer<? super MatsStage.StageConfig<R, S, I>>, MatsEndpoint.ProcessLambda<R, S, I>) - Method in interface io.mats3.MatsEndpoint

Variation of MatsEndpoint.stage(Class, ProcessLambda) that can be configured "on the fly".

stageCompleted(MatsStageInterceptor.StageCompletedContext) - Method in interface io.mats3.api.intercept.MatsStageInterceptor

Invoked after the stage is fully completed, outgoing messages sent, db and messaging system committed.

stageCompleted(MatsStageInterceptor.StageCompletedContext) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

stageCompleted(MatsStageInterceptor.StageCompletedContext) - Method in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

stageCompleted(MatsStageInterceptor.StageCompletedContext) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor

stageCompletedNextDirect(MatsStageInterceptor.StageCompletedContext) - Method in interface io.mats3.api.intercept.MatsStageInterceptor

Special variant of MatsStageInterceptor.stageCompleted(StageCompletedContext) which is invoked when a MatsEndpoint.ProcessContext.nextDirect(Object) has been performed: As opposed to the ordinary variant, this does not execute outside the stage's transactional demarcation, since the nextDirect stage processing happens within the same transactional demarcation as the stage which invoked nextDirect.

staged(String, Class<R>, Class<S>) - Method in class io.mats3.impl.jms.JmsMatsFactory

staged(String, Class<R>, Class<S>, Consumer<? super MatsEndpoint.EndpointConfig<R, S>>) - Method in class io.mats3.impl.jms.JmsMatsFactory

staged(String, Class<R>, Class<S>) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

staged(String, Class<R>, Class<S>, Consumer<? super MatsEndpoint.EndpointConfig<R, S>>) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

staged(String, Class<R>, Class<S>) - Method in interface io.mats3.MatsFactory

Sets up a MatsEndpoint on which you will add stages.

staged(String, Class<R>, Class<S>, Consumer<? super MatsEndpoint.EndpointConfig<R, S>>) - Method in interface io.mats3.MatsFactory

Variation of MatsFactory.staged(String, Class, Class) that can be configured "on the fly".

stageInterceptOutgoingMessages(MatsStageInterceptor.StageInterceptOutgoingMessageContext) - Method in interface io.mats3.api.intercept.MatsStageInterceptor.MatsStageInterceptOutgoingMessages

stageInterceptOutgoingMessages(MatsStageInterceptor.StageInterceptOutgoingMessageContext) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor

stageInterceptUserLambda(MatsStageInterceptor.StageInterceptUserLambdaContext, MatsEndpoint.ProcessLambda<Object, Object, Object>, MatsEndpoint.ProcessContext<Object>, Object, Object) - Method in interface io.mats3.api.intercept.MatsStageInterceptor.MatsStageInterceptUserLambda

stageOrInit(JmsMatsTransactionManager.JmsMatsTxContextKey) - Method in interface io.mats3.impl.jms.JmsMatsStatics

stagePreprocessAndDeserializeError(MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext) - Method in interface io.mats3.api.intercept.MatsStageInterceptor

Invoked if any of the preprocessing and deserialization activities on the incoming message from the message system fails, and hence no Stage processing will be performed - i.e., no further methods of the interceptor will be invoked.

stageReceived(MatsStageInterceptor.StageReceivedContext) - Method in interface io.mats3.api.intercept.MatsStageInterceptor

Invoked right after message have been received, preprocessed and deserialized, before invoking the user lambda.

stageReceived(MatsStageInterceptor.StageReceivedContext) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

stageReceived(MatsStageInterceptor.StageReceivedContext) - Method in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

stageReceived(MatsStageInterceptor.StageReceivedContext) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor

StandardSpecificScenarioDecider(String...) - Constructor for class io.mats3.spring.jms.factories.ConfigurableScenarioDecider.StandardSpecificScenarioDecider

start() - Method in class io.mats3.impl.jms.JmsMatsEndpoint

start() - Method in class io.mats3.impl.jms.JmsMatsFactory

start() - Method in class io.mats3.impl.jms.JmsMatsStage

start() - Method in interface io.mats3.MatsConfig.StartStoppable

Will start the entity - or the entities below it (the only "active" entity is a MatsStage Processor).

start() - Method in interface io.mats3.MatsEndpoint

Starts the endpoint (unless MatsEndpoint.finishSetup() has NOT been invoked), invoking MatsStage.start() on any not-yet started stages of the endpoint (which should be all of them at application startup).

start() - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

start() - Method in interface io.mats3.MatsFactory

Starts all endpoints that has been created by this factory, by invoking MatsEndpoint.start() on them.

start() - Method in interface io.mats3.MatsStage

Starts this stage, thereby firing up the queue processing using a set of threads, the number decided by the MatsConfig.getConcurrency() for each stage.

start(String) - Method in class io.mats3.spring.jms.factories.ConnectionFactoryWithStartStopWrapper

Start whatever is needed to support the ConnectionFactory, i.e.

start() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

stash() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

stash() - Method in interface io.mats3.MatsEndpoint.ProcessContext

Returns a binary representation of the current Mats flow's incoming execution point, which can be unstashed again at a later time using the MatsInitiator, thereby providing a simplistic "continuation" feature in Mats.

stash() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

Sto - Annotation Type in io.mats3.spring

Specifies that the annotated method parameter is an incoming State Transfer Object.

stop(int) - Method in class io.mats3.impl.jms.JmsMatsEndpoint

stop(int) - Method in class io.mats3.impl.jms.JmsMatsFactory

stop(int) - Method in class io.mats3.impl.jms.JmsMatsStage

stop(int) - Method in interface io.mats3.impl.jms.JmsMatsStartStoppable

stop(int) - Method in interface io.mats3.MatsConfig.StartStoppable

Will stop the entity - or the entities below it (the only "active" entity is a MatsStage Processor).

stop(int) - Method in interface io.mats3.MatsEndpoint

Stops the endpoint, invoking MatsStage.stop(int) on all MatsStages.

stop(int) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

stop(int) - Method in interface io.mats3.MatsFactory

Stops all endpoints and initiators, by invoking MatsEndpoint.stop(int) on all the endpoints, and MatsInitiator.close() on all initiators that has been created by this factory.

stop(int) - Method in interface io.mats3.MatsStage

Stops this stage.

stop() - Method in class io.mats3.spring.jms.factories.ConnectionFactoryWithStartStopWrapper

Stop whatever you started in ConnectionFactoryWithStartStopWrapper.start(String).

stop() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

stop(Runnable) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

stopPhase0_SetRunFlagFalse() - Method in interface io.mats3.impl.jms.JmsMatsStartStoppable

stopPhase1_CloseSessionIfInReceive() - Method in interface io.mats3.impl.jms.JmsMatsStartStoppable

stopPhase2_GracefulWaitAfterRunflagFalse(int) - Method in interface io.mats3.impl.jms.JmsMatsStartStoppable

stopPhase3_InterruptIfStillAlive() - Method in interface io.mats3.impl.jms.JmsMatsStartStoppable

stopPhase4_GracefulWaitAfterInterrupt() - Method in interface io.mats3.impl.jms.JmsMatsStartStoppable

subscriptionTerminator(String, Class<S>, Class<I>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in class io.mats3.impl.jms.JmsMatsFactory

subscriptionTerminator(String, Class<S>, Class<I>, Consumer<? super MatsEndpoint.EndpointConfig<Void, S>>, Consumer<? super MatsStage.StageConfig<Void, S, I>>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in class io.mats3.impl.jms.JmsMatsFactory

subscriptionTerminator(String, Class<S>, Class<I>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

subscriptionTerminator(String, Class<S>, Class<I>, Consumer<? super MatsEndpoint.EndpointConfig<Void, S>>, Consumer<? super MatsStage.StageConfig<Void, S, I>>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

subscriptionTerminator(String, Class<S>, Class<I>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in interface io.mats3.MatsFactory

Special kind of terminator that, in JMS-style terms, subscribes to a topic instead of listening to a queue (i.e.

subscriptionTerminator(String, Class<S>, Class<I>, Consumer<? super MatsEndpoint.EndpointConfig<Void, S>>, Consumer<? super MatsStage.StageConfig<Void, S, I>>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in interface io.mats3.MatsFactory

Variation of #subscriptionTerminator(String, Class, Class, ProcessTerminatorLambda) that can be configured "on the fly", but notice that the concurrency of a SubscriptionTerminator is always 1.

SuggestedTimingHistogramsMeterFilter() - Constructor for class io.mats3.intercept.micrometer.MatsMicrometerInterceptor.SuggestedTimingHistogramsMeterFilter

SUPPRESS_LOGGING_ENDPOINT_ALLOWS_ATTRIBUTE_KEY - Static variable in interface io.mats3.api.intercept.MatsInterceptable.MatsLoggingInterceptor

Suppression of loglines will only be done if the affected endpoints allows it.

SUPPRESS_LOGGING_INTERCEPT_CONTEXT_ATTRIBUTE - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

SUPPRESS_LOGGING_TRACE_PROPERTY_KEY - Static variable in interface io.mats3.api.intercept.MatsInterceptable.MatsLoggingInterceptor

If this key is present on the TraceProperties of a Mats Flow, with the value Boolean.TRUE, no ordinary log lines should be emitted while initiating or stage processing the Mats Flow, assuming that the implicated endpoints allows logging suppression.

SUPPRESSION_MDC_KEY_PARTS_SEPARATOR - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

suppressionSummarizerThreadRunnable() - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

SYSPROP_MATS_TEST_BROKER - Static variable in interface io.mats3.test.broker.MatsTestBroker

Which Broker client to use (which JMS ConnectionFactory implementation): activemq (default), artemis or rabbitmq - or if a class-name like String, assumes that it is an implementation of the present interface (MatsTestBroker) and instantiates that.

SYSPROP_MATS_TEST_BROKER_VALUE_ACTIVEMQ - Static variable in interface io.mats3.test.broker.MatsTestBroker

DEFAULT: Use ActiveMQ as broker.

SYSPROP_MATS_TEST_BROKER_VALUE_ARTEMIS - Static variable in interface io.mats3.test.broker.MatsTestBroker

Use Artemis (Apache ActiveMQ Artemis) as broker - this was formerly JBoss HornetQ.

SYSPROP_MATS_TEST_BROKER_VALUE_RABBITMQ - Static variable in interface io.mats3.test.broker.MatsTestBroker

Use RabbitMQ as broker.

SYSPROP_MATS_TEST_BROKERURL - Static variable in interface io.mats3.test.broker.MatsTestBroker

System property ("-D" jvm argument) that if set to something else than MatsTestBroker.SYSPROP_MATS_TEST_BROKERURL_VALUE_IN_VM, will Not start an embedded ("in-VM") ActiveMQ instance. Make the ConnectionFactory use the property's value as brokerURL - with the special case that if the value is "LOCALHOST", it means default localhost connection string for active broker, e.g.

SYSPROP_MATS_TEST_BROKERURL_VALUE_IN_VM - Static variable in interface io.mats3.test.broker.MatsTestBroker

DEFAULT: If the value of MatsTestBroker.SYSPROP_MATS_TEST_BROKERURL is this value OR not set (i.e.

SYSPROP_MATS_TEST_BROKERURL_VALUE_LOCALHOST - Static variable in interface io.mats3.test.broker.MatsTestBroker

If the value of MatsTestBroker.SYSPROP_MATS_TEST_BROKERURL is this value, it means default localhost connection string for active broker, e.g.

SYSPROP_MATS_TEST_H2 - Static variable in class io.mats3.test.TestH2DataSource

System property ("-D" jvm argument) that if set will change the method TestH2DataSource.createStandard() from returning an in-memory H2 DataSource, to instead return a DataSource using the URL from the value, with the special case that if the value is "file", it will be "jdbc:h2:./matsTestH2DB;AUTO_SERVER=TRUE".

SYSPROP_VALUE_FILE_BASED - Static variable in class io.mats3.test.TestH2DataSource

If the value of TestH2DataSource.SYSPROP_MATS_TEST_H2 is this value, the TestH2DataSource.createStandard() will use the URL TestH2DataSource.FILE_BASED_TEST_H2_DATABASE_URL, which is "jdbc:h2:./matsTestH2DB;AUTO_SERVER=TRUE".

T

TAG_APP_NAME - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TAG_APP_VERSION - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TAG_EXEC - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TAG_FROM - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TAG_INITIATING_APP_NAME - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TAG_INITIATOR_ID - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TAG_INITIATOR_NAME - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TAG_STAGE_ID - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TAG_STAGE_INDEX - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TAG_TO - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TAG_TYPE - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

takeNap(int) - Static method in class io.mats3.test.MatsTestHelp

Sleeps the specified number of milliseconds - can emulate processing time, primarily meant for the concurrency tests.

terminator(String, Class<S>, Class<I>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in class io.mats3.impl.jms.JmsMatsFactory

terminator(String, Class<S>, Class<I>, Consumer<? super MatsEndpoint.EndpointConfig<Void, S>>, Consumer<? super MatsStage.StageConfig<Void, S, I>>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in class io.mats3.impl.jms.JmsMatsFactory

terminator(String, Class<S>, Class<I>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

terminator(String, Class<S>, Class<I>, Consumer<? super MatsEndpoint.EndpointConfig<Void, S>>, Consumer<? super MatsStage.StageConfig<Void, S, I>>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

terminator(String, Class<S>, Class<I>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in interface io.mats3.MatsFactory

Sets up a MatsEndpoint that contains a single stage that typically will be the reply-to endpointId for a request initiation, or that can be used to directly send a "fire-and-forget" style invocation to.

terminator(String, Class<S>, Class<I>, Consumer<? super MatsEndpoint.EndpointConfig<Void, S>>, Consumer<? super MatsStage.StageConfig<Void, S, I>>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in interface io.mats3.MatsFactory

Variation of #terminator(String, Class, Class, ProcessTerminatorLambda) that can be configured "on the fly".

terminator() - Static method in class io.mats3.test.MatsTestHelp

terminator(String) - Static method in class io.mats3.test.MatsTestHelp

testH2DataSource() - Method in class io.mats3.spring.test.MatsTestInfrastructureDbConfiguration.MatsTestH2DataSourceConfiguration

TestH2DataSource - Class in io.mats3.test

A wrapped H2 DataBase DataSource which has a couple of extra methods which simplifies testing, in particular the TestH2DataSource.cleanDatabase(), and TestH2DataSource.createDataTable() method with associated convenience methods for storing and getting simple values.

TestH2DataSource.TestH2DataSourceException - Exception in io.mats3.test

A RuntimeException for use in database access methods and tests.

TestH2DataSourceException(String, Throwable) - Constructor for exception io.mats3.test.TestH2DataSource.TestH2DataSourceException

testMatsFactory() - Method in class io.mats3.spring.test.MatsTestInfrastructureConfiguration

testMatsFuturizer(MatsFactory) - Method in class io.mats3.spring.test.MatsTestInfrastructureConfiguration

testMatsInitiator(MatsFactory) - Method in class io.mats3.spring.test.MatsTestInfrastructureConfiguration

testMatsTestLatch() - Method in class io.mats3.spring.test.MatsTestInfrastructureConfiguration

testMatsTestMqInterface() - Method in class io.mats3.spring.test.MatsTestInfrastructureConfiguration

TestSpringMatsFactoryProvider - Class in io.mats3.spring.test

A testing-oriented MatsFactory-provider which utilizes the MatsTestBroker for the produced MatsFactory to connect to - this is for the scenarios where you do NOT have your test load the entire application's Spring configuration, but instead "piece together" the relevant Spring @Components containing test-relevant Mats endpoints and other beans from your application along with test-specific mocked-out endpoints: You will then probably not have the MatsFactory present in the Spring context.

TestSpringMatsFactoryProvider() - Constructor for class io.mats3.spring.test.TestSpringMatsFactoryProvider

THREAD_PREFIX - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

TIMER_EXEC_DB_COMMIT_DESC - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TIMER_EXEC_DB_COMMIT_NAME - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TIMER_EXEC_MSGSYS_COMMIT_DESC - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TIMER_EXEC_MSGSYS_COMMIT_NAME - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TIMER_EXEC_OPS_PREFIX - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TIMER_EXEC_OUT_DESC - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TIMER_EXEC_OUT_NAME - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TIMER_EXEC_TOTAL_DESC - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TIMER_EXEC_TOTAL_NAME - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TIMER_EXEC_USER_LAMBDA_DESC - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TIMER_EXEC_USER_LAMBDA_NAME - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TIMER_IN_TOTAL_DESC - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TIMER_IN_TOTAL_NAME - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TIMER_OUT_MSGSYS_SEND_DESC - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TIMER_OUT_MSGSYS_SEND_NAME - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TIMER_OUT_TOTAL_DESC - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

TIMER_OUT_TOTAL_NAME - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

to(String) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Sets which MATS Endpoint this message should go.

to(String) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

toClass(Class<T>) - Method in interface io.mats3.MatsEndpoint.MatsObject

Deserializes the incoming message class to the desired type - assuming that it actually is a serialized representation of that class.

toString() - Method in class io.mats3.impl.jms.JmsMatsEndpoint

toString() - Method in class io.mats3.impl.jms.JmsMatsFactory

toString() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.ConnectionWithSessionPool

toString() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl

toString() - Method in class io.mats3.impl.jms.JmsMatsProcessContext

toString() - Method in class io.mats3.impl.jms.JmsMatsStage

toString() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext

toString() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

toString() - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

toString() - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

toString() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

toString() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

MatsTraceStringImpl.toString().

toString() - Method in class io.mats3.util.TraceId

toString() - Method in class io.mats3.util.wrappers.DataSourceWrapper

toStringFromMatsTrace(long, int, int, boolean) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl

TOTAL_JMS_MSG_PROPS_SIZE - Static variable in interface io.mats3.impl.jms.JmsMatsStatics

traceId(CharSequence) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Sets (or appends with a joining "|" in case of initiation within a stage) the supplied Trace Id, which is solely used for logging and debugging purposes.

traceId(CharSequence) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

traceId() - Static method in class io.mats3.test.MatsTestHelp

TraceId - Class in io.mats3.util

A small tool to produce a String - specifically an opinionated TraceId.

TraceId(String, String, String) - Constructor for class io.mats3.util.TraceId

TransactionalContext_Jms(JmsMatsTransactionManager.JmsMatsTxContextKey) - Constructor for class io.mats3.impl.jms.JmsMatsTransactionManager_Jms.TransactionalContext_Jms

TransactionalContext_JmsAndJdbc(DataSource, JmsMatsTransactionManager.JmsMatsTxContextKey) - Constructor for class io.mats3.impl.jms.JmsMatsTransactionManager_JmsAndJdbc.TransactionalContext_JmsAndJdbc

U

unbindResource(Object) - Static method in class io.mats3.impl.jms.JmsMatsContextLocalCallback

Removes a ThreadLocal-bound resource, bound with JmsMatsContextLocalCallback.bindResource(Object, Object).

UNIT_BYTES - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor

unstash(byte[], Class<R>, Class<S>, Class<I>, MatsEndpoint.ProcessLambda<R, S, I>) - Method in interface io.mats3.MatsInitiator.MatsInitiate

Unstashes a Mats Flow that have been previously stashed.

unstash(byte[], Class<R>, Class<S>, Class<I>, MatsEndpoint.ProcessLambda<R, S, I>) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

unwrap() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

unwrap() - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

unwrap() - Method in interface io.mats3.MatsFactory.MatsWrapper

unwrap() - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

unwrap() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

unwrap(Class<T>) - Method in class io.mats3.test.TestH2DataSource

unwrap() - Method in class io.mats3.util.wrappers.ConnectionFactoryWrapper

unwrap() - Method in class io.mats3.util.wrappers.DataSourceWrapper

unwrap(Class<T>) - Method in class io.mats3.util.wrappers.DataSourceWrapper

unwrapFully() - Method in interface io.mats3.MatsEndpoint.ProcessContext

unwrapFully() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper

unwrapFully() - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

unwrapFully() - Method in interface io.mats3.MatsFactory.MatsWrapper

unwrapFully() - Method in interface io.mats3.MatsFactory

In a situation where you might be given a MatsFactory.MatsFactoryWrapper, but need the actual implementation, this method allows you to just always call matsFactory.unwrapFully() instead of first checking whether it is a proxy and only then cast and unwrap.

unwrapFully() - Method in interface io.mats3.MatsInitiator.MatsInitiate

unwrapFully() - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper

unwrapTo(Class<I>) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

Resolve the "deadly diamond of death", by calling to MatsWrapper.super.unwrapTo(iface);

unwrapTo(Class<I>) - Method in interface io.mats3.MatsFactory.MatsWrapper

unwrapTo(Class<I>) - Method in interface io.mats3.MatsFactory

In a situation where you might be given a MatsFactory.MatsFactoryWrapper, but need to find a wrappee that implements a specific interface, this method allows you to just always call matsFactory.unwrapTo(iface) instead of first checking whether it is a proxy and only then cast and unwrap.

useSeparateQueueForInteractiveNonPersistent(boolean) - Method in class io.mats3.impl.jms.JmsMatsFactory

V

valueOf(String) - Static method in enum io.mats3.api.intercept.MatsOutgoingMessage.DispatchType

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

valueOf(String) - Static method in enum io.mats3.api.intercept.MatsOutgoingMessage.MessageType

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

valueOf(String) - Static method in enum io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext.ProcessResult

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

valueOf(String) - Static method in enum io.mats3.api.intercept.MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext.StagePreprocessAndDeserializeError

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

valueOf(String) - Static method in enum io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyInitiator

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

valueOf(String) - Static method in enum io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyStageProcessor

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

valueOf(String) - Static method in enum io.mats3.intercept.logging.MatsMetricsLoggingInterceptor.Level

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

valueOf(String) - Static method in enum io.mats3.MatsInitiator.KeepTrace

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

valueOf(String) - Static method in enum io.mats3.serial.MatsTrace.Call.CallType

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

valueOf(String) - Static method in enum io.mats3.serial.MatsTrace.Call.MessagingModel

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

valueOf(String) - Static method in enum io.mats3.serial.MatsTrace.KeepMatsTrace

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

valueOf(String) - Static method in enum io.mats3.spring.jms.factories.MatsScenario

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

valueOf(String) - Static method in enum io.mats3.test.broker.MatsTestBroker.ActiveMq

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

values() - Static method in enum io.mats3.api.intercept.MatsOutgoingMessage.DispatchType

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

values() - Static method in enum io.mats3.api.intercept.MatsOutgoingMessage.MessageType

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

values() - Static method in enum io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext.ProcessResult

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

values() - Static method in enum io.mats3.api.intercept.MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext.StagePreprocessAndDeserializeError

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

values() - Static method in enum io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyInitiator

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

values() - Static method in enum io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyStageProcessor

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

values() - Static method in enum io.mats3.intercept.logging.MatsMetricsLoggingInterceptor.Level

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

values() - Static method in enum io.mats3.MatsInitiator.KeepTrace

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

values() - Static method in enum io.mats3.serial.MatsTrace.Call.CallType

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

values() - Static method in enum io.mats3.serial.MatsTrace.Call.MessagingModel

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

values() - Static method in enum io.mats3.serial.MatsTrace.KeepMatsTrace

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

values() - Static method in enum io.mats3.spring.jms.factories.MatsScenario

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

values() - Static method in enum io.mats3.test.broker.MatsTestBroker.ActiveMq

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

verifyNotInvoked() - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint

Verifies that this endpoint has not been invoked.

W

WAIT_MILLIS_FOR_NON_OCCURRENCE - Static variable in class io.mats3.test.MatsTestLatch

Some tests needs to assert that something does not happen, i.e.

waitForReceiving(int) - Method in class io.mats3.impl.jms.JmsMatsEndpoint

waitForReceiving(int) - Method in class io.mats3.impl.jms.JmsMatsFactory

waitForReceiving(int) - Method in class io.mats3.impl.jms.JmsMatsStage

waitForReceiving(int) - Method in interface io.mats3.impl.jms.JmsMatsStartStoppable

waitForReceiving(int) - Method in interface io.mats3.MatsConfig.StartStoppable

If the entity is stopped or starting, this method won't return until it has actually started the receive-loop (i.e.

waitForReceiving(int) - Method in interface io.mats3.MatsEndpoint

Waits till all stages of the endpoint has entered their receive-loops, i.e.

waitForReceiving(int) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper

waitForReceiving(int) - Method in interface io.mats3.MatsFactory

Waits until all endpoints have fully entered the receive-loops, i.e.

waitForReceiving(int) - Method in interface io.mats3.MatsStage

Will wait until at least one processor of the stage has entered its receive-loop.

waitForRequest() - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint

Blocks and waits for the endpoint to be invoked, then returns the incoming message DTO of the type (I).

waitForRequest(long) - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint

Blocks and waits for the endpoint to be invoked, then returns the incoming message DTO of the type (I).

waitForRequests(int) - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint

Blocks and waits for the endpoint to be invoked x number of times, then returns the x number of corresponding incoming message DTO's of the type (I).

waitForRequests(int, long) - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint

Blocks and waits for the endpoint to be invoked x number of times, then returns the x number of corresponding incoming message DTO's of the type (I).

waitForResult() - Method in class io.mats3.test.MatsTestLatch

Convenience method of MatsTestLatch.waitForResult(long) meant for waiting for something that is expected to happen: Waits for 30 seconds for the test-latch to be resolved.

waitForResult(long) - Method in class io.mats3.test.MatsTestLatch

Waits for the specified time for #resolve(DetachedProcessContext, Object, Object) resolve(..)} to be invoked by some other thread, returning the result.

withChildFlow(String, int) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

withChildFlow(String, int) - Method in interface io.mats3.serial.MatsTrace

If this newly created MatsTrace is a child-flow (initiated within a Stage) of an existing flow, then this method should be invoked to set the parent MatsMessageId, and the "total call number" which is a "Call Overflow protection" mechanism.

withDebugInfo(String, String, String, String, String) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl

withDebugInfo(String, String, String, String, String) - Method in interface io.mats3.serial.MatsTrace

Can only be set once..

withDefaultScenario(MatsScenario) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer

Very optional: If you do not explicitly set the ScenarioConnectionFactoryWrapper.ScenarioDecider using the #withScenarioDecider(ScenarioDecider) method, you get a default ConfigurableScenarioDecider.createDefaultScenarioDecider().

withLocalhostConnectionFactory(ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer

Optional: Provide a ConnectionFactoryProvider lambda for the LOCALHOST scenario (which only is meant to be used for development and possibly testing).

withLocalVmConnectionFactory(ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer

Very optional: Provide a ConnectionFactoryProvider lambda for the LOCALVM scenario (which only is meant to be used for development and testing).

withRegularConnectionFactory(ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider) - Static method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer

Creates a ScenarioConnectionFactoryProducer, where you need to provide the REGULAR scenario's ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider.

withScenarioDecider(ScenarioConnectionFactoryWrapper.ScenarioDecider) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer

Can optionally be overridden should you decide to use a different decision-scheme than the default.

wrap(DataSource) - Static method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper

wrapLazyConnectionDatasource(DataSource) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx

Creates a proxy/wrapper that has lazy connection getting, and monitoring of whether the connection was actually retrieved.

_

_artemisServer - Variable in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_Artemis

_assertFuturizerRunning() - Method in class io.mats3.util.MatsFuturizer

_autoCommitFromWrappedDataSource - Variable in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper

_beanName - Variable in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

_brokerService - Variable in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_ActiveMq

_brokerService - Variable in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_InVmActiveMq

_closedOrCrashed - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl

_closedOrReleasedOrCrashed - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple

_connectionFactory - Variable in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_ActiveMq

_connectionFactory - Variable in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_Artemis

_connectionFactory - Variable in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_InVmActiveMq

_connectionWithSessionPool - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl

_connectionWithSessionPools_crashed - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling

_connectionWithSessionPools_live - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling

_correlationId - Variable in class io.mats3.util.MatsFuturizer.Promise

_correlationIdToPromiseMap - Variable in class io.mats3.util.MatsFuturizer

_createdMatsFactories - Variable in class io.mats3.test.abstractunit.AbstractMatsTest

_createPromise(String, String, String, Class<T>, int, TimeUnit) - Method in class io.mats3.util.MatsFuturizer

_currentContext - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl

_dataSource - Variable in class io.mats3.spring.test.MatsTestInfrastructureConfiguration

_dataSource - Variable in class io.mats3.test.abstractunit.AbstractMatsTest

_defaultScenario - Variable in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider

_deserializeReply(MatsEndpoint.MatsObject, Class<?>) - Method in class io.mats3.util.MatsFuturizer

_enqueuePromise(MatsFuturizer.Promise<T>) - Method in class io.mats3.util.MatsFuturizer

_environment - Variable in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

_from - Variable in class io.mats3.util.MatsFuturizer.Promise

_future - Variable in class io.mats3.util.MatsFuturizer.Promise

_futureCompleterThreadPool - Variable in class io.mats3.util.MatsFuturizer

_handleRepliesForPromises(MatsEndpoint.ProcessContext<Void>, String, MatsEndpoint.MatsObject) - Method in class io.mats3.util.MatsFuturizer

_initiationTimestamp - Variable in class io.mats3.util.MatsFuturizer.Promise

_internalStateLock - Variable in class io.mats3.util.MatsFuturizer

_jmsConnection - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple

_jmsConnectionFactory - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling

_jmsConnectionFactory - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple

_jmsSession - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl

_jmsSession - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple

_latePopulate(ConnectionFactory, MatsFactory) - Method in interface io.mats3.test.MatsTestBrokerInterface

This method is most probably not for you!.

_latePopulate(ConnectionFactory, MatsFactory) - Method in class io.mats3.test.MatsTestBrokerInterface.MatsTestBrokerInterface_JmsMatsFactory

_localhost - Variable in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider

_localhostConnectionFactoryProvider - Variable in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

_localVm - Variable in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider

_localVmConnectionFactoryProvider - Variable in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

_matsFactory - Variable in class io.mats3.test.abstractunit.AbstractMatsTest

_matsFactory - Variable in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint

_matsFactory - Variable in class io.mats3.util.MatsFuturizer

_matsFuturizer - Variable in class io.mats3.test.abstractunit.AbstractMatsTest

_matsInitiator - Variable in class io.mats3.test.abstractunit.AbstractMatsTest

_matsInitiator - Variable in class io.mats3.util.MatsFuturizer

_matsScenarioDecision - Variable in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

_matsSerializer - Variable in class io.mats3.spring.test.MatsTestInfrastructureConfiguration

_matsSerializer - Variable in class io.mats3.test.abstractunit.AbstractMatsTest

_matsTestBroker - Variable in class io.mats3.test.abstractunit.AbstractMatsTest

_matsTestBrokerInterface - Variable in class io.mats3.test.abstractunit.AbstractMatsTest

_matsTestLatch - Variable in class io.mats3.test.abstractunit.AbstractMatsTest

_maxOutstandingPromises - Variable in class io.mats3.util.MatsFuturizer

_messageProducer - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl

_messageProducer - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple

_newThreadPool(int, int) - Method in class io.mats3.util.MatsFuturizer

_nextInLineToTimeout - Variable in class io.mats3.util.MatsFuturizer

_numberOfOutstandingConnections - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple

_platformTransactionManagerObjectProvider - Variable in class io.mats3.spring.test.MatsTestInfrastructureConfiguration

_poolingKeyInitiator - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling

_poolingKeyStageProcessor - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling

_poolIsCrashed_StackTrace - Variable in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.ConnectionWithSessionPool

_processLambda - Variable in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint

_readOnlyFromWrappedDataSource - Variable in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper

_regular - Variable in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider

_regularConnectionFactoryProvider - Variable in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

_replyClass - Variable in class io.mats3.util.MatsFuturizer.Promise

_replyHandlerEndpoint - Variable in class io.mats3.util.MatsFuturizer

_replyHandlerEndpointStarted - Variable in class io.mats3.util.MatsFuturizer

_runFlag - Variable in class io.mats3.util.MatsFuturizer

_scenarioDecider - Variable in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

_sendRequestToFulfillPromise(String, String, String, Object, MatsInitiator.InitiateLambda, MatsFuturizer.Promise<T>) - Method in class io.mats3.util.MatsFuturizer

_startTimeouterThread() - Method in class io.mats3.util.MatsFuturizer

_suppressions - Variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor

_targetConnectionFactory - Variable in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper

_terminatorEndpointId - Variable in class io.mats3.util.MatsFuturizer

_threadNumber - Variable in class io.mats3.util.MatsFuturizer

_timeoutCompleteExceptionally(MatsFuturizer.Promise<?>, String) - Method in class io.mats3.util.MatsFuturizer

_timeouterPing_InternalStateLock - Variable in class io.mats3.util.MatsFuturizer

_timeoutSortedPromises - Variable in class io.mats3.util.MatsFuturizer

_timeoutTimestamp - Variable in class io.mats3.util.MatsFuturizer.Promise

_to - Variable in class io.mats3.util.MatsFuturizer.Promise

_traceId - Variable in class io.mats3.util.MatsFuturizer.Promise

_transactionIsolationFromWrappedDataSource - Variable in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper

_txContextKey - Variable in class io.mats3.impl.jms.JmsMatsTransactionManager_Jms.TransactionalContext_Jms

_uncheckedComplete(MatsEndpoint.ProcessContext<Void>, Object, MatsFuturizer.Promise<?>) - Method in class io.mats3.util.MatsFuturizer

A B C D E F G H I J K L M N O P Q R S T U V W _