Index

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

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, long) - Method in class io.mats3.util.TraceId
 
add(String, String) - 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
 
ADVISORY - Enum constant in enum class io.mats3.test.broker.MatsTestBroker.ActiveMq
Enable the advisory topics, via BrokerService.setAdvisorySupport(boolean) and BrokerService.setAnonymousProducerAdvisorySupport(boolean).
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

basePackageClasses() - Element in annotation interface io.mats3.spring.ComponentScanExcludingConfigurationForTest
Type-safe alternative to ComponentScanExcludingConfigurationForTest.basePackages() for specifying the packages to scan for annotated components.
basePackages() - Element in annotation interface io.mats3.spring.ComponentScanExcludingConfigurationForTest
Base packages to scan for annotated components.
batchId(long) - Method in class io.mats3.util.TraceId
 
batchId(String) - 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

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
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 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.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 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 class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling
 
closeAllAvailableSessions() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple
 
closeAllAvailableSessions() - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler
Closes all Available Session, does not touch Employed.
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
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
 
COMPACT - Enum constant in enum class io.mats3.MatsInitiator.KeepTrace
Nulls out Data for other than current call while still keeping the meta-info for the call history, and condenses State to a pure stack.
COMPACT - Enum constant in enum class io.mats3.serial.MatsTrace.KeepMatsTrace
Default: Nulls out Data for other than current call while still keeping the meta-info for the call history, and condenses State to a pure stack.
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 Interface 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) - Method in class io.mats3.util.TraceId
 
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
 
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() - Constructor for class io.mats3.spring.jms.factories.ConfigurableScenarioDecider
No-args constructor - must set all the ConfigurableScenarioDecider.SpecificScenarioDecider and default MatsScenario by setters.
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.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 Interface 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() - 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.
ConnectionFactoryWrapper(ConnectionFactory) - Constructor for class io.mats3.util.wrappers.ConnectionFactoryWrapper
Standard constructor, taking the wrapped 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 class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl
 
