Index
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 theMatsFactory
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)
andBrokerService.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 providedMatsFactory
, notice that theMatsFactory
is not set or provided directly through this class through the use of the constructor or a method. - beforeAll() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
-
Creates an in-vm ActiveMQ Broker which again is utilized to create a
JmsMatsFactory
. - beforeAll(ExtensionContext) - Method in class io.mats3.test.jupiter.Extension_Mats
-
Executed by Jupiter before any test method is executed.
- beforeAll(ExtensionContext) - Method in class io.mats3.test.jupiter.Extension_MatsGeneric
-
Executed by Jupiter before any test method is executed.
- beforeEach(ExtensionContext) - Method in class io.mats3.test.jupiter.Extension_MatsEndpoint
- bindResource(Object, Object) - Static method in class io.mats3.impl.jms.JmsMatsContextLocalCallback
-
Binds a ThreadLocal resource.
- build() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer
-
SOFT DEPRECATED, use
ScenarioConnectionFactoryProducer.createConnectionFactory()
!
C
- cancelOutgoingMessage(String) - Method in interface io.mats3.api.intercept.CommonInterceptOutgoingMessagesContext
-
To remove an outgoing message, you may invoke this method, providing the unique
MatsMessageId
. - CannotInstantiateClassException(String, Throwable) - Constructor for exception io.mats3.impl.jms.JmsMatsFactory.CannotInstantiateClassException
- checkCorrectSetup() - Method in class io.mats3.test.MatsTestBrokerInterface.MatsTestBrokerInterface_JmsMatsFactory
- cleanDatabase() - Method in class io.mats3.test.TestH2DataSource
-
Cleans the test database: Runs SQL
"DROP ALL OBJECTS DELETE FILES"
. - cleanDatabase(boolean) - Method in class io.mats3.test.TestH2DataSource
-
Cleans the test database: Runs SQL
"DROP ALL OBJECTS DELETE FILES"
, and optionally invokesTestH2DataSource.createDataTable()
. - cleanMatsFactories() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
-
Loops through all the
MatsFactory
's contained in this Rule (default + any specifically created), and removes all endpoints from each of them, this ensures that all factories are "clean". - cleanMatsFactory() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
-
Deprecated.
- 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
-
Common part of the interface of
MatsInitiateInterceptor.InitiateCompletedContext
andMatsStageInterceptor.StageCompletedContext
. - CommonCompletedContext.MatsMeasurement - Interface in io.mats3.api.intercept
- CommonCompletedContext.MatsTimingMeasurement - Interface in io.mats3.api.intercept
- CommonInterceptOutgoingMessagesContext - Interface in io.mats3.api.intercept
-
Common elements of intercepting messages for both Initiate and Stage.
- commonStageAndInitiateCompleted(CommonCompletedContext, String, String, String, String, boolean, String, Logger, List<MatsOutgoingMessage.MatsSentOutgoingMessage>, String, String, long, Map<String, String>) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
- commonStageAndInitiateCompleted_inner(CommonCompletedContext, String, String, String, String, boolean, String, String, long, List<MatsOutgoingMessage.MatsSentOutgoingMessage>, MatsMetricsLoggingInterceptor.Level, Logger, Throwable, String, Map<String, String>) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
- 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 inScenarioConnectionFactoryProducer
and handles all the Spring Profiles specified inMatsProfiles
. - 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 theMatsScenario
s, 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 ofConfigurableScenarioDecider
, 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 ordinaryComponentScan
. - 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 byScenarioConnectionFactoryProducer
, 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 overrideConnectionFactoryWrapper.unwrap()
to provide the desiredConnectionFactory
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 toMatsFactory.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()
returnedfalse
. - 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 isDeflater.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 theMats default serializer
- create() - Static method in class io.mats3.test.jupiter.Extension_Mats
-
Creates an
Extension_Mats
utilizing theMATS 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 providedMatsSerializer
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 providedMatsSerializer
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 providedMatsSerializer
. - 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 aRule_Mats
as first argument for fetching theMatsFactory
, 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 aExtension_Mats
as first argument for fetching theMatsFactory
, 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 methodJmsMatsTransactionManager_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 suppliedDataSource
is wrapped using theJmsMatsTransactionManager_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 methodgetDataSource()
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 providedPlatformTransactionManager
(of a type which manages a DataSource) - Do note that you should preferably have theDataSource
within the
wrapped using thePlatformTransactionManager
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 providedPlatformTransactionManager
(of a type which manages a DataSource) - Do note that you should preferably have theDataSource
within the
wrapped using thePlatformTransactionManager
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 fromthis
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 inScenarioConnectionFactoryProducer
and handles all the Spring Profiles specified inMatsProfiles
. - 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 URLTestH2DataSource.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 theSpringJmsMatsFactoryWrapper
. - 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 URLTestH2DataSource.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, usecreateSpringDataSourceTxMatsFactory(..)
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, usecreateSpringDataSourceTxTestMatsFactory(..)
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 ownPlatformTransactionManager
, this is your factory method - please note that the containedDataSource
should have been wrapped using the static methodJmsMatsTransactionManager_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 aPlatformTransactionManager
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 URLTestH2DataSource.IN_MEMORY_TEST_H2_DATABASE_URL
, which is"jdbc:h2:mem:matsTestH2DB_[randomness];DB_CLOSE_DELAY=-1"
, unless the System PropertyTestH2DataSource.SYSPROP_MATS_TEST_H2
("mats.test.h2"
) is directly set to a different URL to use, with the special case that if it isTestH2DataSource.SYSPROP_VALUE_FILE_BASED
("file"
), in which caseTestH2DataSource.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 overrideDataSourceWrapper.unwrap()
to provide the desiredDataSource
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
andMatsEndpointSetup
, 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 aTestH2DataSource
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 creatingMatsFactory
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(..)
andMatsInitiate.getAttribute(..)
methods: If the executing thread is within aMats initiation
, or is currently processing aMatsStage
, the return value will be the same as if the relevantgetAttribute(..)
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 theMatsTrace.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
-
Inspired from Stackoverflow - Denys Séguret.
- getJavaScript(Appendable) - Method in interface io.mats3.localinspect.LocalHtmlInspectForMatsFactory
-
Note: The return from this method is static, and should only be included once per HTML page, no matter how many MatsFactories you display.
- getJavaScript(Appendable) - Method in class io.mats3.localinspect.LocalHtmlInspectForMatsFactoryImpl
-
Note: The return from this method is static, and should only be included once per HTML page, no matter how many MatsFactories you display.
- getJmsConnectionFactory() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
- getJmsMatsJmsSessionHandler() - Method in class io.mats3.impl.jms.JmsMatsFactory
- getJmsMatsTransactionManager() - Method in class io.mats3.impl.jms.JmsMatsFactory
- getJmsSessionHolder() - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext
- getKeepTrace() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
- getKeepTrace() - Method in interface io.mats3.serial.MatsTrace
- getLabelKeyValue() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsMeasurement
- getLabelKeyValue() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsTimingMeasurement
- getLoginTimeout() - Method in class io.mats3.test.TestH2DataSource
- getLoginTimeout() - Method in class io.mats3.util.wrappers.DataSourceWrapper
- getLogWriter() - Method in class io.mats3.test.TestH2DataSource
- getLogWriter() - Method in class io.mats3.util.wrappers.DataSourceWrapper
- getMatsDestinationPrefix() - Method in interface io.mats3.MatsFactory.FactoryConfig
- getMatsFactory() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
- getMatsFuturizer() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
- getMatsImplementationName() - Method in interface io.mats3.MatsFactory.FactoryConfig
- getMatsImplementationVersion() - Method in interface io.mats3.MatsFactory.FactoryConfig
- getMatsInitiator() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
- getMatsInterceptableMatsFactory() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
- getMatsMessageId() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
- getMatsMessageId() - Method in class io.mats3.impl.jms.JmsMatsMessage
- getMatsMessageId() - Method in class io.mats3.impl.jms.JmsMatsProcessContext
- getMatsMessageId() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext
- getMatsMessageId() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
- getMatsMessageId() - Method in interface io.mats3.MatsInitiator.MessageReference
- getMatsMessageId() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
- getMatsMessageId() - Method in interface io.mats3.serial.MatsTrace.Call
- getMatsMessageId() - Method in interface io.mats3.test.MatsTestBrokerInterface.MatsMessageRepresentation
- getMatsScenarioUsedToMakeConnectionFactory() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper
- getMatsSerializer() - Method in class io.mats3.impl.jms.JmsMatsFactory
- getMatsTestBrokerInterface() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
- getMatsTestLatch() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
- getMatsTrace() - Method in class io.mats3.impl.jms.JmsMatsMessage
- getMatsTrace() - Method in interface io.mats3.serial.MatsSerializer.DeserializedMatsTrace
- getMatsTraceBytes() - Method in interface io.mats3.serial.MatsSerializer.SerializedMatsTrace
- getMatsTraceKey() - Method in interface io.mats3.MatsFactory.FactoryConfig
- getMeasure() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsMeasurement
- getMeasurements() - Method in interface io.mats3.api.intercept.CommonCompletedContext
- getMessageClass() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentation
- getMessageClass() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl
- getMessageConsumer() - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext
- getMessageSystemCommitNanos() - Method in interface io.mats3.api.intercept.CommonCompletedContext
- getMessageSystemCommitNanos() - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext
- getMessageSystemDeconstructNanos() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
- getMessageSystemProduceAndSendNanos() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage
- getMessageSystemProduceAndSendNanos() - Method in class io.mats3.impl.jms.JmsMatsMessage
- getMessageSystemTotalWireSize() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage
- getMessageSystemTotalWireSize() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
- getMessageSystemTotalWireSize() - Method in class io.mats3.impl.jms.JmsMatsMessage
- getMessageType() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
- getMessageType() - Method in class io.mats3.impl.jms.JmsMatsMessage
- getMessageType() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.IncomingMessageRepresentationImpl
- getMessageType() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.MessageRepresentation
- getMessageType() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl
- getMessagingModel() - Method in interface io.mats3.serial.MatsTrace.Call.Channel
- getMeta() - Method in interface io.mats3.serial.MatsSerializer.SerializedMatsTrace
- getMetricDescription() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsMeasurement
- getMetricDescription() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsTimingMeasurement
- getMetricId() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsMeasurement
- getMetricId() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsTimingMeasurement
- getName() - Method in interface io.mats3.MatsFactory.FactoryConfig
- getName() - Method in interface io.mats3.MatsInitiator
- getNanos() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsTimingMeasurement
- getNanosCompression() - Method in interface io.mats3.serial.MatsSerializer.SerializedMatsTrace
- getNanosDecompression() - Method in interface io.mats3.serial.MatsSerializer.DeserializedMatsTrace
- getNanosDeserialization() - Method in interface io.mats3.serial.MatsSerializer.DeserializedMatsTrace
- getNanosSerialization() - Method in interface io.mats3.serial.MatsSerializer.SerializedMatsTrace
- getNextStage() - Method in class io.mats3.impl.jms.JmsMatsStage
- getNodename() - Method in interface io.mats3.MatsFactory.FactoryConfig
-
Returns a node-specific identifier, that is, a name which is different between different instances of the same app running of different nodes.
- getNumberOfCpus() - Method in interface io.mats3.MatsFactory.FactoryConfig
- getOrCreateInitiator(String) - Method in class io.mats3.impl.jms.JmsMatsFactory
- getOrCreateInitiator(String) - Method in interface io.mats3.MatsFactory
-
Gets or creates a new Initiator from which to initiate new Mats processes, i.e.
- getOrCreateInitiator(String) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
- getOrCreateInitiator_internal(String) - Method in class io.mats3.impl.jms.JmsMatsFactory
- getOrigin() - Method in interface io.mats3.MatsEndpoint.EndpointConfig
- getOrigin() - Method in interface io.mats3.MatsStage.StageConfig
- getOrWaitForPoolJmsConnection() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.ConnectionWithSessionPool
- getOutgoingMessageCounts() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.InitiatorStats
- getOutgoingMessageCounts() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.StageStats
- getOutgoingMessages() - Method in interface io.mats3.api.intercept.CommonCompletedContext
- getOutgoingMessages() - Method in interface io.mats3.api.intercept.CommonInterceptOutgoingMessagesContext
- getOutstandingPromiseCount() - Method in class io.mats3.util.MatsFuturizer
- getParentEndpoint() - Method in class io.mats3.impl.jms.JmsMatsStage
- getParentEndpoint() - Method in interface io.mats3.MatsStage
- getParentFactory() - Method in class io.mats3.impl.jms.JmsMatsEndpoint
- getParentFactory() - Method in interface io.mats3.MatsEndpoint
- getParentFactory() - Method in interface io.mats3.MatsInitiator
- getParentLogger() - Method in class io.mats3.test.TestH2DataSource
- getParentLogger() - Method in class io.mats3.util.wrappers.DataSourceWrapper
- getParentMatsMessageId() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
- getParentMatsMessageId() - Method in interface io.mats3.serial.MatsTrace
-
If this is a
child flow
of an existing flow, this should return the MatsMessageId of the message whose processing spawned this new flow. - getPassword() - Method in class io.mats3.test.TestH2DataSource
-
Get the current password.
- getPhase() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper
- getPlatformTransactionManager() - Method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx
- getPooledConnection() - Method in class io.mats3.test.TestH2DataSource
- getPooledConnection(String, String) - Method in class io.mats3.test.TestH2DataSource
- getPrecedingSameStackHeightOutgoingTimestamp() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
-
Returns the timestamp of the preceding outgoing message on the same stack height as this stage.
- getProcessContext() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
- getProcessContext() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageInterceptOutgoingMessageContext
- getProcessContext() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageInterceptUserLambdaContext
- getProcessContext() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageReceivedContext
- getProcessResult() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext
- getProcessResultCounts() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.StageStats
- getReadOnlyFromWrappedDataSource() - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper
- getReply() - Method in class io.mats3.util.MatsFuturizer.Reply
- getReplyClass() - Method in interface io.mats3.MatsEndpoint.EndpointConfig
- getReplyFromSpanId() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
- getReplyFromSpanId() - Method in interface io.mats3.serial.MatsTrace.Call
- getReplyStack() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
- getReplyStack() - Method in interface io.mats3.serial.MatsTrace.Call
- getReplyStackHeight() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
- getReplyStackHeight() - Method in interface io.mats3.serial.MatsTrace.Call
- getReplyTo() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
- getReplyTo() - Method in class io.mats3.impl.jms.JmsMatsMessage
- getResource(Object) - Static method in class io.mats3.impl.jms.JmsMatsContextLocalCallback
-
Retrieves a ThreadLocal-bound resource, bound with
JmsMatsContextLocalCallback.bindResource(Object, Object)
. - getRunningStageProcessors() - Method in interface io.mats3.MatsStage.StageConfig
- getSameHeightEndpointEnteredTimestamp() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
- getSameHeightEndpointEnteredTimestamp() - Method in interface io.mats3.serial.MatsTrace
- getSameHeightOutgoingTimestamp() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
- getSameHeightOutgoingTimestamp() - Method in interface io.mats3.serial.MatsTrace
- getSameStackHeightState() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
- getSameStackHeightState() - Method in class io.mats3.impl.jms.JmsMatsMessage
- getSession() - Method in 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 toProcessContext.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
-
Only for
MatsOutgoingMessage.DispatchType.STAGE
. - 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 tillMatsFactory.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 ofMatsInitiator.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 aMatsFactory
). - install(MatsInterceptableMatsFactory) - Static method in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor
-
Creates a
MatsMicrometerInterceptor
employing the providedglobalRegistry
, and installs it as a singleton on the providedMatsInterceptableMatsFactory
- install(MatsInterceptableMatsFactory, MeterRegistry, boolean) - Static method in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor
-
Creates a
MatsMicrometerInterceptor
employing the providedMeterRegistry
, and installs it as a singleton on the providedMatsInterceptableMatsFactory
- 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
andMats3 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 ofScenarioConnectionFactoryProducer
- 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'sTransactionManager
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
andMatsTestInfrastructureConfiguration
. - 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, andTestH2DataSource
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
andJDBC DataSource
- with a special "deferred connection proxy" wrapper which is smart to use as underlying DataSource for the SQL-orientedJmsMatsTransactionManager
s, 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 returntrue
: 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
- uponcreation
, you decide how Connections are shared forJmsMatsStageProcessor
s andMatsInitiator
s. - 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
-
The
JmsMatsTransactionManager.TransactionContext
implementation forJmsMatsTransactionManager_Jms
. - JmsMatsTransactionManager_JmsAndJdbc - Class in io.mats3.impl.jms
-
Implementation of
JmsMatsTransactionManager
that in addition to the JMS transaction also handles a JDBC SQLConnection
(using only pure java, i.e. - JmsMatsTransactionManager_JmsAndJdbc(DataSource) - Constructor for class io.mats3.impl.jms.JmsMatsTransactionManager_JmsAndJdbc
- JmsMatsTransactionManager_JmsAndJdbc.TransactionalContext_JmsAndJdbc - Class in io.mats3.impl.jms
-
The
JmsMatsTransactionManager.TransactionContext
-implementation forJmsMatsTransactionManager_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 SpringPlatformTransactionManager
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 implementsInfrastructureProxy
. - 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 onlocalhost: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
-
Implementation of
LocalHtmlInspectForMatsFactory
. - LocalStatsMatsInterceptor - Class in io.mats3.localinspect
-
Interceptor that collects "local stats" for Initiators and Stages of Endpoints, which can be used in conjunction with a MatsFactory report generator,
LocalHtmlInspectForMatsFactory
. - LocalStatsMatsInterceptor.EndpointStats - Interface in io.mats3.localinspect
- LocalStatsMatsInterceptor.EndpointStatsImpl - Class in io.mats3.localinspect
- LocalStatsMatsInterceptor.IncomingMessageRepresentation - Interface in io.mats3.localinspect
- LocalStatsMatsInterceptor.IncomingMessageRepresentationImpl - Class in io.mats3.localinspect
- LocalStatsMatsInterceptor.InitiatorStats - Interface in io.mats3.localinspect
- LocalStatsMatsInterceptor.MessageRepresentation - Interface in io.mats3.localinspect
- LocalStatsMatsInterceptor.OutgoingMessageRepresentation - Interface in io.mats3.localinspect
- LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl - Class in io.mats3.localinspect
- LocalStatsMatsInterceptor.StageStats - Interface in io.mats3.localinspect
- 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
andMatsStage
have some configurable elements, provided by a config instance, this is the top of that hierarchy. - MatsConfig.StartStoppable - Interface in io.mats3
- 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 theMatsStage
s 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 invokeMatsEndpoint.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 asProcessReturnLambda
- 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 andMatsStage
process context - currentlyMatsFactory.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 theMatsFactory
. - matsFactoryBeanName() - Element in annotation interface io.mats3.spring.MatsEndpointSetup
-
Specified the
MatsFactory
to use by means of specifying the bean name of theMatsFactory
. - matsFactoryBeanName() - Element in annotation interface io.mats3.spring.MatsMapping
-
Specified the
MatsFactory
to use by means of specifying the bean name of theMatsFactory
. - 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 withQualifier
). - 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 withQualifier
). - 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 withQualifier
). - 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 overrideMatsFactory.MatsFactoryWrapper.unwrap()
to provide the desiredMatsFactory
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 theCompletableFuture
is reached (to get yourself a future, use one of thefuturizeXYZ(..)
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
CompletableFuture
s created with theMatsFuturizer
. - 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 overrideMatsInitiator.MatsInitiateWrapper.unwrap()
to provide the desiredMatsInitiator.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 typicallyMatsFactory.getDefaultInitiator()
, and then invokeMatsInitiator.initiate(InitiateLambda)
, where the lambda will provide you with the necessaryMatsInitiator.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 theinitiate
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 theMatsInitiator.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 theMatsInitiator.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 theMatsInitiator.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
andMatsFactory
. - MatsMapping - Annotation Interface in io.mats3.spring
-
A method annotated with this repeatable annotation directly becomes a
Mats Single-stage Endpoint
or aMats 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 ofConfigurableScenarioDecider
. - 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 threeScenarioConnectionFactoryWrapper.ScenarioDecider
s, with an optional default choice. - MatsSerializer<Z> - Interface in io.mats3.serial
-
Defines the operations needed serialize and deserialize
MatsTrace
s 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 usingDeflater
andInflater
. - 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 raisesInvocationTargetException
and the underlying exception is not aRuntimeException
. - 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 byMatsTestInfrastructureDbConfiguration
. - 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 aMatsSerializer
from the Spring context if available, otherwise creates a defaultMatsSerializerJson
. - 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 byMatsTestInfrastructureDbConfiguration.MatsTestH2DataSourceConfiguration
, which uses theTestH2DataSource.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 fromMatsSerializer.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 itsMatsTestBroker.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
-
Only for
MatsOutgoingMessage.DispatchType.STAGE
. - 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
-
Only for
MatsOutgoingMessage.DispatchType.STAGE
. - 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 allMatsMapping
andMatsEndpointSetup
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 overrideMatsEndpoint.ProcessContextWrapper.unwrap()
to provide the desiredMatsEndpoint.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
JmsMatsMessage
s. - 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 byScenarioConnectionFactoryProducer.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
-
Only for
MatsOutgoingMessage.DispatchType.STAGE
. - 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 aSubscriptionTerminator
. - 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 creatingMatsFactory
utilizing an in-vm Active MQ broker, and optionally aTestH2DataSource
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 creatingMatsFactory
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 threeMatsScenario
s are active, and produces the wrapper-targetConnectionFactory
based on that - you most probably want to useScenarioConnectionFactoryProducer
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.ConnectionFactoryProvider
s for each of the threeMatsScenario
s and aScenarioConnectionFactoryWrapper.ScenarioDecider
to decide which of these to employ - you most probably want to useScenarioConnectionFactoryProducer
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
MatsScenario
s. - 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 theMatsEndpoint
). - 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 theinteractive
flag set. - setInteractiveConcurrency(int) - Method in interface io.mats3.MatsEndpoint.EndpointConfig
- setInteractiveConcurrency(int) - Method in interface io.mats3.MatsFactory.FactoryConfig
- setInteractiveConcurrency(int) - Method in interface io.mats3.MatsStage.StageConfig
- setLocalhostDecider(ConfigurableScenarioDecider.SpecificScenarioDecider) - Method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider
- setLocalVmDecider(ConfigurableScenarioDecider.SpecificScenarioDecider) - Method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider
- setLoginTimeout(int) - Method in class io.mats3.test.TestH2DataSource
- setLoginTimeout(int) - Method in class io.mats3.util.wrappers.DataSourceWrapper
- setLogWriter(PrintWriter) - Method in class io.mats3.test.TestH2DataSource
- setLogWriter(PrintWriter) - Method in class io.mats3.util.wrappers.DataSourceWrapper
- setMatsDestinationPrefix(String) - Method in interface io.mats3.MatsFactory.FactoryConfig
-
Sets the prefix that should be applied to the endpointIds to get queue or topic name in the underlying messaging system - the default is
"mats."
. - setMatsFactory(MatsFactory) - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint
-
Set the
MatsFactory
of this classAbstractMatsTestEndpoint._matsFactory
. - setMatsFactory(MatsFactory) - Method in class io.mats3.test.junit.Rule_MatsEndpoint
-
Sets the internal
MatsFactory
to be utilized for the creation of this endpoint. - setMatsFactory(MatsFactory) - Method in class io.mats3.test.jupiter.Extension_MatsEndpoint
-
Sets the internal
MatsFactory
to be utilized for the creation of this endpoint. - setMatsTraceKey(String) - Method in interface io.mats3.MatsFactory.FactoryConfig
-
Sets the key name on which to store the "wire representation" of the Mats message if the underlying mechanism uses some kind of Map - the default is
"mats:trace"
. - setMessageSystemCommitNanos(long) - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext
- setName(String) - Method in interface io.mats3.MatsFactory.FactoryConfig
-
Sets the name of the MatsFactory, default is "" (empty string).
- setNodename(String) - Method in interface io.mats3.MatsFactory.FactoryConfig
-
Sets the nodename that
MatsFactory.FactoryConfig.getNodename()
should return. - setOrigin(String) - Method in interface io.mats3.MatsEndpoint.EndpointConfig
-
Sets the origin for this Endpoint, i.e.
- setOrigin(String) - Method in interface io.mats3.MatsStage.StageConfig
-
Sets the origin for this Stage, i.e.
- setOutgoingTimestamp(long) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
- setOutgoingTimestamp(long) - Method in interface io.mats3.serial.MatsTrace
-
Shall be invoked after adding the outgoing call, immediately before serializing the outgoing MatsTrace.
- setPassword(String) - Method in class io.mats3.test.TestH2DataSource
-
Set the current password.
- setPasswordChars(char[]) - Method in class io.mats3.test.TestH2DataSource
-
Set the current password in the form of a char array.
- setProcessLambda(MatsEndpoint.ProcessSingleLambda<R, I>) - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint
-
Specify the processing lambda to be executed by the endpoint aka the endpoint logic.
- setProcessLambda(MatsEndpoint.ProcessSingleLambda<R, I>) - Method in class io.mats3.test.junit.Rule_MatsEndpoint
- setProcessLambda(MatsEndpoint.ProcessSingleLambda<R, I>) - Method in class io.mats3.test.jupiter.Extension_MatsEndpoint
- setRegularDecider(ConfigurableScenarioDecider.SpecificScenarioDecider) - Method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider
- setSameStackHeightExtraState(String, Object) - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsEditableOutgoingMessage
-
An interceptor might need to add state to an outgoing message which will be present on incoming message of the next stage of a multi-stage endpoint - i.e.
- setSameStackHeightExtraState(String, Object) - Method in class io.mats3.impl.jms.JmsMatsMessage
- setSqlTxConnectionSuppliers(Supplier<Connection>, Supplier<Boolean>) - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext
-
If the current
JmsMatsTransactionManager
is managing a SQL Connection, then it SHALL set a way to get the current transactional SQL Connection, and a way to determine whether the SQL Connection was actually employed (if this is not possible to determine, then return whether it was gotten). - setStageEnteredTimestamp(long) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
- setStageEnteredTimestamp(long) - Method in interface io.mats3.serial.MatsTrace
-
Invoke this as early as possible on the reception of a message.
- setTraceProperty(String, Object) - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsEditableOutgoingMessage
-
Set trace property.
- setTraceProperty(String, Object) - Method in class io.mats3.impl.jms.JmsMatsMessage
- setTraceProperty(String, Object) - Method in class io.mats3.impl.jms.JmsMatsProcessContext
- setTraceProperty(String, Object) - Method in interface io.mats3.MatsEndpoint.ProcessContext
-
Adds a property that will "stick" with the Mats Trace from this call on out.
- setTraceProperty(String, Object) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
- setTraceProperty(String, Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate
-
Adds a property that will "stick" with the call flow from this call on out.
- setTraceProperty(String, Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
- setTraceProperty(String, Z) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
- setTraceProperty(String, Z) - Method in interface io.mats3.serial.MatsTrace
-
Sets a trace property, refer to
ProcessContext.setTraceProperty(String, Object)
. - setUrl(String) - Method in class io.mats3.test.TestH2DataSource
-
Set the current URL.
- setURL(String) - Method in class io.mats3.test.TestH2DataSource
-
Set the current URL.
- setUser(String) - Method in class io.mats3.test.TestH2DataSource
-
Set the current user name.
- setUserLambdaExceptionLogged() - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext
- setWrappee(MatsEndpoint.ProcessContext<R>) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
Sets the wrapped
MatsEndpoint.ProcessContext
, e.g. - setWrappee(MatsFactory) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
-
Sets the wrapped
MatsFactory
, e.g. - setWrappee(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 JUnitRule
or JUnit 5 JupiterRegisterExtension
, and runsbeanFactory.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 (usingJmsMatsTransactionManager_JmsAndSpringManagedSqlTx
, or only theJmsMatsTransactionManager_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 aJmsMatsFactory
via theMatsFactory.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 aMatsEndpoint.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), invokingMatsStage.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 theMatsInitiator
, 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 whatever you started in
ConnectionFactoryWithStartStopWrapper.start(String)
. - 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 allMatsStage
s. - 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, andMatsInitiator.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 valueBoolean.TRUE
, no ordinary log lines should be emitted while initiating or stage processing the Mats Flow, assuming that the implicated endpointsallows
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 foractive 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 foractive 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, theTestH2DataSource.createStandard()
will use the URLTestH2DataSource.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), orMatsMessageSendException
(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 arequest initiation
, or that can be used to directly send a "fire-and-forget" styleinvocation
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()
, andTestH2DataSource.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 theMatsTestBroker
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 callmatsFactory.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 callmatsFactory.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 beresolved
. - 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
-
Very optional: If you do not explicitly set the
ScenarioConnectionFactoryWrapper.ScenarioDecider
using theScenarioConnectionFactoryProducer.withScenarioDecider(ScenarioDecider)
method, you get a defaultConfigurableScenarioDecider.createDefaultScenarioDecider()
. - withLocalhostConnectionFactory(ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer
-
Optional: Provide a ConnectionFactoryProvider lambda for the
LOCALHOST
scenario (which only is meant to be used for development and possibly testing). - withLocalVmConnectionFactory(ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer
-
Very optional: Provide a ConnectionFactoryProvider lambda for the
LOCALVM
scenario (which only is meant to be used for development and testing). - withRegularConnectionFactory(ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider) - Static method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer
-
Creates a
ScenarioConnectionFactoryProducer
, where you need to provide theREGULAR
scenario'sScenarioConnectionFactoryWrapper.ConnectionFactoryProvider
. - withScenarioDecider(ScenarioConnectionFactoryWrapper.ScenarioDecider) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer
-
Can optionally be overridden should you decide to use a different decision-scheme than the
default
. - wrap(DataSource) - Static method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper
- wrapLazyConnectionDatasource(DataSource) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx
-
Creates a proxy/wrapper that has lazy connection getting, and monitoring of whether the connection was actually retrieved.
- 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
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
AbstractMatsTest.cleanMatsFactories()
.