crashed(Throwable) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple
 
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.
create() - Static method in class io.mats3.impl.jms.JmsMatsTransactionManager_Jms
 
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() - 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() - Static method in class io.mats3.test.jupiter.Extension_Mats
Creates an Extension_Mats utilizing the MATS default serializer
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(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(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(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(MatsSerializer<Z>) - Static method in class io.mats3.test.junit.Rule_MatsGeneric
 
create(MatsSerializer<Z>) - Static method in class io.mats3.test.jupiter.Extension_MatsGeneric
Creates an Extension_MatsGeneric utilizing the user provided MatsSerializer.
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(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(String) - Static method in class io.mats3.test.TestH2DataSource
Creates a TestH2DataSource using the supplied URL.
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(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(String, String) - Static method in class io.mats3.util.TraceId
 
create(String, String, String) - Static method in class io.mats3.util.TraceId
 
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) - Static method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple
 
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, 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(DataSource) - Static method in class io.mats3.impl.jms.JmsMatsTransactionManager_JmsAndJdbc
 
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.
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() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
You should probably NOT use this method, but instead the AbstractMatsTest.getMatsFactory()!.
createMatsFactory(String, String, JmsMatsJmsSessionHandler, JmsMatsTransactionManager, MatsSerializer<Z>) - Static method in class io.mats3.impl.jms.JmsMatsFactory
 
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(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(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(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() - Static method in class io.mats3.test.jupiter.Extension_Mats
 
createWithDb(MatsSerializer<String>) - Static method in class io.mats3.test.junit.Rule_Mats
 
createWithDb(MatsSerializer<String>) - Static method in class io.mats3.test.jupiter.Extension_Mats
 
createWithDb(MatsSerializer<Z>) - Static method in class io.mats3.test.junit.Rule_MatsGeneric
 
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() - 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.
DataSourceWrapper(DataSource) - Constructor for class io.mats3.util.wrappers.DataSourceWrapper
Standard constructor, taking the wrapped 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
 
DECONSTRUCT_ERROR - Enum constant in enum class io.mats3.api.intercept.MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext.StagePreprocessAndDeserializeError
If getting problems deserializing the message, or getting hold of other properties from the message.
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_InfrastructureProxy(DataSource) - Constructor for class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx.DeferredConnectionProxyDataSourceWrapper_InfrastructureProxy
 
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.
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[], 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 class io.mats3.serial.json.MatsSerializerJson
 
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 class io.mats3.impl.jms.JmsMatsTransactionManager_Jms.TransactionalContext_Jms
 
doTransaction(JmsMatsInternalExecutionContext, JmsMatsTransactionManager.ProcessingLambda) - Method in class io.mats3.impl.jms.JmsMatsTransactionManager_JmsAndJdbc.TransactionalContext_JmsAndJdbc
 
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).
Dto - Annotation Interface in io.mats3.spring
Specifies that the annotated method parameter is an incoming Data Transfer Object.

E

EnableMats - Annotation Interface 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
 
ENDPOINT - Enum constant in enum class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyStageProcessor
All StageProcessors in all Stages for each Endpoint share a common JMS Connection - i.e.
endpointId() - Element in annotation interface io.mats3.spring.MatsClassMapping
The Mats Endpoint Id that this endpoint should listen to.
endpointId() - Element in annotation interface io.mats3.spring.MatsEndpointSetup
The Mats Endpoint Id that this endpoint should listen to.
endpointId() - Element in annotation interface io.mats3.spring.MatsMapping
The Mats Endpoint Id that this endpoint should listen to.
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
 
ERROR - Enum constant in enum class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor.Level
 
excludeFilters() - Element in annotation interface io.mats3.spring.ComponentScanExcludingConfigurationForTest
Specifies which types are not eligible for component scanning.
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

FACTORY - Enum constant in enum class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyInitiator
All initiators share a common JMS Connection.
FACTORY - Enum constant in enum class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyStageProcessor
All StageProcessors in all Stages in all Endpoints share a common JMS Connection - i.e.
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) - Method in class io.mats3.util.TraceId
 
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
 
from() - Static method in class io.mats3.test.MatsTestHelp
 
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(String) - Static method in class io.mats3.test.MatsTestHelp
 
FULL - Enum constant in enum class io.mats3.MatsInitiator.KeepTrace
Default: Keep all history for request and reply DTOs, and all history for state STOs.
FULL - Enum constant in enum class io.mats3.serial.MatsTrace.KeepMatsTrace
Keeps all Data and State history for the entire trace.
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!

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(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
 
getAttribute(String) - Method in interface io.mats3.MatsConfig
 
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() - 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.test.TestH2DataSource
 
getConnection(String, String) - Method in class io.mats3.util.wrappers.DataSourceWrapper
 
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 class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl
 
getDefaultNoDestinationMessageProducer() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple
 
getDefaultNoDestinationMessageProducer() - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler.JmsSessionHolder
 
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
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 class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl
 
getSession() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple
 
getSession() - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler.JmsSessionHolder
 
getSessionHolder(JmsMatsInitiator<?>) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling
 
getSessionHolder(JmsMatsInitiator<?>) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_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 class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling
 
getSessionHolder(JmsMatsStageProcessor<?, ?, ?, ?>) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple
 
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_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) - 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).
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
 
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 class io.mats3.impl.jms.JmsMatsTransactionManager_Jms
 
getTransactionContext(JmsMatsTransactionManager.JmsMatsTxContextKey) - Method in class io.mats3.impl.jms.JmsMatsTransactionManager_JmsAndJdbc
 
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.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) - 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) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
 
goTo(String, Object, Object) - Method in class io.mats3.impl.jms.JmsMatsProcessContext
 
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, Object) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
 
GOTO - Enum constant in enum class io.mats3.api.intercept.MatsOutgoingMessage.MessageType
GOTO - Enum constant in enum class io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext.ProcessResult
 
GOTO - Enum constant in enum class io.mats3.serial.MatsTrace.Call.CallType
Not yet used.

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(Class<?>) - Method in class io.mats3.test.abstractunit.AbstractMatsTest
 
id(Object) - Method in interface io.mats3.impl.jms.JmsMatsStatics
 
id(String, Object) - Method in interface io.mats3.impl.jms.JmsMatsStatics
 
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
 
includeFilters() - Element in annotation interface io.mats3.spring.ComponentScanExcludingConfigurationForTest
Specifies which types are eligible for component scanning.
IncomingMessageRepresentationImpl(MatsOutgoingMessage.MessageType, String, String, String, String) - Constructor for class io.mats3.localinspect.LocalStatsMatsInterceptor.IncomingMessageRepresentationImpl
 
INFO - Enum constant in enum class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor.Level
 
init() - Static method in class io.mats3.impl.jms.JmsMatsMessageBrokerSpecifics
 
INIT - Enum constant in enum class io.mats3.api.intercept.MatsOutgoingMessage.DispatchType
 
INITIAL - Static variable in annotation interface 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 - Enum constant in enum class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyInitiator
Each initiator gets its own JSM Connection.
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(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).
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(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
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 Mats3: 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
Mats3 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
Mats3 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
Mats3 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
Mats3 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 Mats3 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
Mats3 MatsSerializer implementation using Jackson to serialize between MatsTraceStringImpl and byte arrays - Employed by the Mats3 JMS Implementation.
io.mats3.spring - package io.mats3.spring
Mats3 Spring integration ("SpringConfig"), supplying a set of annotations including @EnableMats to enable bean scanning for @MatsMapping and @MatsClassMapping annotations, simplifying use of Mats3 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
Mats3 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
Mats3 testing tools for JUnit 4.
io.mats3.test.jupiter - package io.mats3.test.jupiter
Mats3 testing tools for Jupiter (JUnit 5).
io.mats3.util - package io.mats3.util
Mats3 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 class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl
 
isSessionOk() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple
 
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.
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_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 Class in io.mats3.impl.jms
What kind of sharing of JMS Connections to employ for a JmsMatsInitiator.
JmsMatsJmsSessionHandler_Pooling.PoolingKeyStageProcessor - Enum Class 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
 
JmsMatsJmsSessionHandler.JmsSessionHolder - Interface in io.mats3.impl.jms
A "sidecar object" for the JMS Session, so that additional stuff can be bound to it.
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_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
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
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.
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.
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
 
JMX - Enum constant in enum class io.mats3.test.broker.MatsTestBroker.ActiveMq
Enable the JMX support, via BrokerService.setUseJmx(boolean).

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>, 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 class io.mats3.impl.jms.JmsMatsEndpoint
 
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
 
lazyInit() - Element in annotation interface io.mats3.spring.ComponentScanExcludingConfigurationForTest
Specify whether scanned beans should be registered for lazy initialization.
LOCALHOST - Enum constant in enum class io.mats3.spring.jms.factories.MatsScenario
NOTICE: Only meant for development and testing.
LOCALHOST - Enum constant in enum class io.mats3.test.broker.MatsTestBroker.ActiveMq
Add a Localhost TransportConnector, so that the broker is available on localhost:61616 in addition to in-vm connector.
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
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
 
LOCALVM - Enum constant in enum class io.mats3.spring.jms.factories.MatsScenario
NOTICE: Only meant for development and testing.
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!
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!
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 Interface 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 Interface in io.mats3.spring
 
MatsClassMapping.Stage - Annotation Interface 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 Interface 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 Interface 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.
matsFactoryBeanName() - Element in annotation interface io.mats3.spring.MatsClassMapping
Specified the MatsFactory to use by means of specifying the bean name of the MatsFactory.
matsFactoryBeanName() - Element in annotation interface io.mats3.spring.MatsEndpointSetup
Specified the MatsFactory to use by means of specifying the bean name of the MatsFactory.
matsFactoryBeanName() - Element in annotation interface io.mats3.spring.MatsMapping
Specified the MatsFactory to use by means of specifying the bean name of the MatsFactory.
matsFactoryCustomQualifierType() - Element in annotation interface io.mats3.spring.MatsClassMapping
Specifies the MatsFactory to use by means of a specific qualifier annotation type (which thus must be meta-annotated with Qualifier).
matsFactoryCustomQualifierType() - Element in annotation interface io.mats3.spring.MatsEndpointSetup
Specifies the MatsFactory to use by means of a specific qualifier annotation type (which thus must be meta-annotated with Qualifier).
matsFactoryCustomQualifierType() - Element in annotation interface io.mats3.spring.MatsMapping
Specifies the MatsFactory to use by means of a specific qualifier annotation type (which thus must be meta-annotated with Qualifier).
matsFactoryQualifierValue() - Element in annotation interface io.mats3.spring.MatsClassMapping
Specified the MatsFactory to use by means of specifying the @Qualifier value.
matsFactoryQualifierValue() - Element in annotation interface io.mats3.spring.MatsEndpointSetup
Specified the MatsFactory to use by means of specifying the @Qualifier value.
matsFactoryQualifierValue() - Element in annotation interface io.mats3.spring.MatsMapping
Specified the MatsFactory to use by means of specifying the @Qualifier value.
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.
MatsFactoryWrapper(MatsFactory) - Constructor for class io.mats3.MatsFactory.MatsFactoryWrapper
Standard constructor, taking the wrapped 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() - Constructor for class io.mats3.MatsInitiator.MatsInitiateWrapper
No-args constructor, which implies that you either need to invoke MatsInitiator.MatsInitiateWrapper.setWrappee(MatsInitiate) before publishing the instance (making it available for other threads), or override MatsInitiator.MatsInitiateWrapper.unwrap() to provide the desired MatsInitiator.MatsInitiate instance.
MatsInitiateWrapper(MatsInitiator.MatsInitiate) - Constructor for class io.mats3.MatsInitiator.MatsInitiateWrapper
Standard constructor, taking the wrapped 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 Class 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 Interface 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 Interface 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 Class 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 Class in io.mats3.api.intercept
 
MatsOutgoingMessage.MatsEditableOutgoingMessage - Interface in io.mats3.api.intercept
 
MatsOutgoingMessage.MatsSentOutgoingMessage - Interface in io.mats3.api.intercept
 
MatsOutgoingMessage.MessageType - Enum Class 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) - Constructor for exception io.mats3.MatsEndpoint.MatsRefuseMessageException
 
MatsRefuseMessageException(String, Throwable) - Constructor for exception io.mats3.MatsEndpoint.MatsRefuseMessageException
 
MatsScenario - Enum Class 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) - Constructor for exception io.mats3.spring.MatsSpringAnnotationRegistration.MatsSpringConfigException
 
MatsSpringConfigException(String, Throwable) - 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 Class 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 Class 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 Class 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 Interface 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 Interface 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 Interface 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 Class 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 Class in io.mats3.serial
Specifies what type of Messaging Model a 'to' and 'replyTo' is to go over: Queue or Topic.
MatsTrace.KeepMatsTrace - Enum Class 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.
MINIMAL - Enum constant in enum class io.mats3.MatsInitiator.KeepTrace
Only keep the current call, and condenses State to a pure stack.
MINIMAL - Enum constant in enum class io.mats3.serial.MatsTrace.KeepMatsTrace
Only keep the current call, and condenses State to a pure stack.
MISSING_CONTENTS - Enum constant in enum class io.mats3.api.intercept.MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext.StagePreprocessAndDeserializeError
If there is missing required contents in the message system message (i.e.
MQ_NAME_REPLACE_PATTERN - Static variable in class io.mats3.util.SanitizeMqNames
 
ms(double) - Static method in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor.SuggestedTimingHistogramsMeterFilter
 
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).
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

nameGenerator() - Element in annotation interface io.mats3.spring.ComponentScanExcludingConfigurationForTest
The BeanNameGenerator class to be used for naming detected components within the Spring container.
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.
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
 
NEXT - Enum constant in enum class io.mats3.api.intercept.MatsOutgoingMessage.MessageType
NEXT - Enum constant in enum class io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext.ProcessResult
 
NEXT - Enum constant in enum class io.mats3.serial.MatsTrace.Call.CallType
 
NEXT_DIRECT - Enum constant in enum class io.mats3.api.intercept.MatsOutgoingMessage.MessageType
NEXT_DIRECT - Enum constant in enum class io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext.ProcessResult
 
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
 
NONE - Enum constant in enum class io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext.ProcessResult
No standard processing result, which is default mode for a Terminator - but note that initiations might have been produced nevertheless!
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() - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
 
nonPersistent(long) - Method in interface io.mats3.MatsInitiator.MatsInitiate
Same as MatsInitiator.MatsInitiate.nonPersistent(), but you can set a time-to-live too.
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.
ordinal() - Element in annotation interface io.mats3.spring.MatsClassMapping.Stage
The ordinal of this Stage in the sequence of stages of this endpoint - that is, an integer that expresses the relative position of this Stage wrt.
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
 
PERSISTENT - Enum constant in enum class io.mats3.test.broker.MatsTestBroker.ActiveMq
Enable broker persistence, using KahaDB.
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<Void>, S, I) - Method in interface io.mats3.MatsEndpoint.ProcessTerminatorLambda
 
process(MatsEndpoint.ProcessContext<R>, I) - Method in interface io.mats3.MatsEndpoint.ProcessSingleLambda
 
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
 
ProcessContextWrapper() - Constructor for class io.mats3.MatsEndpoint.ProcessContextWrapper
No-args constructor, which implies that you either need to invoke MatsEndpoint.ProcessContextWrapper.setWrappee(ProcessContext) before publishing the instance (making it available for other threads), or override MatsEndpoint.ProcessContextWrapper.unwrap() to provide the desired MatsEndpoint.ProcessContext instance.
ProcessContextWrapper(MatsEndpoint.ProcessContext<R>) - Constructor for class io.mats3.MatsEndpoint.ProcessContextWrapper
Standard constructor, taking the wrapped 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) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
 
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, Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
 
PUBLISH - Enum constant in enum class io.mats3.api.intercept.MatsOutgoingMessage.MessageType
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
 
QUEUE - Enum constant in enum class io.mats3.serial.MatsTrace.Call.MessagingModel
 

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(int) - Static method in class io.mats3.util.RandomString
 
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
 
REGULAR - Enum constant in enum class io.mats3.spring.jms.factories.MatsScenario
For Production, Staging, Pre-prod, etc.
release() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl
 
release() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple
 
release() - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler.JmsSessionHolder
For Initiators: This returns the JmsSessionHolder to the Session Pool for the underlying Connection.
remove(int) - Method in class io.mats3.impl.jms.JmsMatsEndpoint
 
remove(int) - Method in interface io.mats3.MatsEndpoint
Should most probably only be used for testing!
remove(MatsInterceptable) - Static method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
Removes the singleton MatsMetricsLoggingInterceptor.INSTANCE as both Initiation and Stage interceptors.
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 - Variable in class io.mats3.util.MatsFuturizer.Reply
 
reply() - Element in annotation interface io.mats3.spring.MatsEndpointSetup
The Mats Data Transfer Object class that will be returned by the last stage of the staged endpoint.
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 - Enum constant in enum class io.mats3.api.intercept.MatsOutgoingMessage.MessageType
REPLY - Enum constant in enum class io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext.ProcessResult
 
REPLY - Enum constant in enum class io.mats3.serial.MatsTrace.Call.CallType
 
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(Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate
The standard request initiation method: All of from, to and replyTo must be set.
request(Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
 
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, 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 - Enum constant in enum class io.mats3.api.intercept.MatsOutgoingMessage.MessageType
REQUEST - Enum constant in enum class io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext.ProcessResult
 
REQUEST - Enum constant in enum class io.mats3.serial.MatsTrace.Call.CallType
 
resolve(MatsEndpoint.DetachedProcessContext, Object, Object) - Method in class io.mats3.test.MatsTestLatch
When this method is invoked, the waiting threads will be released.
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!
resourcePattern() - Element in annotation interface io.mats3.spring.ComponentScanExcludingConfigurationForTest
Controls the class files eligible for component detection.
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.
scopedProxy() - Element in annotation interface io.mats3.spring.ComponentScanExcludingConfigurationForTest
Indicates whether proxies should be generated for detected components, which may be necessary when using scopes in a proxy-style fashion.
scopeResolver() - Element in annotation interface io.mats3.spring.ComponentScanExcludingConfigurationForTest
The ScopeMetadataResolver to be used for resolving the scope of detected components.
send(Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate
Sends a message to an endpoint, without expecting any reply ("fire-and-forget").
send(Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
 
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, Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
 
SEND - Enum constant in enum class io.mats3.api.intercept.MatsOutgoingMessage.MessageType
SEND - Enum constant in enum class io.mats3.serial.MatsTrace.Call.CallType
 
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
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(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.
setWrappee(T) - Method in interface io.mats3.MatsFactory.MatsWrapper
 
shouldSuppressStageLogging(MatsStageInterceptor.StageCommonContext) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
 
SHUTDOWNHOOK - Enum constant in enum class io.mats3.test.broker.MatsTestBroker.ActiveMq
Add a shutdown hook, to cleanly shut down the broker upon JVM shutdown, i.e.
single(String, Class<R>, Class<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>, 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 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.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 interface io.mats3.MatsFactory
Variation of MatsFactory.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 Interface 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>, 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 class io.mats3.impl.jms.JmsMatsEndpoint
 
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".
STAGE - Enum constant in enum class io.mats3.api.intercept.MatsOutgoingMessage.DispatchType
 
STAGE - Enum constant in enum class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyStageProcessor
All StageProcessors in each Stage share a common JMS Connection - i.e.
STAGE_INIT - Enum constant in enum class io.mats3.api.intercept.MatsOutgoingMessage.DispatchType
 
STAGE_PROCESSOR - Enum constant in enum class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyStageProcessor
Each StageProcessor has its own JMS Connection - i.e.
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>) - 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 class io.mats3.impl.jms.JmsMatsFactory
 
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>, 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() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper
 
start(String) - Method in class io.mats3.spring.jms.factories.ConnectionFactoryWithStartStopWrapper
Start whatever is needed to support the ConnectionFactory, i.e.
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
 
state() - Element in annotation interface io.mats3.spring.MatsEndpointSetup
The Mats State Transfer Object class that should be employed for all of the stages for this endpoint.
Sto - Annotation Interface in io.mats3.spring
Specifies that the annotated method parameter is an incoming State Transfer Object.
stop() - Method in class io.mats3.spring.jms.factories.ConnectionFactoryWithStartStopWrapper
stop() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper
 
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(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
 
subscription() - Element in annotation interface io.mats3.spring.MatsMapping
If this MatsEndpoint is subscription based.
subscriptionTerminator(String, Class<S>, Class<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>, 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 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.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 interface io.mats3.MatsFactory
Variation of MatsFactory.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".
SYSTEM_EXCEPTION - Enum constant in enum class io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext.ProcessResult
If the messaging or processing system failed, this will be either MatsBackendException (messaging handling or db commit), or MatsMessageSendException (which is the "VERY BAD!" scenario where db is committed, whereupon the messaging commit failed - which quite possibly is a "notify the humans!"-situation, unless the user code is crafted to handle such a situation by being idempotent).

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() - Static method in class io.mats3.test.MatsTestHelp
 
terminator(String) - Static method in class io.mats3.test.MatsTestHelp
 
terminator(String, Class<S>, Class<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>, 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 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.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 interface io.mats3.MatsFactory
Variation of MatsFactory.terminator(String, Class, Class, ProcessTerminatorLambda) that can be configured "on the fly".
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.
TOPIC - Enum constant in enum class io.mats3.serial.MatsTrace.Call.MessagingModel
 
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() - Static method in class io.mats3.test.MatsTestHelp
 
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 - 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() - 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.test.TestH2DataSource
 
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.
useDefaultFilters() - Element in annotation interface io.mats3.spring.ComponentScanExcludingConfigurationForTest
Indicates whether automatic detection of classes annotated with @Component @Repository, @Service, or @Controller should be enabled.
USER_EXCEPTION - Enum constant in enum class io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext.ProcessResult
Any exception thrown in the user lambda, causing rollback of the processing.
useSeparateQueueForInteractiveNonPersistent(boolean) - Method in class io.mats3.impl.jms.JmsMatsFactory
 

V

value() - Element in annotation interface io.mats3.spring.ComponentScanExcludingConfigurationForTest
value() - Element in annotation interface io.mats3.spring.MatsClassMapping.MatsClassMappings
 
value() - Element in annotation interface io.mats3.spring.MatsClassMapping.Stage
Alias for "ordinal", so that if you only need to set the ordinal (which relative position in the sequence of stages this Stage is), you can do so directly: @Stage(15).
value() - Element in annotation interface io.mats3.spring.MatsClassMapping
Alias for "endpointId", so that if you only need to set the endpointId, you can do so directly: @MatsEndpointSetup("endpointId")
value() - Element in annotation interface io.mats3.spring.MatsEndpointSetup.MatsEndpointSetups
 
value() - Element in annotation interface io.mats3.spring.MatsEndpointSetup
Alias for "endpointId", so that if you only need to set the endpointId, you can do so directly: @MatsEndpointSetup("endpointId")
value() - Element in annotation interface io.mats3.spring.MatsMapping.MatsMappings
 
value() - Element in annotation interface io.mats3.spring.MatsMapping
Alias for "endpointId", so that if you only need to set the endpointId, you can do so directly: @MatsMapping("endpointId")
valueOf(String) - Static method in enum class io.mats3.api.intercept.MatsOutgoingMessage.DispatchType
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.mats3.api.intercept.MatsOutgoingMessage.MessageType
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext.ProcessResult
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.mats3.api.intercept.MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext.StagePreprocessAndDeserializeError
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyInitiator
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyStageProcessor
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor.Level
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.mats3.MatsInitiator.KeepTrace
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.mats3.serial.MatsTrace.Call.CallType
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.mats3.serial.MatsTrace.Call.MessagingModel
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.mats3.serial.MatsTrace.KeepMatsTrace
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.mats3.spring.jms.factories.MatsScenario
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.mats3.test.broker.MatsTestBroker.ActiveMq
Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.mats3.api.intercept.MatsOutgoingMessage.DispatchType
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.mats3.api.intercept.MatsOutgoingMessage.MessageType
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext.ProcessResult
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.mats3.api.intercept.MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext.StagePreprocessAndDeserializeError
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyInitiator
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyStageProcessor
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor.Level
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.mats3.MatsInitiator.KeepTrace
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.mats3.serial.MatsTrace.Call.CallType
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.mats3.serial.MatsTrace.Call.MessagingModel
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.mats3.serial.MatsTrace.KeepMatsTrace
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.mats3.spring.jms.factories.MatsScenario
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.mats3.test.broker.MatsTestBroker.ActiveMq
Returns an array containing the constants of this enum class, 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 MatsTestLatch.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
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
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.
WRONG_MESSAGE_TYPE - Enum constant in enum class io.mats3.api.intercept.MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext.StagePreprocessAndDeserializeError
If the incoming message is not of the message system's expected type (for JMS, it should be MapMessage)
WRONG_STAGE - Enum constant in enum class io.mats3.api.intercept.MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext.StagePreprocessAndDeserializeError
If the incoming Mats message is not intended for this stage.

_

_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 _ 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form