- 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
-
- cleanMatsFactories() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
-
Loops through all the
MatsFactory
's contained in this Rule (default + any specifically created), and
removes all endpoints from each of them, this ensures that all factories are "clean".
- cleanMatsFactory() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
-
- clone() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
-
- cloneForNewCall() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
Takes into account the KeepMatsTrace value.
- close() - Method in class io.mats3.impl.jms.JmsMatsFactory
-
Method for Spring's default lifecycle - directly invokes
stop(30_000)
.
- close() - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler.JmsSessionHolder
-
Employed by StageProcessors: This physically closes the JMS Session, and removes it from the pool-Connection,
and when all Sessions for a given pool-Connection is closed, the pool-Connection is closed.
- close() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl
-
- close() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple
-
- close() - Method in interface io.mats3.MatsFactory
-
Convenience method, particularly for Spring's default destroy mechanism: Default implemented to invoke
stop(30 seconds)
.
- close() - Method in interface io.mats3.MatsInitiator
-
Closes any underlying backend resource.
- close() - Method in interface io.mats3.test.broker.MatsTestBroker
-
- close() - Method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_ActiveMq
-
- close() - Method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_Artemis
-
- close() - Method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_InVmActiveMq
-
- close() - Method in class io.mats3.test.TestH2DataSource
-
Closes the database IF it is a random in-memory URL (as created by
TestH2DataSource.createInMemoryRandom()
,
note:
this method will be picked up by Spring as a destroy-method if the instance is made available as a Bean.
- close() - Method in class io.mats3.util.MatsFuturizer
-
Closes the MatsFuturizer.
- closeAllAvailableSessions() - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler
-
Closes all Available Session, does not touch Employed.
- closeAllAvailableSessions() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling
-
- closeAllAvailableSessions() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple
-
- closeBroker(BrokerService) - Static method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_InVmActiveMq
-
- closeJmsConnection() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.ConnectionWithSessionPool
-
- CommonCompletedContext - Interface in io.mats3.api.intercept
-
- CommonCompletedContext.MatsMeasurement - Interface in io.mats3.api.intercept
-
- CommonCompletedContext.MatsTimingMeasurement - Interface in io.mats3.api.intercept
-
- CommonInterceptOutgoingMessagesContext - Interface in io.mats3.api.intercept
-
Common elements of intercepting messages for both Initiate and Stage.
- commonStageAndInitiateCompleted(CommonCompletedContext, String, String, String, String, boolean, String, Logger, List<MatsOutgoingMessage.MatsSentOutgoingMessage>, String, String, long, Map<String, String>) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
-
- commonStageAndInitiateCompleted_inner(CommonCompletedContext, String, String, String, String, boolean, String, String, long, List<MatsOutgoingMessage.MatsSentOutgoingMessage>, MatsMetricsLoggingInterceptor.Level, Logger, Throwable, String, Map<String, String>) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
-
- compareTo(LocalStatsMatsInterceptor.IncomingMessageRepresentation) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.IncomingMessageRepresentationImpl
-
- compareTo(LocalStatsMatsInterceptor.OutgoingMessageRepresentation) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl
-
- compareTo(MatsFuturizer.Promise<?>) - Method in class io.mats3.util.MatsFuturizer.Promise
-
- ComponentScanExcludingConfigurationForTest - Annotation Type in io.mats3.spring
-
A simple convenience replacement for @ComponentScan which excludes any configuration classes employing the special
@ConfigurationForTest
annotation instead of the standard
@Configuration
annotation.
- compress(byte[]) - Method in class io.mats3.serial.json.MatsSerializerJson
-
- concat(String, String, String) - Static method in class io.mats3.util.TraceId
-
- concat(String, String, String, String) - Static method in class io.mats3.util.TraceId
-
- concat(String) - Method in class io.mats3.util.TraceId
-
- ConfigurableScenarioDecider - Class in io.mats3.spring.jms.factories
-
- ConfigurableScenarioDecider(ConfigurableScenarioDecider.SpecificScenarioDecider, ConfigurableScenarioDecider.SpecificScenarioDecider, ConfigurableScenarioDecider.SpecificScenarioDecider, Supplier<MatsScenario>) - Constructor for class io.mats3.spring.jms.factories.ConfigurableScenarioDecider
-
- ConfigurableScenarioDecider() - Constructor for class io.mats3.spring.jms.factories.ConfigurableScenarioDecider
-
- 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
-
- ConfigurationForTest - Annotation Type in io.mats3.spring
-
An "alias" for the @Configuration annotation which is meant to be used on tests' configuration classes - which then
is excluded from component scanning if the component scan is using
ComponentScanExcludingConfigurationForTest
instead of the ordinary
ComponentScan
.
- configure(Meter.Id, DistributionStatisticConfig) - Method in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor.SuggestedTimingHistogramsMeterFilter
-
- ConnectionFactoryWithStartStopWrapper - Class in io.mats3.spring.jms.factories
-
- ConnectionFactoryWithStartStopWrapper() - Constructor for class io.mats3.spring.jms.factories.ConnectionFactoryWithStartStopWrapper
-
- ConnectionFactoryWrapper - Class in io.mats3.util.wrappers
-
A base Wrapper for a JMS ConnectionFactory
, which simply implements ConnectionFactory, takes a
ConnectionFactory instance and forwards all calls to that.
- ConnectionFactoryWrapper(ConnectionFactory) - Constructor for class io.mats3.util.wrappers.ConnectionFactoryWrapper
-
Standard constructor, taking the wrapped ConnectionFactory
instance.
- ConnectionFactoryWrapper() - Constructor for class io.mats3.util.wrappers.ConnectionFactoryWrapper
-
- 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
-
- ContextLocal() - Constructor for class io.mats3.MatsFactory.ContextLocal
-
- CouldNotGetConnectionFactoryFromProviderException(String, Throwable) - Constructor for exception io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper.CouldNotGetConnectionFactoryFromProviderException
-
- CouldNotStartConnectionFactoryWithStartStopWrapperException(String, Throwable) - Constructor for exception io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper.CouldNotStartConnectionFactoryWithStartStopWrapperException
-
- CouldNotStopConnectionFactoryWithStartStopWrapperException(String, Throwable) - Constructor for exception io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper.CouldNotStopConnectionFactoryWithStartStopWrapperException
-
- crashed(Throwable) - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler.JmsSessionHolder
-
Notifies that a Session (or "downstream" consumer or producer) raised some exception - probably due to some
connectivity issues experienced as a JMSException while interacting with the JMS API, or because the
JmsMatsJmsSessionHandler.JmsSessionHolder.isSessionOk()
returned
false
.
- crashed(Throwable) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl
-
- crashed(Throwable) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple
-
- create(ConnectionFactory) - Static method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling
-
Returns a JmsMatsJmsSessionHandler which employs a single JMS Connection for everything: Initiations, and all
Stages (consumers and producers).
- create(ConnectionFactory, JmsMatsJmsSessionHandler_Pooling.PoolingKeyInitiator, JmsMatsJmsSessionHandler_Pooling.PoolingKeyStageProcessor) - Static method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling
-
Returns a JmsMatsJmsSessionHandler which have specific pooling derivation.
- create(ConnectionFactory) - Static method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple
-
- create() - Static method in class io.mats3.impl.jms.JmsMatsTransactionManager_Jms
-
- create(DataSource) - Static method in class io.mats3.impl.jms.JmsMatsTransactionManager_JmsAndJdbc
-
- create(MatsFactory) - Static method in interface io.mats3.localinspect.LocalHtmlInspectForMatsFactory
-
- create(MatsFactory) - Static method in class io.mats3.localinspect.LocalHtmlInspectForMatsFactoryImpl
-
- create() - Static method in class io.mats3.serial.json.MatsSerializerJson
-
- create(int) - Static method in class io.mats3.serial.json.MatsSerializerJson
-
Constructs a MatsSerializer, using the specified Compression Level - refer to Deflater
's constants and
levels.
- create(DataSource) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx
-
- create(DataSource, Function<JmsMatsTransactionManager.JmsMatsTxContextKey, DefaultTransactionDefinition>) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx
-
- create(PlatformTransactionManager) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx
-
- create(PlatformTransactionManager, Function<JmsMatsTransactionManager.JmsMatsTxContextKey, DefaultTransactionDefinition>) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx
-
Creates an instance of this class from a provided PlatformTransactionManager
(of a type which manages a
DataSource), where the supplied instance is introspected to find a method getDataSource()
from where
to get the underlying DataSource.
- create(PlatformTransactionManager, DataSource) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx
-
- create(PlatformTransactionManager, DataSource, Function<JmsMatsTransactionManager.JmsMatsTxContextKey, DefaultTransactionDefinition>) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx
-
- create() - Static method in interface io.mats3.test.broker.MatsTestBroker
-
- create() - Static method in class io.mats3.test.junit.Rule_Mats
-
- create(MatsSerializer<String>) - Static method in class io.mats3.test.junit.Rule_Mats
-
- create(String, Class<R>, Class<I>) - Static method in class io.mats3.test.junit.Rule_MatsEndpoint
-
Creates a JUnit Rule for a single-staged endpoint whose processor is not defined at start.
- create(Rule_Mats, String, Class<R>, Class<I>) - Static method in class io.mats3.test.junit.Rule_MatsEndpoint
-
- create(MatsSerializer<Z>) - Static method in class io.mats3.test.junit.Rule_MatsGeneric
-
- create() - Static method in class io.mats3.test.jupiter.Extension_Mats
-
- create(MatsSerializer<String>) - Static method in class io.mats3.test.jupiter.Extension_Mats
-
- create(String, Class<R>, Class<I>) - Static method in class io.mats3.test.jupiter.Extension_MatsEndpoint
-
Creates a Jupiter Extension for a single-staged endpoint whose processor is not defined at start.
- create(Extension_Mats, String, Class<R>, Class<I>) - Static method in class io.mats3.test.jupiter.Extension_MatsEndpoint
-
- create(MatsSerializer<Z>) - Static method in class io.mats3.test.jupiter.Extension_MatsGeneric
-
- create(ConnectionFactory, MatsFactory) - Static method in interface io.mats3.test.MatsTestBrokerInterface
-
If you have both the JMS ConnectionFactory and a JmsMatsFactory available from start, then you can create a
working instance right away.
- create(String) - Static method in class io.mats3.test.TestH2DataSource
-
- create(String, String) - Static method in class io.mats3.util.TraceId
-
- create(String, String, String) - Static method in class io.mats3.util.TraceId
-
- createActiveMQConnectionFactory(String) - Static method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_InVmActiveMq
-
- createArtemisBroker(String) - Static method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_Artemis
-
- createArtemisBroker_Should_Be_Individual_DLQs_But_Does_Not_Work(String) - Static method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_Artemis
-
This is an attempt to get Artemis to use the "separate DLQ per queue" solution.
- createConnection() - Method in class io.mats3.util.wrappers.ConnectionFactoryWrapper
-
- createConnection(String, String) - Method in class io.mats3.util.wrappers.ConnectionFactoryWrapper
-
- createDataTable() - Method in class io.mats3.test.TestH2DataSource
-
Creates a test "datatable", runs SQL "CREATE TABLE datatable ( data VARCHAR )"
, using a SQL
Connection from this
DataSource.
- createDataTable(Connection) - Static method in class io.mats3.test.TestH2DataSource
-
Creates a test "datatable", runs SQL "CREATE TABLE datatable ( data VARCHAR )"
, using the provided
SQL Connection.
- createDefaultScenarioDecider() - Static method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider
-
- 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
-
- createFlowId(long) - Method in interface io.mats3.impl.jms.JmsMatsStatics
-
- createForLaterPopulation() - Static method in interface io.mats3.test.MatsTestBrokerInterface
-
- 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
-
- createInVmActiveMqBroker() - Static method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_InVmActiveMq
-
- createJmsTxOnlyMatsFactory(String, String, MatsSerializer<?>, ConnectionFactory) - Static method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryProducer
-
If you need a
MatsFactory
that only handles the JMS transactions, this is your factory method - but if
you DO make any database calls within any Mats endpoint lambda, you will now have no or poor transactional
demarcation, use
createSpringDataSourceTxMatsFactory(..)
instead.
- createJmsTxOnlyTestMatsFactory(int, MatsSerializer<?>) - Static method in class io.mats3.spring.test.TestSpringMatsFactoryProvider
-
If you need a
MatsFactory
that only handles the JMS transactions, this is your factory method - but if
you DO make any database calls within any Mats endpoint lambda, you will now have no or poor transactional
demarcation, use
createSpringDataSourceTxTestMatsFactory(..)
instead.
- createJmsTxOnlyTestMatsFactory(MatsSerializer<?>) - Static method in class io.mats3.spring.test.TestSpringMatsFactoryProvider
-
- createMatsFactory(String, String, JmsMatsJmsSessionHandler, JmsMatsTransactionManager, MatsSerializer<Z>) - Static method in class io.mats3.impl.jms.JmsMatsFactory
-
- createMatsFactory() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
-
- 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
-
- createNewMatsTrace(String, String, MatsTrace.KeepMatsTrace, boolean, boolean, long, boolean) - Method in class io.mats3.serial.json.MatsSerializerJson
-
- createNewMatsTrace(String, String, MatsTrace.KeepMatsTrace, boolean, boolean, long, boolean) - Method in interface io.mats3.serial.MatsSerializer
-
Used when initiating a new Mats flow.
- createSpringDataSourceTxMatsFactory(String, String, MatsSerializer<?>, ConnectionFactory, DataSource) - Static method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryProducer
-
If you need a
MatsFactory
employing Spring's DataSourceTransactionManager (which you probably do in a
Spring environment utilizing SQL), this is your factory method.
- createSpringDataSourceTxTestMatsFactory(int, DataSource, MatsSerializer<?>) - Static method in class io.mats3.spring.test.TestSpringMatsFactoryProvider
-
If you need a
MatsFactory
employing Spring's DataSourceTransactionManager (which you probably do in a
Spring environment utilizing SQL), this is your factory method.
- createSpringDataSourceTxTestMatsFactory(DataSource, MatsSerializer<?>) - Static method in class io.mats3.spring.test.TestSpringMatsFactoryProvider
-
- createSpringDataSourceTxTestMatsFactory(int, PlatformTransactionManager, MatsSerializer<?>) - Static method in class io.mats3.spring.test.TestSpringMatsFactoryProvider
-
- createSpringDataSourceTxTestMatsFactory(PlatformTransactionManager, MatsSerializer<?>) - Static method in class io.mats3.spring.test.TestSpringMatsFactoryProvider
-
- createSpringPlatformTransactionManagerTxMatsFactory(String, String, MatsSerializer<?>, ConnectionFactory, PlatformTransactionManager) - Static method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryProducer
-
If you need a
MatsFactory
employing a
PlatformTransactionManager
of your choosing, which you
quite possibly want in a Spring environment using e.g.
- createStageReport(Appendable, MatsStage<?, ?, ?>) - Method in interface io.mats3.localinspect.LocalHtmlInspectForMatsFactory
-
Creates the report of a single stage.
- createStageReport(Appendable, MatsStage<?, ?, ?>) - Method in class io.mats3.localinspect.LocalHtmlInspectForMatsFactoryImpl
-
- createStandard() - Static method in class io.mats3.test.TestH2DataSource
-
- createTargetConnectionFactoryBasedOnScenarioDecider() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper
-
- createUniqueInVmActiveMq() - Static method in interface io.mats3.test.broker.MatsTestBroker
-
This is a special factory method, which creates a unique (randomly named) in-vm ActiveMQ instance, no matter what
the system properties says.
- createWithDb() - Static method in class io.mats3.test.junit.Rule_Mats
-
- createWithDb(MatsSerializer<String>) - Static method in class io.mats3.test.junit.Rule_Mats
-
- createWithDb(MatsSerializer<Z>) - Static method in class io.mats3.test.junit.Rule_MatsGeneric
-
- createWithDb() - Static method in class io.mats3.test.jupiter.Extension_Mats
-
- createWithDb(MatsSerializer<String>) - Static method in class io.mats3.test.jupiter.Extension_Mats
-
- createWithDb(MatsSerializer<Z>) - Static method in class io.mats3.test.jupiter.Extension_MatsGeneric
-
- get(Environment) - Method in interface io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider
-
- getAppName() - Method in interface io.mats3.MatsFactory.FactoryConfig
-
- getAppVersion() - Method in interface io.mats3.MatsFactory.FactoryConfig
-
- getAttribute(Class<T>, String...) - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- getAttribute(String) - Method in interface io.mats3.MatsConfig
-
- getAttribute(Class<T>, String...) - Method in interface io.mats3.MatsEndpoint.ProcessContext
-
Provides a way to get hold of (optional) attributes/objects from the Mats implementation, either specific to
the Mats implementation in use, or configured into this instance of the Mats implementation.
- getAttribute(Class<T>, String...) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- getAttribute(Class<T>, String...) - Static method in class io.mats3.MatsFactory.ContextLocal
-
- getAttribute(Class<T>, String...) - Method in interface io.mats3.MatsInitiator.MatsInitiate
-
Provides a way to get hold of (optional) attributes/objects from the Mats implementation, either specific to
the Mats implementation in use, or configured into this instance of the Mats implementation.
- getAttribute(Class<T>, String...) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
-
- getAutoCommitFromWrappedDataSource() - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper
-
- getBaseUnit() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsMeasurement
-
- getBetweenStagesTimeNanos() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.StageStats
-
- getBytes(String) - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- getBytes(String) - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getBytes(String) - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- getBytes(String) - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext
-
Get binary "sideloads" from the incoming message.
- getBytes(String) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- getBytesKeys() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- getBytesKeys() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getBytesKeys() - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- getBytesKeys() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext
-
- getBytesKeys() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- getCalledTimestamp() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
-
- getCalledTimestamp() - Method in interface io.mats3.serial.MatsTrace.Call
-
- getCallFlow() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getCallFlow() - Method in interface io.mats3.serial.MatsTrace
-
- getCallingAppName() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
-
- getCallingAppName() - Method in interface io.mats3.serial.MatsTrace.Call
-
- getCallingAppVersion() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
-
- getCallingAppVersion() - Method in interface io.mats3.serial.MatsTrace.Call
-
- getCallingHost() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
-
- getCallingHost() - Method in interface io.mats3.serial.MatsTrace.Call
-
- getCallNumber() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getCallNumber() - Method in interface io.mats3.serial.MatsTrace
-
- getCallType() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
-
- getCallType() - Method in interface io.mats3.serial.MatsTrace.Call
-
- getChildrenStartStoppable() - Method in class io.mats3.impl.jms.JmsMatsEndpoint
-
- getChildrenStartStoppable() - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- getChildrenStartStoppable() - Method in class io.mats3.impl.jms.JmsMatsStage
-
- getChildrenStartStoppable() - Method in interface io.mats3.impl.jms.JmsMatsStartStoppable
-
Must be implemented to provide your children.
- getClassLogger() - Static method in class io.mats3.test.MatsTestHelp
-
- getCompleterThreadPool() - Method in class io.mats3.util.MatsFuturizer
-
- getConcurrency() - Method in interface io.mats3.MatsConfig
-
Returns the concurrency set up for this factory, or endpoint, or stage.
- getConnection() - Method in class io.mats3.test.TestH2DataSource
-
- getConnection(String, String) - Method in class io.mats3.test.TestH2DataSource
-
- getConnection() - Method in class io.mats3.util.wrappers.DataSourceWrapper
-
- getConnection(String, String) - Method in class io.mats3.util.wrappers.DataSourceWrapper
-
- getConnection() - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper
-
- getConnection(String, String) - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper
-
- getConnectionFactory() - Method in interface io.mats3.test.broker.MatsTestBroker
-
- getConnectionFactory() - Method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_ActiveMq
-
- getConnectionFactory() - Method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_Artemis
-
- getConnectionFactory() - Method in class io.mats3.test.broker.MatsTestBroker.MatsTestBroker_InVmActiveMq
-
- getContext() - Method in interface io.mats3.test.MatsTestLatch.Result
-
- getContext() - Method in class io.mats3.util.MatsFuturizer.Reply
-
- getCurrentCall() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getCurrentCall() - Method in interface io.mats3.serial.MatsTrace
-
- getCurrentSpanId() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getCurrentSpanId() - Method in interface io.mats3.serial.MatsTrace
-
- getCurrentState() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getCurrentState() - Method in interface io.mats3.serial.MatsTrace
-
- getData() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- getData() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getData() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
-
- getData() - Method in interface io.mats3.serial.MatsTrace.Call
-
- getData() - Method in interface io.mats3.test.MatsTestLatch.Result
-
- getDataAndStateDeserializationNanos() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
-
- getDataFromDataTable() - Method in class io.mats3.test.TestH2DataSource
-
- getDataFromDataTable(Connection) - Static method in class io.mats3.test.TestH2DataSource
-
- getDataSerializedSize() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage
-
- getDataSerializedSize() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
-
- getDataSerializedSize() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getDataSource() - Method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx
-
- getDataSource() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
-
- getDataSource() - Method in class io.mats3.test.junit.Rule_Mats
-
- getDataSource() - Method in class io.mats3.test.junit.Rule_MatsGeneric
-
- getDataSource() - Method in class io.mats3.test.jupiter.Extension_MatsGeneric
-
- getDataSourceUnwrapped() - Method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx
-
- getDbCommitNanos() - Method in interface io.mats3.api.intercept.CommonCompletedContext
-
- getDbCommitNanos() - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext
-
- getDebugInfo() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
-
- getDebugInfo() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getDebugInfo() - Method in interface io.mats3.serial.MatsTrace.Call
-
- getDebugInfo() - Method in interface io.mats3.serial.MatsTrace
-
- getDefaultInitiator() - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- getDefaultInitiator() - Method in interface io.mats3.MatsFactory
-
Gets or creates the default Initiator (whose name is 'default') from which to initiate new Mats processes, i.e.
- getDefaultInitiator() - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
-
- getDefaultNoDestinationMessageProducer() - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler.JmsSessionHolder
-
- getDefaultNoDestinationMessageProducer() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl
-
- getDefaultNoDestinationMessageProducer() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple
-
- getDescription() - Method in class io.mats3.test.TestH2DataSource
-
Get the current description.
- getDispatchType() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- getDispatchType() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getDlqMessage(String) - Method in interface io.mats3.test.MatsTestBrokerInterface
-
Waits a couple of seconds for a message to appear on the Dead Letter Queue for the provided endpoint- or stageId
(Queue name "DLQ."+matsendpointPrefix+endpointOrStageId) - and also checks the standard common ActiveMQ DLQ
(Queue name "ActiveMQ.DLQ") in case the broker is not configured with specific DLQs per Queue, which is relevant
if you fire up an unmodified ActiveMQ distribution on the command line, check the MatsTestBroker
class
JavaDoc for how to use an external MQ instead of the in-VM which otherwise is fired up.
- getDlqMessage(String) - Method in class io.mats3.test.MatsTestBrokerInterface.MatsTestBrokerInterface_JmsMatsFactory
-
Waits a couple of seconds for a message to appear on the Dead Letter Queue for the provided endpoint- or
stageId (Queue name "DLQ."+matsendpointPrefix+endpointOrStageId) - and also checks the standard common
ActiveMQ DLQ (Queue name "ActiveMQ.DLQ") in case the broker is not configured with specific DLQs per Queue,
which is relevant if you fire up an unmodified ActiveMQ distribution on the command line, check the
MatsTestBroker
class JavaDoc for how to use an external MQ instead of the in-VM which otherwise is
fired up.
- getEndpoint(String) - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- getEndpoint(String) - Method in interface io.mats3.MatsFactory
-
- getEndpoint(String) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
-
- getEndpointConfig() - Method in class io.mats3.impl.jms.JmsMatsEndpoint
-
- getEndpointConfig() - Method in interface io.mats3.MatsEndpoint
-
- getEndpointEnteredTimestamp() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
-
Returns the timestamp when the initial stage of the Endpoint which this Stage belongs to, was entered.
- getEndpointId() - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- getEndpointId() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext
-
- getEndpointId() - Method in interface io.mats3.MatsEndpoint.EndpointConfig
-
- getEndpointId() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- getEndpoints() - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- getEndpoints() - Method in interface io.mats3.MatsFactory
-
- getEndpoints() - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
-
- getEndpointStats(MatsEndpoint<?, ?>) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor
-
- getEnvelopeCompressionNanos() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage
-
- getEnvelopeCompressionNanos() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getEnvelopeDecompressionNanos() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
-
- getEnvelopeDeserializationNanos() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
-
- getEnvelopeProduceNanos() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage
-
- getEnvelopeProduceNanos() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getEnvelopeSerializationNanos() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage
-
- getEnvelopeSerializationNanos() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getEnvelopeSerializedSize() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage
-
- getEnvelopeSerializedSize() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
-
- getEnvelopeSerializedSize() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getEnvelopeWireSize() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage
-
- getEnvelopeWireSize() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
-
- getEnvelopeWireSize() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getExtraState(String) - Method in interface io.mats3.serial.MatsTrace.StackState
-
Retrieves "extra state" on this StackState.
- getFactory() - Method in interface io.mats3.impl.jms.JmsMatsTransactionManager.JmsMatsTxContextKey
-
- getFactoryConfig() - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- getFactoryConfig() - Method in interface io.mats3.MatsFactory
-
- getFactoryConfig() - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
-
- getFlowId() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- getFlowId() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getFlowId() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getFlowId() - Method in interface io.mats3.serial.MatsTrace
-
- getFrom() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- 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
-
- 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
-
- getInitiatorToTerminatorTimeNanos() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStatsImpl
-
- getInteractiveConcurrency() - Method in interface io.mats3.MatsConfig
-
Returns the interactive concurrency set up for this factory, or endpoint, or stage.
- getInterceptContextAttribute(String) - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
-
- getInvocationPoint() - Method in interface io.mats3.impl.jms.JmsMatsStatics
-
- getJavaScript(Appendable) - Method in interface io.mats3.localinspect.LocalHtmlInspectForMatsFactory
-
Note: The return from this method is static, and should only be included once per HTML page, no matter how many
MatsFactories you display.
- getJavaScript(Appendable) - Method in class io.mats3.localinspect.LocalHtmlInspectForMatsFactoryImpl
-
Note: The return from this method is static, and should only be included once per HTML page, no matter how many
MatsFactories you display.
- getJmsConnectionFactory() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
-
- getJmsMatsJmsSessionHandler() - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- getJmsMatsTransactionManager() - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- getJmsSessionHolder() - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext
-
- getKeepTrace() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getKeepTrace() - Method in interface io.mats3.serial.MatsTrace
-
- getLabelKeyValue() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsMeasurement
-
- getLabelKeyValue() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsTimingMeasurement
-
- getLoginTimeout() - Method in class io.mats3.test.TestH2DataSource
-
- getLoginTimeout() - Method in class io.mats3.util.wrappers.DataSourceWrapper
-
- getLogWriter() - Method in class io.mats3.test.TestH2DataSource
-
- getLogWriter() - Method in class io.mats3.util.wrappers.DataSourceWrapper
-
- getMatsDestinationPrefix() - Method in interface io.mats3.MatsFactory.FactoryConfig
-
- getMatsFactory() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
-
- getMatsFuturizer() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
-
- getMatsImplementationName() - Method in interface io.mats3.MatsFactory.FactoryConfig
-
- getMatsImplementationVersion() - Method in interface io.mats3.MatsFactory.FactoryConfig
-
- getMatsInitiator() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
-
- getMatsInterceptableMatsFactory() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
-
- getMatsMessageId() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- getMatsMessageId() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getMatsMessageId() - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- getMatsMessageId() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext
-
- getMatsMessageId() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- getMatsMessageId() - Method in interface io.mats3.MatsInitiator.MessageReference
-
- getMatsMessageId() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
-
- getMatsMessageId() - Method in interface io.mats3.serial.MatsTrace.Call
-
- getMatsMessageId() - Method in interface io.mats3.test.MatsTestBrokerInterface.MatsMessageRepresentation
-
- getMatsScenarioUsedToMakeConnectionFactory() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper
-
- getMatsSerializer() - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- getMatsTestBrokerInterface() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
-
- getMatsTestLatch() - Method in class io.mats3.test.abstractunit.AbstractMatsTest
-
- getMatsTrace() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getMatsTrace() - Method in interface io.mats3.serial.MatsSerializer.DeserializedMatsTrace
-
- getMatsTraceBytes() - Method in interface io.mats3.serial.MatsSerializer.SerializedMatsTrace
-
- getMatsTraceKey() - Method in interface io.mats3.MatsFactory.FactoryConfig
-
- getMeasure() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsMeasurement
-
- getMeasurements() - Method in interface io.mats3.api.intercept.CommonCompletedContext
-
- getMessageClass() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentation
-
- getMessageClass() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl
-
- getMessageConsumer() - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext
-
- getMessageSystemCommitNanos() - Method in interface io.mats3.api.intercept.CommonCompletedContext
-
- getMessageSystemCommitNanos() - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext
-
- getMessageSystemDeconstructNanos() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
-
- getMessageSystemProduceAndSendNanos() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage
-
- getMessageSystemProduceAndSendNanos() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getMessageSystemTotalWireSize() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage
-
- getMessageSystemTotalWireSize() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
-
- getMessageSystemTotalWireSize() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getMessageType() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- getMessageType() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getMessageType() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.IncomingMessageRepresentationImpl
-
- getMessageType() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.MessageRepresentation
-
- getMessageType() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl
-
- getMessagingModel() - Method in interface io.mats3.serial.MatsTrace.Call.Channel
-
- getMeta() - Method in interface io.mats3.serial.MatsSerializer.SerializedMatsTrace
-
- getMetricDescription() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsMeasurement
-
- getMetricDescription() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsTimingMeasurement
-
- getMetricId() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsMeasurement
-
- getMetricId() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsTimingMeasurement
-
- getName() - Method in interface io.mats3.MatsFactory.FactoryConfig
-
- getName() - Method in interface io.mats3.MatsInitiator
-
- getNanos() - Method in interface io.mats3.api.intercept.CommonCompletedContext.MatsTimingMeasurement
-
- getNanosCompression() - Method in interface io.mats3.serial.MatsSerializer.SerializedMatsTrace
-
- getNanosDecompression() - Method in interface io.mats3.serial.MatsSerializer.DeserializedMatsTrace
-
- getNanosDeserialization() - Method in interface io.mats3.serial.MatsSerializer.DeserializedMatsTrace
-
- getNanosSerialization() - Method in interface io.mats3.serial.MatsSerializer.SerializedMatsTrace
-
- getNextStage() - Method in class io.mats3.impl.jms.JmsMatsStage
-
- getNodename() - Method in interface io.mats3.MatsFactory.FactoryConfig
-
Returns a node-specific identifier, that is, a name which is different between different instances of the
same app running of different nodes.
- getNumberOfCpus() - Method in interface io.mats3.MatsFactory.FactoryConfig
-
- getOrCreateInitiator(String) - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- getOrCreateInitiator(String) - Method in interface io.mats3.MatsFactory
-
Gets or creates a new Initiator from which to initiate new Mats processes, i.e.
- getOrCreateInitiator(String) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
-
- getOrCreateInitiator_internal(String) - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- getOrigin() - Method in interface io.mats3.MatsEndpoint.EndpointConfig
-
- getOrigin() - Method in interface io.mats3.MatsStage.StageConfig
-
- getOrWaitForPoolJmsConnection() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.ConnectionWithSessionPool
-
- getOutgoingMessageCounts() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.InitiatorStats
-
- getOutgoingMessageCounts() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.StageStats
-
- getOutgoingMessages() - Method in interface io.mats3.api.intercept.CommonCompletedContext
-
- getOutgoingMessages() - Method in interface io.mats3.api.intercept.CommonInterceptOutgoingMessagesContext
-
- getOutstandingPromiseCount() - Method in class io.mats3.util.MatsFuturizer
-
- getParentEndpoint() - Method in class io.mats3.impl.jms.JmsMatsStage
-
- getParentEndpoint() - Method in interface io.mats3.MatsStage
-
- getParentFactory() - Method in class io.mats3.impl.jms.JmsMatsEndpoint
-
- getParentFactory() - Method in interface io.mats3.MatsEndpoint
-
- getParentFactory() - Method in interface io.mats3.MatsInitiator
-
- getParentLogger() - Method in class io.mats3.test.TestH2DataSource
-
- getParentLogger() - Method in class io.mats3.util.wrappers.DataSourceWrapper
-
- getParentMatsMessageId() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getParentMatsMessageId() - Method in interface io.mats3.serial.MatsTrace
-
If this is a
child flow
of an existing flow, this should return the
MatsMessageId of the message whose processing spawned this new flow.
- getPassword() - Method in class io.mats3.test.TestH2DataSource
-
Get the current password.
- getPhase() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper
-
- getPlatformTransactionManager() - Method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx
-
- getPooledConnection() - Method in class io.mats3.test.TestH2DataSource
-
- getPooledConnection(String, String) - Method in class io.mats3.test.TestH2DataSource
-
- getPrecedingSameStackHeightOutgoingTimestamp() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
-
Returns the timestamp of the preceding outgoing message on the same stack height as this stage.
- getProcessContext() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
-
- getProcessContext() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageInterceptOutgoingMessageContext
-
- getProcessContext() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageInterceptUserLambdaContext
-
- getProcessContext() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageReceivedContext
-
- getProcessResult() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext
-
- getProcessResultCounts() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.StageStats
-
- getReadOnlyFromWrappedDataSource() - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper
-
- getReply() - Method in class io.mats3.util.MatsFuturizer.Reply
-
- getReplyClass() - Method in interface io.mats3.MatsEndpoint.EndpointConfig
-
- getReplyFromSpanId() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
-
- getReplyFromSpanId() - Method in interface io.mats3.serial.MatsTrace.Call
-
- getReplyStack() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
-
- getReplyStack() - Method in interface io.mats3.serial.MatsTrace.Call
-
- getReplyStackHeight() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
-
- getReplyStackHeight() - Method in interface io.mats3.serial.MatsTrace.Call
-
- getReplyTo() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- getReplyTo() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getResource(Object) - Static method in class io.mats3.impl.jms.JmsMatsContextLocalCallback
-
- getRunningStageProcessors() - Method in interface io.mats3.MatsStage.StageConfig
-
- getSameHeightEndpointEnteredTimestamp() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getSameHeightEndpointEnteredTimestamp() - Method in interface io.mats3.serial.MatsTrace
-
- getSameHeightOutgoingTimestamp() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getSameHeightOutgoingTimestamp() - Method in interface io.mats3.serial.MatsTrace
-
- getSameStackHeightState() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- getSameStackHeightState() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getSession() - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler.JmsSessionHolder
-
- getSession() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl
-
- getSession() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple
-
- getSessionHolder(JmsMatsInitiator<?>) - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler
-
Will be invoked every time an Initiator wants to send a message - it will be returned after the message(s) is
sent.
- getSessionHolder(JmsMatsStageProcessor<?, ?, ?, ?>) - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler
-
Will be invoked before the StageProcessor goes into its consumer loop - it will be closed once the Stage is
stopped, or if the Session "crashes", i.e.
- getSessionHolder(JmsMatsInitiator<?>) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling
-
- getSessionHolder(JmsMatsStageProcessor<?, ?, ?, ?>) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling
-
- getSessionHolder(JmsMatsInitiator<?>) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple
-
- getSessionHolder(JmsMatsStageProcessor<?, ?, ?, ?>) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple
-
- getSessionHolder_internal(JmsMatsTransactionManager.JmsMatsTxContextKey) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling
-
- getSessionHolder_internal(JmsMatsTransactionManager.JmsMatsTxContextKey) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple
-
- getSizeCompressed() - Method in interface io.mats3.serial.MatsSerializer.SerializedMatsTrace
-
- getSizeDecompressed() - Method in interface io.mats3.serial.MatsSerializer.DeserializedMatsTrace
-
- getSizeIncoming() - Method in interface io.mats3.serial.MatsSerializer.DeserializedMatsTrace
-
- getSizeUncompressed() - Method in interface io.mats3.serial.MatsSerializer.SerializedMatsTrace
-
- getSpentQueueTimeNanos() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.StageStats
-
Note: Only has millisecond resolution, AND is susceptible to time skews between nodes (uses
System.currentTimeMillis()
on the sending and receiving node).
- getStage() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageInterceptContext
-
- getStage() - Method in interface io.mats3.impl.jms.JmsMatsTransactionManager.JmsMatsTxContextKey
-
- getStageConfig() - Method in class io.mats3.impl.jms.JmsMatsStage
-
- getStageConfig() - Method in interface io.mats3.MatsStage
-
- getStageId() - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- getStageId() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext
-
- getStageId() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- getStageId() - Method in interface io.mats3.MatsStage.StageConfig
-
- getStageIndex() - Method in interface io.mats3.MatsStage.StageConfig
-
- getStageInitiatedMessages() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext
-
- getStageInterceptor(Class<T>) - Method in interface io.mats3.api.intercept.MatsInterceptable
-
- getStageInterceptor(Class<T>) - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- getStageInterceptor(Class<T>) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper
-
- getStageInterceptors() - Method in interface io.mats3.api.intercept.MatsInterceptable
-
- getStageInterceptors() - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- getStageInterceptors() - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper
-
- getStagePreprocessAndDeserializeError() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext
-
- getStageRequestMessages() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext
-
- getStageResultMessage() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext
-
- getStages() - Method in class io.mats3.impl.jms.JmsMatsEndpoint
-
- getStages() - Method in interface io.mats3.MatsEndpoint
-
- getStagesMap() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStatsImpl
-
- getStagesStats() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStats
-
- getStagesStats() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStatsImpl
-
- getStageStats(MatsStage<?, ?, ?>) - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStats
-
- getStageStats(MatsStage<?, ?, ?>) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStatsImpl
-
- getStageStats(MatsStage<?, ?, ?>) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor
-
- getStageTotalExecutionTimeNanos() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.StageStats
-
- getStandardTransactionDefinitionFunctionFor(Class<? extends PlatformTransactionManager>) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx
-
Returns the standard TransactionDefinition Function for the supplied PlatformTransactionManager.
- getStartedInstant() - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor.InitiateInterceptContext
-
- getStartedInstant() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageInterceptContext
-
- getStartedNanoTime() - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor.InitiateInterceptContext
-
- getStartedNanoTime() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageInterceptContext
-
- getState() - Method in interface io.mats3.serial.MatsTrace.StackState
-
- getState() - Method in interface io.mats3.test.MatsTestLatch.Result
-
- getStateClass() - Method in interface io.mats3.MatsEndpoint.EndpointConfig
-
- getStateFlow() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getStateFlow() - Method in interface io.mats3.serial.MatsTrace
-
- getStateSerializedSize() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
-
- getStateStack() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getStateStack() - Method in interface io.mats3.serial.MatsTrace
-
- getStateStack_internal() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getString(String) - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- getString(String) - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getString(String) - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- getString(String) - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext
-
Get String
"sideloads" from the incoming message.
- getString(String) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- getStringKeys() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- getStringKeys() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getStringKeys() - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- getStringKeys() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext
-
- getStringKeys() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- getStyleSheet(Appendable) - Method in interface io.mats3.localinspect.LocalHtmlInspectForMatsFactory
-
Note: The return from this method is static, and should only be included once per HTML page, no matter how many
MatsFactories you display.
- getStyleSheet(Appendable) - Method in class io.mats3.localinspect.LocalHtmlInspectForMatsFactoryImpl
-
Note: The return from this method is static, and should only be included once per HTML page, no matter how many
MatsFactories you display.
- getSumEnvelopeSerializationAndCompressionNanos() - Method in interface io.mats3.api.intercept.CommonCompletedContext
-
- getSumMessageSystemProductionAndSendNanos() - Method in interface io.mats3.api.intercept.CommonCompletedContext
-
- getSystemMessageId() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage.MatsSentOutgoingMessage
-
- getSystemMessageId() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getSystemMessageId() - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- getSystemMessageId() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext
-
- getSystemMessageId() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- getThrowable() - Method in interface io.mats3.api.intercept.CommonCompletedContext
-
- getThrowable() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext
-
- getTimeToLive() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- getTimeToLive() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getTimeToLive() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getTimeToLive() - Method in interface io.mats3.serial.MatsTrace
-
- getTimingMeasurements() - Method in interface io.mats3.api.intercept.CommonCompletedContext
-
- getTo() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- getTo() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getTo() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentation
-
- getTo() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.OutgoingMessageRepresentationImpl
-
- getTo() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
-
- getTo() - Method in interface io.mats3.serial.MatsTrace.Call
-
- getTo() - Method in interface io.mats3.test.MatsTestBrokerInterface.MatsMessageRepresentation
-
- getTotalCallNumber() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getTotalCallNumber() - Method in interface io.mats3.serial.MatsTrace
-
"Stack overflow protection" mechanism.
- getTotalEndpointProcessingTimeNanos() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStats
-
- getTotalEndpointProcessingTimeNanos() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStatsImpl
-
- getTotalExecutionNanos() - Method in interface io.mats3.api.intercept.CommonCompletedContext
-
- getTotalExecutionTimeNanos() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.InitiatorStats
-
- getTotalPreprocessAndDeserializeNanos() - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
-
- getTraceId() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- getTraceId() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getTraceId() - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- getTraceId() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext
-
- getTraceId() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- getTraceId() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getTraceId() - Method in interface io.mats3.serial.MatsTrace
-
- getTraceId() - Method in interface io.mats3.test.MatsTestBrokerInterface.MatsMessageRepresentation
-
- getTraceId() - Method in exception io.mats3.util.MatsFuturizer.MatsFuturizerTimeoutException
-
- getTraceProperty(String, Class<T>) - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- getTraceProperty(String, Class<T>) - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getTraceProperty(String, Class<T>) - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- getTraceProperty(String, Class<T>) - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext
-
Retrieves the Mats Trace property with the specified name, deserializing the value to the specified class,
using the active MATS serializer.
- getTraceProperty(String, Class<T>) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- getTraceProperty(String) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getTraceProperty(String) - Method in interface io.mats3.serial.MatsTrace
-
- getTracePropertyKeys() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- getTracePropertyKeys() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getTracePropertyKeys() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- getTracePropertyKeys() - Method in interface io.mats3.serial.MatsTrace
-
- getTransactionContext(JmsMatsTransactionManager.JmsMatsTxContextKey) - Method in interface io.mats3.impl.jms.JmsMatsTransactionManager
-
- getTransactionContext(JmsMatsTransactionManager.JmsMatsTxContextKey) - Method in class io.mats3.impl.jms.JmsMatsTransactionManager_Jms
-
- getTransactionContext(JmsMatsTransactionManager.JmsMatsTxContextKey) - Method in class io.mats3.impl.jms.JmsMatsTransactionManager_JmsAndJdbc
-
- getTransactionContext(JmsMatsTransactionManager.JmsMatsTxContextKey) - Method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx
-
- getTransactionIsolationFromWrappedDataSource() - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper
-
- getURL() - Method in class io.mats3.test.TestH2DataSource
-
Get the current URL.
- getUrl() - Method in class io.mats3.test.TestH2DataSource
-
Get the current URL.
- getUser() - Method in class io.mats3.test.TestH2DataSource
-
Get the current user name.
- getUserLambdaNanos() - Method in interface io.mats3.api.intercept.CommonCompletedContext
-
- getWhat() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- getWrappedObject() - Method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx.DeferredConnectionProxyDataSourceWrapper_InfrastructureProxy
-
- getXAConnection() - Method in class io.mats3.test.TestH2DataSource
-
- getXAConnection(String, String) - Method in class io.mats3.test.TestH2DataSource
-
- goTo(String, Object) - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- goTo(String, Object, Object) - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- goTo(String, Object) - Method in interface io.mats3.MatsEndpoint.ProcessContext
-
Sends a message which passes the current call stack over to another endpoint, so that when that endpoint
replies, it will return to the endpoint which invoked this endpoint.
- goTo(String, Object, Object) - Method in interface io.mats3.MatsEndpoint.ProcessContext
-
- goTo(String, Object) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- goTo(String, Object, Object) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- id(String, Object) - Method in interface io.mats3.impl.jms.JmsMatsStatics
-
- id(Object) - Method in interface io.mats3.impl.jms.JmsMatsStatics
-
- id(Class<?>) - Method in class io.mats3.test.abstractunit.AbstractMatsTest
-
- IDENTIFICATION - Static variable in class io.mats3.serial.json.MatsSerializerJson
-
- idThis() - Method in class io.mats3.impl.jms.JmsMatsEndpoint
-
- idThis() - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- idThis() - Method in class io.mats3.impl.jms.JmsMatsStage
-
- idThis() - Method in interface io.mats3.impl.jms.JmsMatsStatics
-
- idThis() - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint
-
- ILLEGAL_CALL_FLOWS - Static variable in interface io.mats3.impl.jms.JmsMatsStatics
-
- IN_MEMORY_TEST_H2_DATABASE_URL - Static variable in class io.mats3.test.TestH2DataSource
-
- IncomingMessageRepresentationImpl(MatsOutgoingMessage.MessageType, String, String, String, String) - Constructor for class io.mats3.localinspect.LocalStatsMatsInterceptor.IncomingMessageRepresentationImpl
-
- init() - Static method in class io.mats3.impl.jms.JmsMatsMessageBrokerSpecifics
-
- INITIAL - Static variable in annotation type io.mats3.spring.MatsClassMapping.Stage
-
Constant for 0 (zero), the initial Stage's ordinal.
- initialize(ConfigurableApplicationContext) - Method in class io.mats3.spring.test.MatsTestContext.MatsSimpleTestInfrastructureContextInitializer
-
- initialize(ConfigurableApplicationContext) - Method in class io.mats3.spring.test.MatsTestDbContext.MatsSimpleTestInfrastructureDbContextInitializer
-
- initiate(MatsInitiator.InitiateLambda) - Method in interface io.mats3.api.intercept.CommonInterceptOutgoingMessagesContext
-
To add a new message, you may initiate it here.
- initiate(MatsInitiator.InitiateLambda) - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor.InitiateInterceptUserLambdaContext
-
- initiate(MatsInitiator.InitiateLambda) - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor.InitiateStartedContext
-
- initiate(MatsInitiator.InitiateLambda) - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- initiate(MatsInitiator.InitiateLambda) - Method in interface io.mats3.MatsEndpoint.ProcessContext
-
Initiates a new message out to an endpoint.
- initiate(MatsInitiator.InitiateLambda) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- initiate(MatsInitiator.InitiateLambda) - Method in interface io.mats3.MatsInitiator
-
Initiates a new message ("request" or "send") out to an endpoint: You provide a lambda which is supplied the
MatsInitiator.MatsInitiate
instance on which you invoke methods to construct and dispatch messages.
- initiate(MatsInitiator.MatsInitiate) - Method in interface io.mats3.MatsInitiator.InitiateLambda
-
- initiateCompleted(MatsInitiateInterceptor.InitiateCompletedContext) - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor
-
- initiateCompleted(MatsInitiateInterceptor.InitiateCompletedContext) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
-
- initiateCompleted(MatsInitiateInterceptor.InitiateCompletedContext) - Method in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor
-
- initiateCompleted(MatsInitiateInterceptor.InitiateCompletedContext) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor
-
- initiateInterceptOutgoingMessages(MatsInitiateInterceptor.InitiateInterceptOutgoingMessagesContext) - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor.MatsInitiateInterceptOutgoingMessages
-
- initiateInterceptOutgoingMessages(MatsInitiateInterceptor.InitiateInterceptOutgoingMessagesContext) - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor
-
- initiateInterceptUserLambda(MatsInitiateInterceptor.InitiateInterceptUserLambdaContext, MatsInitiator.InitiateLambda, MatsInitiator.MatsInitiate) - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor.MatsInitiateInterceptUserLambda
-
- initiateStarted(MatsInitiateInterceptor.InitiateStartedContext) - Method in interface io.mats3.api.intercept.MatsInitiateInterceptor
-
Invoked right before user lambda is invoked.
- initiateUnchecked(MatsInitiator.InitiateLambda) - Method in interface io.mats3.MatsInitiator
-
- initiationTimestamp - Variable in class io.mats3.util.MatsFuturizer.Reply
-
- INITIATOR_ID_WHEN_NO_OUTGOING_MESSAGES - Static variable in interface io.mats3.api.intercept.MatsInterceptable.MatsMetricsInterceptor
-
When measuring "initiate complete", and the initiation ends up sending no messages, there is no
InitiatorId
to include.
- insertDataIntoDataTable(String) - Method in class io.mats3.test.TestH2DataSource
-
Inserts the provided 'data' into the SQL Table 'datatable', using a SQL Connection from this
DataSource.
- insertDataIntoDataTable(Connection, String) - Static method in class io.mats3.test.TestH2DataSource
-
Inserts the provided 'data' into the SQL Table 'datatable', using the provided SQL Connection.
- instaDlqWithRollbackLambda(MessageConsumer, JmsMatsMessageBrokerSpecifics.JmsMatsJmsExceptionThrowingRunnable) - Static method in class io.mats3.impl.jms.JmsMatsMessageBrokerSpecifics
-
If the MessageConsumer is an ActiveMQMessageConsumer, then it should set it into "0 redeliveries" mode, and then
run the provided lambda to rollback the current message, and then re-set the deliveries.
- install(MatsInterceptable) - Static method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
-
- install(MatsInterceptableMatsFactory, MeterRegistry, boolean) - Static method in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor
-
- install(MatsInterceptableMatsFactory) - Static method in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor
-
- install(MatsInterceptable) - Static method in class io.mats3.localinspect.LocalStatsMatsInterceptor
-
Creates an instance of this interceptor and installs it on the provided
MatsInterceptable
(which most
probably is a
MatsFactory
).
- INSTANCE - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
-
- instantiateNewObject(Class<T>) - Method in interface io.mats3.MatsFactory.FactoryConfig
-
This method is only relevant for tooling, and thus "hidden away" in this config class.
- interactive() - Method in interface io.mats3.MatsInitiator.MatsInitiate
-
Prioritize this Mats flow! Hint to the underlying implementation that a human is actually waiting for
the result of a request, and that the flow therefore should be prioritized.
- interactive() - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
-
- INTERCEPTOR_CLASS_MATS_LOGGING - Static variable in class io.mats3.impl.jms.JmsMatsFactory
-
- INTERCEPTOR_CLASS_MATS_METRICS - Static variable in class io.mats3.impl.jms.JmsMatsFactory
-
- internalCloseSession(JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.ConnectionWithSessionPool
-
- invoke(Object, Method, Object[]) - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper.DeferredFetchInvocationHandler
-
- io.mats3 - package io.mats3
-
API for Mats3: Message-based Asynchronous Transactional Staged Stateless Services.
- io.mats3.api.intercept - package io.mats3.api.intercept
-
Extension to the Mats3 API
which adds interception capabilities - all operations for
initiation and stage processing can be intercepted.
- io.mats3.impl.jms - package io.mats3.impl.jms
-
Java Message Service v1.1 (JMS v1.1) implementation of the Mats3 API
and
Mats3 Intercept API
.
- io.mats3.intercept.logging - package io.mats3.intercept.logging
-
Mats
3 interceptor for structured logging over SLF4J, adding several data points using the SLF4J MDC for
each initiation, message receive and message send - consists of a single class
MatsMetricsLoggingInterceptor
, for which the JMS
implementation has special support in that if it resides on the classpath, it will autoinstall.
- io.mats3.intercept.micrometer - package io.mats3.intercept.micrometer
-
Mats
3 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
-
Mats
3 Spring integration ("SpringConfig"), supplying a set of annotations including
@EnableMats
to enable bean scanning for
@MatsMapping
and
@MatsClassMapping
annotations, simplifying use of Mats
3 in a Spring context.
- io.mats3.spring.jms.factories - package io.mats3.spring.jms.factories
-
Tooling for handling your application's configuration of a JMS
ConnectionFactory
in different scenarios (development, testing, staging, production) - best explained in the class doc of
ScenarioConnectionFactoryProducer
-
do
note that this should not be the first thing you delve into when trying out Mats!
- io.mats3.spring.jms.tx - package io.mats3.spring.jms.tx
-
- io.mats3.spring.test - package io.mats3.spring.test
-
- io.mats3.test - package io.mats3.test
-
Contains a set of helpful tools for testing:
MatsTestBrokerInterface
to
get DLQ'ed messages,
MatsTestHelp
for creation of relevant ids,
MatsTestLatch
for a simple tool to synchronize between the test method and the
async Mats endpoints, and
TestH2DataSource
which is a small wrapper around H2
to create a database with a test table - mainly used by the API Tests to verify SQL transactions.
- io.mats3.test.abstractunit - package io.mats3.test.abstractunit
-
Common code for the modules 'mats-test-junit' and 'mats-test-jupiter' - These abstract classes should not be used
directly, but rather utilized through the mentioned implementations.
- io.mats3.test.broker - package io.mats3.test.broker
-
Tool for creating a MQ Broker to easily create a MatsFactory backed by an in-vm MQ Broker, employed by several of the
other Mats testing tools - by default uses Apache ActiveMQ, but may be directed to use Apache Artemis instead, or
to use an external ActiveMQ or Artemis broker.
- io.mats3.test.junit - package io.mats3.test.junit
-
Mats3 testing tools for JUnit 4.
- io.mats3.test.jupiter - package io.mats3.test.jupiter
-
Mats3 testing tools for Jupiter (JUnit 5).
- io.mats3.util - package io.mats3.util
-
Mats3 Utilities - notably the MatsFuturizer, which provides a bridge from synchronous processes to the
highly asynchronous Mats^3 services.
- io.mats3.util.wrappers - package io.mats3.util.wrappers
-
Wrappers for JMS ConnectionFactory
and JDBC
DataSource
- with a special "deferred connection proxy" wrapper which is smart to use as underlying DataSource for
the SQL-oriented JmsMatsTransactionManager
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
return
true
:
jmsConnection.isClosing()
jmsConnection.isClosed()
jmsConnection.isTransportFailed()
- isHoldEndpointsUntilFactoryIsStarted() - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- isInitial() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.StageStats
-
- isInteractive() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- isInteractive() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- isInteractive() - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- isInteractive() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext
-
This is relevant if stashing or otherwise when a stage is accessing an external system (e.g.
- isInteractive() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- isInteractive() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- isInteractive() - Method in interface io.mats3.serial.MatsTrace
-
- isInteractiveConcurrencyDefault() - Method in interface io.mats3.MatsConfig
-
- isNoAudit() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- isNoAudit() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- isNoAudit() - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- isNoAudit() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext
-
Hint to monitoring/logging/auditing systems that this call flow is not very valuable to fully audit,
typically because it is just a "getter" of information for display to a user, or is health check request to
see if the endpoint is up and answers in a timely manner.
- isNoAudit() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- isNoAudit() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- isNoAudit() - Method in interface io.mats3.serial.MatsTrace
-
- isNonPersistent() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- isNonPersistent() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- isNonPersistent() - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- isNonPersistent() - Method in interface io.mats3.MatsEndpoint.DetachedProcessContext
-
This is relevant if stashing or otherwise when a stage is accessing an external system (e.g.
- isNonPersistent() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- isNonPersistent() - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- isNonPersistent() - Method in interface io.mats3.serial.MatsTrace
-
- isProfileOrPropertyPresent(Environment, String...) - Static method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider.StandardSpecificScenarioDecider
-
- isReplyToSubscription() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- isReplyToSubscription() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- isRunning() - Method in interface io.mats3.MatsConfig
-
- isRunning() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper
-
- isSessionOk() - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler.JmsSessionHolder
-
- isSessionOk() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl
-
- isSessionOk() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple
-
- isSubscription() - Method in interface io.mats3.MatsEndpoint.EndpointConfig
-
- isTerminatorEndpoint() - Method in interface io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStats
-
- isTerminatorEndpoint() - Method in class io.mats3.localinspect.LocalStatsMatsInterceptor.EndpointStatsImpl
-
- isToSubscription() - Method in interface io.mats3.api.intercept.MatsOutgoingMessage
-
- isToSubscription() - Method in class io.mats3.impl.jms.JmsMatsMessage
-
- isUserLambdaExceptionLogged() - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext
-
- isWrapperFor(Class<?>) - Method in class io.mats3.test.TestH2DataSource
-
- isWrapperFor(Class<?>) - Method in class io.mats3.util.wrappers.DataSourceWrapper
-
- MATS_TEST_BROKER_INTERFACE_CLASSNAME - Static variable in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper
-
- MatsBackendException(String) - Constructor for exception io.mats3.MatsInitiator.MatsBackendException
-
- MatsBackendException(String, Throwable) - Constructor for exception io.mats3.MatsInitiator.MatsBackendException
-
- MatsBackendRuntimeException(String) - Constructor for exception io.mats3.MatsInitiator.MatsBackendRuntimeException
-
- MatsBackendRuntimeException(String, Throwable) - Constructor for exception io.mats3.MatsInitiator.MatsBackendRuntimeException
-
- MatsClassMapping - Annotation Type in io.mats3.spring
-
A class annotated with this repeatable annotation will become a Mats Endpoint, where an instance of the class itself
is the State (STO) object for the Endpoint, and each @
Stage
-annotated method on the class is a stage of
the Endpoint.
- MatsClassMapping.MatsClassMappings - Annotation Type in io.mats3.spring
-
- MatsClassMapping.Stage - Annotation Type in io.mats3.spring
-
Each method in the class that shall correspond to a Stage on the Mats endpoint must be annotated with this
@Stage
annotation.
- MatsConfig - Interface in io.mats3
-
- 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 the
MatsStage
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
-
- MatsEndpoint.ProcessSingleLambda<R,I> - Interface in io.mats3
-
Specialization of
ProcessLambda
which does not have a state, and have the same
return-semantics as
ProcessReturnLambda
- used for single-stage
endpoints as these does not have multiple stages to transfer state between.
- MatsEndpoint.ProcessTerminatorLambda<S,I> - Interface in io.mats3
-
Specialization of
ProcessLambda
which does not have reply specified - used for
terminator endpoints.
- MatsEndpointSetup - Annotation Type in io.mats3.spring
-
A method annotated with this repeatable annotation specifies a method that shall set up a (usually)
Multi-Staged Mats Endpoint.
- MatsEndpointSetup.MatsEndpointSetups - Annotation Type in io.mats3.spring
-
- MatsFactory - Interface in io.mats3
-
The start point for all interaction with Mats - you need to get hold of an instance of this interface to be able to
code and configure Mats endpoints, and to perform
initiations
like sending a message,
perform a request and publish a message.
- MatsFactory.ContextLocal - Class in io.mats3
-
- MatsFactory.FactoryConfig - Interface in io.mats3
-
Provides for a way to configure factory-wide elements and defaults.
- MatsFactory.MatsFactoryWrapper - Class in io.mats3
-
A base Wrapper for
MatsFactory
, which simply implements MatsFactory, takes a MatsFactory instance and
forwards all calls to that.
- MatsFactory.MatsWrapper<T> - Interface in io.mats3
-
Base Wrapper interface which Mats-specific Wrappers implements, defining four "wrappee" methods.
- MatsFactoryWrapper(MatsFactory) - Constructor for class io.mats3.MatsFactory.MatsFactoryWrapper
-
Standard constructor, taking the wrapped
MatsFactory
instance.
- MatsFactoryWrapper() - Constructor for class io.mats3.MatsFactory.MatsFactoryWrapper
-
- MatsFuturizer - Class in io.mats3.util
-
An instance of this class acts as a bridge service between the synchronous world of e.g.
- MatsFuturizer(MatsFactory, String, int, int, int) - Constructor for class io.mats3.util.MatsFuturizer
-
- MatsFuturizer.MatsFuturizerTimeoutException - Exception in io.mats3.util
-
This exception is raised through the
CompletableFuture
if the timeout specified when getting the
CompletableFuture
is reached (to get yourself a future, use one of the
futurizeXYZ(..)
methods).
- MatsFuturizer.Promise<T> - Class in io.mats3.util
-
- MatsFuturizer.Reply<T> - Class in io.mats3.util
-
An instance of this class will be the return value of any
CompletableFuture
s created with the
MatsFuturizer
.
- MatsFuturizerTimeoutException(String, long, String) - Constructor for exception io.mats3.util.MatsFuturizer.MatsFuturizerTimeoutException
-
- MatsInitiateInterceptor - Interface in io.mats3.api.intercept
-
- MatsInitiateInterceptor.InitiateCompletedContext - Interface in io.mats3.api.intercept
-
- MatsInitiateInterceptor.InitiateInterceptContext - Interface in io.mats3.api.intercept
-
- MatsInitiateInterceptor.InitiateInterceptOutgoingMessagesContext - Interface in io.mats3.api.intercept
-
- MatsInitiateInterceptor.InitiateInterceptUserLambdaContext - Interface in io.mats3.api.intercept
-
- MatsInitiateInterceptor.InitiateStartedContext - Interface in io.mats3.api.intercept
-
- MatsInitiateInterceptor.MatsInitiateInterceptOutgoingMessages - Interface in io.mats3.api.intercept
-
While still within the initiation context, this interception enables modifying outgoing messages from the user
lambda, setting trace properties, adding "sideloads", deleting a message, or initiating additional messages.
- MatsInitiateInterceptor.MatsInitiateInterceptUserLambda - Interface in io.mats3.api.intercept
-
Enables the intercepting of the invocation of the user lambda in an Initiation, with ability to wrap the
MatsInitiator.MatsInitiate
(and thus modify any request, send or publishes) - or even take over the entire initiation.
- MatsInitiateWrapper(MatsInitiator.MatsInitiate) - Constructor for class io.mats3.MatsInitiator.MatsInitiateWrapper
-
- MatsInitiateWrapper() - Constructor for class io.mats3.MatsInitiator.MatsInitiateWrapper
-
- MatsInitiator - Interface in io.mats3
-
- MatsInitiator.InitiateLambda - Interface in io.mats3
-
@FunctionalInterface
for the "initiate lambda" - what you supply to the
initiate
method.
- MatsInitiator.KeepTrace - Enum in io.mats3
-
A hint to the underlying implementation of how much historic debugging information for the call flow should be
retained in the underlying protocol.
- MatsInitiator.MatsBackendException - Exception in io.mats3
-
- MatsInitiator.MatsBackendRuntimeException - Exception in io.mats3
-
- 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
-
- MatsInitiator.MatsMessageSendRuntimeException - Exception in io.mats3
-
- 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
-
- MatsMapping - Annotation Type in io.mats3.spring
-
- MatsMapping.MatsMappings - Annotation Type in io.mats3.spring
-
- MatsMessageSendException(String) - Constructor for exception io.mats3.MatsInitiator.MatsMessageSendException
-
- MatsMessageSendException(String, Throwable) - Constructor for exception io.mats3.MatsInitiator.MatsMessageSendException
-
- MatsMessageSendRuntimeException(String) - Constructor for exception io.mats3.MatsInitiator.MatsMessageSendRuntimeException
-
- MatsMessageSendRuntimeException(String, Throwable) - Constructor for exception io.mats3.MatsInitiator.MatsMessageSendRuntimeException
-
- MatsMetricsLoggingInterceptor - Class in io.mats3.intercept.logging
-
A logging interceptor that writes loglines to two SLF4J loggers, including multiple pieces of information on the MDC
(initiatorId, endpointId and stageIds, and timings and sizes), so that it hopefully is easy to reason about and debug
all Mats flows, and to be able to use the logging system (e.g.
- MatsMetricsLoggingInterceptor() - Constructor for class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
-
- MatsMetricsLoggingInterceptor.Level - Enum in io.mats3.intercept.logging
-
- MatsMicrometerInterceptor - Class in io.mats3.intercept.micrometer
-
An interceptor that instruments a MatsFactory with metrics using the (Spring) Micrometer framework.
- MatsMicrometerInterceptor.SuggestedTimingHistogramsMeterFilter - Class in io.mats3.intercept.micrometer
-
A MeterFilter
that applies a hopefully reasonable histogram to all timing meters.
- MatsOutgoingMessage - Interface in io.mats3.api.intercept
-
Represents an Outgoing Mats Message.
- MatsOutgoingMessage.DispatchType - Enum in io.mats3.api.intercept
-
- MatsOutgoingMessage.MatsEditableOutgoingMessage - Interface in io.mats3.api.intercept
-
- MatsOutgoingMessage.MatsSentOutgoingMessage - Interface in io.mats3.api.intercept
-
- MatsOutgoingMessage.MessageType - Enum in io.mats3.api.intercept
-
- MatsProfiles - Interface in io.mats3.spring.jms.factories
-
- MatsRefuseMessageException(String, Throwable) - Constructor for exception io.mats3.MatsEndpoint.MatsRefuseMessageException
-
- MatsRefuseMessageException(String) - Constructor for exception io.mats3.MatsEndpoint.MatsRefuseMessageException
-
- MatsScenario - Enum in io.mats3.spring.jms.factories
-
- 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
-
- MatsSerializerJson(int) - Constructor for class io.mats3.serial.json.MatsSerializerJson
-
Constructs a MatsSerializer, using the specified Compression Level - refer to Deflater
's constants and
levels.
- MatsSimpleTestInfrastructureContextInitializer() - Constructor for class io.mats3.spring.test.MatsTestContext.MatsSimpleTestInfrastructureContextInitializer
-
- MatsSimpleTestInfrastructureDbContextInitializer() - Constructor for class io.mats3.spring.test.MatsTestDbContext.MatsSimpleTestInfrastructureDbContextInitializer
-
- MatsSpringAnnotationRegistration - Class in io.mats3.spring
-
The
BeanPostProcessor
-class specified by the
@EnableMats
annotation.
- MatsSpringAnnotationRegistration() - Constructor for class io.mats3.spring.MatsSpringAnnotationRegistration
-
- MatsSpringAnnotationRegistration.MatsSpringConfigException - Exception in io.mats3.spring
-
Thrown if the setup of a Mats Spring endpoint fails.
- MatsSpringAnnotationRegistration.MatsSpringInvocationTargetException - Exception in io.mats3.spring
-
Thrown if the invocation of a
@MatsMapping
or
@MatsEndpointSetup
annotated method raises
InvocationTargetException
and the underlying exception is not a
RuntimeException
.
- MatsSpringConfigException(String, Throwable) - Constructor for exception io.mats3.spring.MatsSpringAnnotationRegistration.MatsSpringConfigException
-
- MatsSpringConfigException(String) - Constructor for exception io.mats3.spring.MatsSpringAnnotationRegistration.MatsSpringConfigException
-
- MatsSpringInvocationTargetException(String, Throwable) - Constructor for exception io.mats3.spring.MatsSpringAnnotationRegistration.MatsSpringInvocationTargetException
-
- MatsSqlCommitOrRollbackFailedException(String, Throwable) - Constructor for exception io.mats3.impl.jms.JmsMatsTransactionManager_JmsAndJdbc.TransactionalContext_JmsAndJdbc.MatsSqlCommitOrRollbackFailedException
-
- MatsStage<R,S,I> - Interface in io.mats3
-
- 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
-
- MatsStageInterceptor.MatsStageInterceptOutgoingMessages - Interface in io.mats3.api.intercept
-
While still within the stage process context, this interception enables modifying outgoing messages from the user
lambda, setting trace properties, adding "sideloads", deleting a message, or initiating additional messages.
- MatsStageInterceptor.MatsStageInterceptUserLambda - Interface in io.mats3.api.intercept
-
Enables the intercepting of the invocation of the "user lambda" in a Stage, with ability to wrap the
MatsEndpoint.ProcessContext
(and thus modify any reply, request, next or initiations) and/or modifying state and
message - or even take over the entire stage.
- MatsStageInterceptor.StageCommonContext - Interface in io.mats3.api.intercept
-
Common context elements for stage interception, including all the incoming message/envelope data and metadata.
- MatsStageInterceptor.StageCompletedContext - Interface in io.mats3.api.intercept
-
- MatsStageInterceptor.StageCompletedContext.ProcessResult - Enum in io.mats3.api.intercept
-
- MatsStageInterceptor.StageInterceptContext - Interface in io.mats3.api.intercept
-
- MatsStageInterceptor.StageInterceptOutgoingMessageContext - Interface in io.mats3.api.intercept
-
- MatsStageInterceptor.StageInterceptUserLambdaContext - Interface in io.mats3.api.intercept
-
- MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext - Interface in io.mats3.api.intercept
-
- MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext.StagePreprocessAndDeserializeError - Enum in io.mats3.api.intercept
-
- MatsStageInterceptor.StageReceivedContext - Interface in io.mats3.api.intercept
-
- MatsTestBroker - Interface in io.mats3.test.broker
-
A special utility class utilized in tests and Mats test infrastructure providing a ConnectionFactory for the test
(Jms)MatsFactory - and if relevant also fires up an embedded ("in-VM") ActiveMQ (default) or Artemis message broker.
- MatsTestBroker.MatsTestBroker_ActiveMq - Class in io.mats3.test.broker
-
Either creates an in-vm ActiveMQ, or an ActiveMQ ConnectionFactory to an external URL, based on system
properties.
- MatsTestBroker.MatsTestBroker_Artemis - Class in io.mats3.test.broker
-
Creates a connection to an Artemis broker.
- MatsTestBroker.MatsTestBroker_InVmActiveMq - Class in io.mats3.test.broker
-
Creates an in-vm ActiveMQ no matter what the properties says.
- MatsTestBrokerInterface - Interface in io.mats3.test
-
Tool that makes it possible to query the underlying broker of a test MatsFactory for messages, in particular
"residual" messages and DLQs.
- MatsTestBrokerInterface.MatsMessageRepresentation - Interface in io.mats3.test
-
Representation of the Mats message that sat on the DLQ.
- MatsTestBrokerInterface.MatsTestBrokerInterface_JmsMatsFactory - Class in io.mats3.test
-
- MatsTestContext - Annotation Type in io.mats3.spring.test
-
One-stop-shop for making simple Spring-based integration/unit tests of Mats endpoints (NOT utilizing SQL
Connections), automatically importing the configuration .
- MatsTestContext.MatsSimpleTestInfrastructureContextInitializer - Class in io.mats3.spring.test
-
The reason for this obscure way to add the
MatsTestInfrastructureConfiguration
(as opposed to just point
to it with "classes=..") is as follows: Spring's testing integration has this feature where any static
inner @Configuration class of the test class is automatically loaded.
- MatsTestDbContext - Annotation Type in io.mats3.spring.test
-
- MatsTestDbContext.MatsSimpleTestInfrastructureDbContextInitializer - Class in io.mats3.spring.test
-
The reason for this obscure way to add the
MatsTestInfrastructureDbConfiguration
(as opposed to just
point to it with "classes=..") is as follows: Spring's testing integration has this feature where any static
inner @Configuration class of the test class is automatically loaded.
- MatsTestH2DataSourceConfiguration() - Constructor for class io.mats3.spring.test.MatsTestInfrastructureDbConfiguration.MatsTestH2DataSourceConfiguration
-
- MatsTestHelp - Class in io.mats3.test
-
Microscopic helper methods to create Loggers and Ids typically needed when making Mats tests.
- MatsTestHelp() - Constructor for class io.mats3.test.MatsTestHelp
-
- MatsTestInfrastructureConfiguration - Class in io.mats3.spring.test
-
Spring
@Configuration
class that cooks up the simple test infrastructure, employing a
MatsSerializer
from the Spring context if available, otherwise creates a default
MatsSerializerJson
.
- MatsTestInfrastructureConfiguration() - Constructor for class io.mats3.spring.test.MatsTestInfrastructureConfiguration
-
- MatsTestInfrastructureDbConfiguration - Class in io.mats3.spring.test
-
- MatsTestInfrastructureDbConfiguration() - Constructor for class io.mats3.spring.test.MatsTestInfrastructureDbConfiguration
-
- MatsTestInfrastructureDbConfiguration.MatsTestH2DataSourceConfiguration - Class in io.mats3.spring.test
-
- MatsTestLatch - Class in io.mats3.test
-
Test-utility: Gives a latch-functionality facilitating communication back from typically a Mats Terminator to the
main-thread that sent a message to some processor, and is now waiting for the Terminator to get the result.
- MatsTestLatch() - Constructor for class io.mats3.test.MatsTestLatch
-
- MatsTestLatch.Result<S,I> - Interface in io.mats3.test
-
- MatsTestProfile - Annotation Type in io.mats3.spring.test
-
- 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
-
- MatsTrace.Call.CallType - Enum in io.mats3.serial
-
Which type of Call this is.
- MatsTrace.Call.Channel - Interface in io.mats3.serial
-
- MatsTrace.Call.MessagingModel - Enum in io.mats3.serial
-
Specifies what type of Messaging Model a 'to' and 'replyTo' is to go over: Queue or Topic.
- MatsTrace.KeepMatsTrace - Enum in io.mats3.serial
-
Specifies how the MatsTrace will handle historic values that are present just for debugging.
- MatsTrace.StackState<Z> - Interface in io.mats3.serial
-
The State instances (of type Z), along with the height of the stack the state relates to.
- MatsTraceFieldImpl<Z> - Class in io.mats3.serial.impl
-
An implementation of
MatsTrace
which uses fields to hold all state necessary for a Mats flow, including
"holders" for the serialization of DTOs and STOs, with type 'Z'.
- MatsTraceFieldImpl() - Constructor for class io.mats3.serial.impl.MatsTraceFieldImpl
-
- MatsTraceFieldImpl(String, String, MatsTrace.KeepMatsTrace, boolean, boolean, long, boolean) - Constructor for class io.mats3.serial.impl.MatsTraceFieldImpl
-
- MatsTraceFieldImpl.CallImpl<Z> - Class in io.mats3.serial.impl
-
- 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
-
- MAX_TOTAL_CALL_NUMBER - Static variable in interface io.mats3.impl.jms.JmsMatsStatics
-
- 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_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_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_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
-
- methodInvoked(boolean, DeferredConnectionProxyDataSourceWrapper.DeferredConnectionProxy, Connection, Method, Object[], Object) - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper
-
- MQ_NAME_REPLACE_PATTERN - Static variable in class io.mats3.util.SanitizeMqNames
-
- ms(long) - Static method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
-
Converts nanos to millis with a sane number of significant digits ("3.5" significant digits), but assuming that
this is not used to measure things that take less than 0.001 milliseconds (in which case it will be "rounded" to
0.0001, 1e-4, as a special value).
- ms(double) - Static method in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor.SuggestedTimingHistogramsMeterFilter
-
- ms3(double) - Method in interface io.mats3.impl.jms.JmsMatsStatics
-
Truncate milliseconds to 3 decimals.
- msgLog_AddMsgMdcs(MatsOutgoingMessage.MatsSentOutgoingMessage, Runnable) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
-
- msgLog_CreateMsgLogLine(String, MatsOutgoingMessage.MatsSentOutgoingMessage) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
-
- msS(long) - Static method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
-
- partTraceId() - Static method in class io.mats3.util.RandomString
-
- performWithinTransaction() - Method in interface io.mats3.impl.jms.JmsMatsTransactionManager.ProcessingLambda
-
- postConstruct() - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper
-
If created as a @Bean, thus sitting directly in the Spring context, this class relies on Spring property
injection and @PostConstruct
being run.
- postConstructForFactoryBean(Environment, ApplicationContext) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper
-
If you construct this bean using a Spring FactoryBean
(e.g.
- postProcessAfterInitialization(Object, String) - Method in class io.mats3.spring.MatsSpringAnnotationRegistration
-
- postProcessBeforeInitialization(Object, String) - Method in class io.mats3.spring.MatsSpringAnnotationRegistration
-
- prepareTestInstance(TestContext) - Method in class io.mats3.spring.test.SpringInjectRulesAndExtensions.SpringInjectRulesAndExtensionsTestExecutionListener
-
Performs dependency injection on Rule
and @RegisterExtension
fields in test-class
as supplied by testContext.
- process(MatsEndpoint.ProcessContext<R>, S, I) - Method in interface io.mats3.MatsEndpoint.ProcessLambda
-
- process(MatsEndpoint.ProcessContext<R>, S, I) - Method in interface io.mats3.MatsEndpoint.ProcessReturnLambda
-
- process(MatsEndpoint.ProcessContext<R>, I) - Method in interface io.mats3.MatsEndpoint.ProcessSingleLambda
-
- process(MatsEndpoint.ProcessContext<Void>, S, I) - Method in interface io.mats3.MatsEndpoint.ProcessTerminatorLambda
-
- ProcessContextWrapper(MatsEndpoint.ProcessContext<R>) - Constructor for class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- ProcessContextWrapper() - Constructor for class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- produceAndSendMsgSysMessages(Logger, JmsMatsJmsSessionHandler.JmsSessionHolder, JmsMatsFactory<Z>, List<JmsMatsMessage<Z>>) - Method in interface io.mats3.impl.jms.JmsMatsStatics
-
- produceMessage(MatsOutgoingMessage.DispatchType, long, MatsSerializer<Z>, MatsTrace<Z>, Object, Object, Object, HashMap<String, Object>, HashMap<String, byte[]>, HashMap<String, String>) - Static method in class io.mats3.impl.jms.JmsMatsMessage
-
NOTE: The Maps are copied/cloned out, so invoker can do whatever he feels like with them afterwards.
- PROFILE_MATS_LOCALHOST - Static variable in interface io.mats3.spring.jms.factories.MatsProfiles
-
If this Spring Profile ("mats-localhost") is active, the ConnectionFactory specified by
ScenarioConnectionFactoryProducer#withLocalhostConnectionFactory(ConnectionFactoryProvider)
will be used.
- PROFILE_MATS_LOCALVM - Static variable in interface io.mats3.spring.jms.factories.MatsProfiles
-
If this Spring Profile ("mats-localvm") is active, the ConnectionFactory specified by
ScenarioConnectionFactoryProducer#withLocalVmConnectionFactory(ConnectionFactoryProvider)
will be used.
- PROFILE_MATS_MOCKS - Static variable in interface io.mats3.spring.jms.factories.MatsProfiles
-
Suggested Profile name ("mats-mocks") (or Profile name prefix if you want to divide the mocks into sets) to use
when you mock out project-external collaborator Mats Endpoints for use in the "LocalVM" scenario.
- PROFILE_MATS_REGULAR - Static variable in interface io.mats3.spring.jms.factories.MatsProfiles
-
If this Spring Profile ("mats-regular") is active, the ConnectionFactory
specified by
ScenarioConnectionFactoryProducer#withRegularConnectionFactory(ConnectionFactoryProvider)
will be used.
- PROFILE_MATS_TEST - Static variable in interface io.mats3.spring.jms.factories.MatsProfiles
-
- PROFILE_PRODUCTION - Static variable in interface io.mats3.spring.jms.factories.MatsProfiles
-
- PROFILE_STAGING - Static variable in interface io.mats3.spring.jms.factories.MatsProfiles
-
- Promise(String, String, String, String, long, long, Class<T>, CompletableFuture<MatsFuturizer.Reply<T>>) - Constructor for class io.mats3.util.MatsFuturizer.Promise
-
- publish(Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate
-
Sends a message to a
SubscriptionTerminator
, employing the publish/subscribe pattern instead of message queues (topic in JMS
terms).
- publish(Object, Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate
-
- publish(Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
-
- publish(Object, Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
-
- putInterceptContextAttribute(String, Object) - Method in interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
-
Set an attribute on this particular interception, which is shared between the different stages of
interception, and also between all interceptors - use some namespacing to avoid accidental collisions.
- RANDOM_ALPHABET - Static variable in interface io.mats3.impl.jms.JmsMatsStatics
-
- randomCorrelationId() - Static method in class io.mats3.util.RandomString
-
According to the internet, there are ~7.5e18 grains of sand on all the beaches on earth.
- randomId() - Static method in class io.mats3.test.MatsTestHelp
-
- randomString(int) - Method in interface io.mats3.impl.jms.JmsMatsStatics
-
- RandomString - Class in io.mats3.util
-
If you need a random string for a part of the traceId (Read NOTE about traceIds!), use this class instead of
UUID
, because UUID has low entropy density with only 4 bits per character, and dashes.
- RandomString() - Constructor for class io.mats3.util.RandomString
-
- randomString(int) - Static method in class io.mats3.util.RandomString
-
- release() - Method in interface io.mats3.impl.jms.JmsMatsJmsSessionHandler.JmsSessionHolder
-
For Initiators: This returns the JmsSessionHolder to the Session Pool for the underlying Connection.
- release() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl
-
- release() - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Simple.JmsSessionHolder_Simple
-
- remove(int) - Method in class io.mats3.impl.jms.JmsMatsEndpoint
-
- remove(MatsInterceptable) - Static method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
-
- remove(int) - Method in interface io.mats3.MatsEndpoint
-
Should most probably only be used for testing!
First invokes
stop(gracefulShutdownMillis)
, and if successful
removes the endpoint from
its MatsFactory.
- removeInitiationInterceptor(MatsInitiateInterceptor) - Method in interface io.mats3.api.intercept.MatsInterceptable
-
- removeInitiationInterceptor(MatsInitiateInterceptor) - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- removeInitiationInterceptor(MatsInitiateInterceptor) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper
-
- removeSessionHolderFromPool_And_DitchPoolIfEmpty(JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.ConnectionWithSessionPool
-
- removeStageInterceptor(MatsStageInterceptor) - Method in interface io.mats3.api.intercept.MatsInterceptable
-
- removeStageInterceptor(MatsStageInterceptor) - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- removeStageInterceptor(MatsStageInterceptor) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper
-
- reply(Object) - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- reply(R) - Method in interface io.mats3.MatsEndpoint.ProcessContext
-
Sends a reply to the requesting service.
- reply(R) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- Reply(MatsEndpoint.DetachedProcessContext, T, long) - Constructor for class io.mats3.util.MatsFuturizer.Reply
-
- reply - Variable in class io.mats3.util.MatsFuturizer.Reply
-
- replyTo(String, Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate
-
Specified which MATS Endpoint the reply of the invoked Endpoint should go to.
- replyTo(String, Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
-
- replyToSubscription(String, Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate
-
A "pub-sub" variant of
replyTo
, where the reply will go to the specified
endpointId which must be a
SubscriptionTerminator
.
- replyToSubscription(String, Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
-
- request(String, Object) - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- request(String, Object) - Method in interface io.mats3.MatsEndpoint.ProcessContext
-
Sends a request message, meaning that the specified endpoint will be invoked, with the reply-to endpointId
set to the next stage in the multi-stage endpoint.
- request(String, Object) - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- request(Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate
-
The standard request initiation method: All of from, to and replyTo must be set.
- request(Object, Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate
-
Variation of the request initiation method, where the incoming state is sent along.
- request(Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
-
- request(Object, Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
-
- resolve(Object, Object) - Method in class io.mats3.test.MatsTestLatch
-
When this method is invoked, the waiting threads will be released - this variant does not take the
ProcessContext, use the other one
!
- resolve(MatsEndpoint.DetachedProcessContext, Object, Object) - Method in class io.mats3.test.MatsTestLatch
-
When this method is invoked, the waiting threads will be released.
- retrieveDefaultAutoCommitAndTransactionIsolationAndReadOnlyValues(Connection) - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper
-
- Rule_Mats - Class in io.mats3.test.junit
-
ClassRule
which provides a full Mats harness for unit testing by creating
MatsFactory
utilizing an in-vm Active MQ broker, and optionally a
TestH2DataSource
for database tests.
- Rule_Mats(MatsSerializer<String>) - Constructor for class io.mats3.test.junit.Rule_Mats
-
- Rule_Mats(MatsSerializer<String>, DataSource) - Constructor for class io.mats3.test.junit.Rule_Mats
-
- Rule_MatsEndpoint<R,I> - Class in io.mats3.test.junit
-
Rule to create a single staged endpoint whose reply/processor can be changed throughout its life, i.e.
- Rule_MatsGeneric<Z> - Class in io.mats3.test.junit
-
Similar to
Rule_Mats
, provides a full Mats harness for unit testing by creating
MatsFactory
utilizing an in-vm Active MQ broker.
- Rule_MatsGeneric(MatsSerializer<Z>) - Constructor for class io.mats3.test.junit.Rule_MatsGeneric
-
- Rule_MatsGeneric(MatsSerializer<Z>, DataSource) - Constructor for class io.mats3.test.junit.Rule_MatsGeneric
-
- SanitizeMqNames - Class in io.mats3.util
-
Utility class for replacing dodgy characters from queue/topic names, and names in general, in the Message Broker
world - it is quite restrictive, replacing any character not in [a-z,A-Z,0-9,.,_,-] (lower alpha, upper alpha,
digits, dot, underscore, minus/dash) with '_'.
- SanitizeMqNames() - Constructor for class io.mats3.util.SanitizeMqNames
-
- sanitizeName(String) - Static method in class io.mats3.util.SanitizeMqNames
-
Sanitizes the input, only allowing [a-z,A-Z,0-9,.,-,_] (last being dot, minus, underscore)
- scenarioActive(Environment) - Method in interface io.mats3.spring.jms.factories.ConfigurableScenarioDecider.SpecificScenarioDecider
-
Decides whether a specific Scenario is active.
- scenarioActive(Environment) - Method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider.StandardSpecificScenarioDecider
-
- ScenarioConnectionFactoryProducer - Class in io.mats3.spring.jms.factories
-
Provides a factory for a Spring-integrated Wrapper/Facade around a JMS ConnectionFactory, which in addition to
supporting the production setup, also facilitates the development situation where you often want to run against
either an in-vm MQ Broker or against a MQ Broker running on localhost, and also integrates with the
"mats-spring-test" integration test library where when run with the MatsTestProfile
you will most
probably want an in-vm setup (typically mocking up the project-external Mats endpoints that the tested endpoints
collaborate with).
- ScenarioConnectionFactoryProducer() - Constructor for class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer
-
- ScenarioConnectionFactoryWrapper - Class in io.mats3.spring.jms.factories
-
A
ConnectionFactoryWrapper
which lazily decides which of the three
MatsScenario
s are active, and
produces the wrapper-target
ConnectionFactory
based on that - you most probably want to use
ScenarioConnectionFactoryProducer
to make an instance of this class, but you can configure it directly too.
- ScenarioConnectionFactoryWrapper(ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider, ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider, ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider, ScenarioConnectionFactoryWrapper.ScenarioDecider) - Constructor for class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper
-
- ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider - Interface in io.mats3.spring.jms.factories
-
- 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.
- send(Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate
-
Sends a message to an endpoint, without expecting any reply ("fire-and-forget").
- send(Object, Object) - Method in interface io.mats3.MatsInitiator.MatsInitiate
-
- send(Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
-
- send(Object, Object) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
-
- SerializationException(String) - Constructor for exception io.mats3.serial.MatsSerializer.SerializationException
-
- SerializationException(String, Throwable) - Constructor for exception io.mats3.serial.MatsSerializer.SerializationException
-
- serializeMatsTrace(MatsTrace<String>) - Method in class io.mats3.serial.json.MatsSerializerJson
-
- serializeMatsTrace(MatsTrace<Z>) - Method in interface io.mats3.serial.MatsSerializer
-
Used for serializing the
MatsTrace
to a byte array.
- serializeObject(Object) - Method in class io.mats3.serial.json.MatsSerializerJson
-
- serializeObject(Object) - Method in interface io.mats3.serial.MatsSerializer
-
Used for serializing STOs and DTOs into type Z, typically String
.
- setApplicationContext(ApplicationContext) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper
-
- setApplicationContext(ApplicationContext) - Method in class io.mats3.spring.MatsSpringAnnotationRegistration
-
- setAttribute(String, Object) - Method in interface io.mats3.MatsConfig
-
Sets an attribute for this entity (factory, endpoint, stage) - can e.g.
- setAttribute(String, Object) - Method in interface io.mats3.MatsEndpoint.EndpointConfig
-
- setAttribute(String, Object) - Method in interface io.mats3.MatsFactory.FactoryConfig
-
- setAttribute(String, Object) - Method in interface io.mats3.MatsStage.StageConfig
-
- setBeanName(String) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper
-
- setConcurrency(int) - Method in interface io.mats3.MatsConfig
-
Changes the default concurrency of the Factory, or of the endpoint (which defaults to the concurrency of the
MatsFactory
), or of the process stage (which defaults to the concurrency of the
MatsEndpoint
).
- setConcurrency(int) - Method in interface io.mats3.MatsEndpoint.EndpointConfig
-
- setConcurrency(int) - Method in interface io.mats3.MatsFactory.FactoryConfig
-
- setConcurrency(int) - Method in interface io.mats3.MatsStage.StageConfig
-
- setConcurrencyWithLog(Logger, String, Supplier<Integer>, Supplier<Boolean>, Consumer<Integer>, int) - Method in interface io.mats3.impl.jms.JmsMatsStatics
-
Set concurrency on entity, printing log
- setConnectionProxy(DeferredConnectionProxyDataSourceWrapper.DeferredConnectionProxy) - Method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper.DeferredFetchInvocationHandler
-
- setCurrentContext(Object) - Method in class io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl
-
- setDbCommitNanos(long) - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext
-
- setDebugInfo(String, String, String, String) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl.CallImpl
-
- setDebugInfo(String, String, String, String) - Method in interface io.mats3.serial.MatsTrace.Call
-
Can only be set once.
- setDefaultKeepTrace(MatsInitiator.KeepTrace) - Method in class io.mats3.impl.jms.JmsMatsFactory
-
Sets the default KeepTrace if the initiation doesn't set one itself.
- setDefaultScenario(Supplier<MatsScenario>) - Method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider
-
- setDescription(String) - Method in class io.mats3.test.TestH2DataSource
-
Set the description.
- setEnvironment(Environment) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper
-
- setEnvironment(Environment) - Method in class io.mats3.spring.jms.factories.SpringJmsMatsFactoryWrapper
-
- setExtraState(String, Z) - Method in interface io.mats3.serial.MatsTrace.StackState
-
Sets "extra state" on this StackState.
- setInitiateTraceIdModifier(Function<String, String>) - Method in interface io.mats3.MatsFactory.FactoryConfig
-
Sets a Function that may modify the TraceId of Mats flows that are initiated "from the outside", i.e.
- setInteractiveConcurrency(int) - Method in interface io.mats3.MatsConfig
-
- setInteractiveConcurrency(int) - Method in interface io.mats3.MatsEndpoint.EndpointConfig
-
- setInteractiveConcurrency(int) - Method in interface io.mats3.MatsFactory.FactoryConfig
-
- setInteractiveConcurrency(int) - Method in interface io.mats3.MatsStage.StageConfig
-
- setLocalhostDecider(ConfigurableScenarioDecider.SpecificScenarioDecider) - Method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider
-
- setLocalVmDecider(ConfigurableScenarioDecider.SpecificScenarioDecider) - Method in class io.mats3.spring.jms.factories.ConfigurableScenarioDecider
-
- setLoginTimeout(int) - Method in class io.mats3.test.TestH2DataSource
-
- setLoginTimeout(int) - Method in class io.mats3.util.wrappers.DataSourceWrapper
-
- setLogWriter(PrintWriter) - Method in class io.mats3.test.TestH2DataSource
-
- setLogWriter(PrintWriter) - Method in class io.mats3.util.wrappers.DataSourceWrapper
-
- setMatsDestinationPrefix(String) - Method in interface io.mats3.MatsFactory.FactoryConfig
-
Sets the prefix that should be applied to the endpointIds to get queue or topic name in the underlying
messaging system - the default is "mats."
.
- setMatsFactory(MatsFactory) - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint
-
- setMatsFactory(MatsFactory) - Method in class io.mats3.test.junit.Rule_MatsEndpoint
-
Sets the internal
MatsFactory
to be utilized for the creation of this endpoint.
- setMatsFactory(MatsFactory) - Method in class io.mats3.test.jupiter.Extension_MatsEndpoint
-
Sets the internal
MatsFactory
to be utilized for the creation of this endpoint.
- setMatsTraceKey(String) - Method in interface io.mats3.MatsFactory.FactoryConfig
-
Sets the key name on which to store the "wire representation" of the Mats message if the underlying mechanism
uses some kind of Map - the default is "mats:trace"
.
- setMessageSystemCommitNanos(long) - Method in class io.mats3.impl.jms.JmsMatsInternalExecutionContext
-
- setName(String) - Method in interface io.mats3.MatsFactory.FactoryConfig
-
Sets the name of the MatsFactory, default is "" (empty string).
- setNodename(String) - Method in interface io.mats3.MatsFactory.FactoryConfig
-
- 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
-
- setWrappee(MatsFactory) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
-
- setWrappee(T) - Method in interface io.mats3.MatsFactory.MatsWrapper
-
- setWrappee(MatsInitiator.MatsInitiate) - Method in class io.mats3.MatsInitiator.MatsInitiateWrapper
-
- setWrappee(ConnectionFactory) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper
-
- setWrappee(ConnectionFactory) - Method in class io.mats3.util.wrappers.ConnectionFactoryWrapper
-
Sets the wrapped ConnectionFactory
, e.g.
- setWrappee(DataSource) - Method in class io.mats3.util.wrappers.DataSourceWrapper
-
Sets the wrapped DataSource
, e.g.
- shouldSuppressStageLogging(MatsStageInterceptor.StageCommonContext) - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
-
- single(String, Class<R>, Class<I>, MatsEndpoint.ProcessSingleLambda<R, I>) - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- single(String, Class<R>, Class<I>, Consumer<? super MatsEndpoint.EndpointConfig<R, Void>>, Consumer<? super MatsStage.StageConfig<R, Void, I>>, MatsEndpoint.ProcessSingleLambda<R, I>) - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- single(String, Class<R>, Class<I>, MatsEndpoint.ProcessSingleLambda<R, I>) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
-
- single(String, Class<R>, Class<I>, Consumer<? super MatsEndpoint.EndpointConfig<R, Void>>, Consumer<? super MatsStage.StageConfig<R, Void, I>>, MatsEndpoint.ProcessSingleLambda<R, I>) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
-
- single(String, Class<R>, Class<I>, MatsEndpoint.ProcessSingleLambda<R, I>) - Method in interface io.mats3.MatsFactory
-
Sets up a
MatsEndpoint
that just contains one stage, useful for simple "request the full person data for
this/these personId(s)" scenarios.
- single(String, Class<R>, Class<I>, Consumer<? super MatsEndpoint.EndpointConfig<R, Void>>, Consumer<? super MatsStage.StageConfig<R, Void, I>>, MatsEndpoint.ProcessSingleLambda<R, I>) - Method in interface io.mats3.MatsFactory
-
Variation of #single(String, Class, Class, ProcessSingleLambda)
that can be configured "on the fly".
- SIZE_OUT_ENVELOPE_DESC - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor
-
- SIZE_OUT_ENVELOPE_NAME - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor
-
- SIZE_OUT_WIRE_DESC - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor
-
- SIZE_OUT_WIRE_NAME - Static variable in class io.mats3.intercept.micrometer.MatsMicrometerInterceptor
-
- sizeOfSerialized(String) - Method in class io.mats3.serial.json.MatsSerializerJson
-
- sizeOfSerialized(Z) - Method in interface io.mats3.serial.MatsSerializer
-
- SpringInjectRulesAndExtensions - Annotation Type in io.mats3.spring.test
-
Use this Test Execution Listener to autowire JUnit Rules and Jupiter Extensions, i.e.
- SpringInjectRulesAndExtensions.SpringInjectRulesAndExtensionsTestExecutionListener - Class in io.mats3.spring.test
-
This TestExecutionListener
finds all fields in the test class instance which is annotated with JUnit
Rule
or JUnit 5 Jupiter RegisterExtension
, and runs
beanFactory.autowireBean(fieldValue)
on them.
- SpringInjectRulesAndExtensionsTestExecutionListener() - Constructor for class io.mats3.spring.test.SpringInjectRulesAndExtensions.SpringInjectRulesAndExtensionsTestExecutionListener
-
- SpringJmsMatsFactoryProducer - Class in io.mats3.spring.jms.factories
-
- 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
-
- stage(Class<I>, MatsEndpoint.ProcessLambda<R, S, I>) - Method in class io.mats3.impl.jms.JmsMatsEndpoint
-
- stage(Class<I>, Consumer<? super MatsStage.StageConfig<R, S, I>>, MatsEndpoint.ProcessLambda<R, S, I>) - Method in class io.mats3.impl.jms.JmsMatsEndpoint
-
- stage(Class<I>, MatsEndpoint.ProcessLambda<R, S, I>) - Method in interface io.mats3.MatsEndpoint
-
Adds a new stage to a multi-stage endpoint.
- stage(Class<I>, Consumer<? super MatsStage.StageConfig<R, S, I>>, MatsEndpoint.ProcessLambda<R, S, I>) - Method in interface io.mats3.MatsEndpoint
-
- 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
-
- staged(String, Class<R>, Class<S>) - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- staged(String, Class<R>, Class<S>, Consumer<? super MatsEndpoint.EndpointConfig<R, S>>) - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- staged(String, Class<R>, Class<S>) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
-
- staged(String, Class<R>, Class<S>, Consumer<? super MatsEndpoint.EndpointConfig<R, S>>) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
-
- staged(String, Class<R>, Class<S>) - Method in interface io.mats3.MatsFactory
-
- staged(String, Class<R>, Class<S>, Consumer<? super MatsEndpoint.EndpointConfig<R, S>>) - Method in interface io.mats3.MatsFactory
-
- 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
-
- start() - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
-
- start() - Method in interface io.mats3.MatsFactory
-
Starts all endpoints that has been created by this factory, by invoking
MatsEndpoint.start()
on them.
- start() - Method in interface io.mats3.MatsStage
-
Starts this stage, thereby firing up the queue processing using a set of threads, the number decided by the
MatsConfig.getConcurrency()
for each stage.
- start(String) - Method in class io.mats3.spring.jms.factories.ConnectionFactoryWithStartStopWrapper
-
Start whatever is needed to support the ConnectionFactory, i.e.
- start() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper
-
- stash() - Method in class io.mats3.impl.jms.JmsMatsProcessContext
-
- stash() - Method in interface io.mats3.MatsEndpoint.ProcessContext
-
Returns a binary representation of the current Mats flow's incoming execution point, which can be
unstashed
again at a later time
using the
MatsInitiator
, thereby providing a simplistic "continuation" feature in Mats.
- stash() - Method in class io.mats3.MatsEndpoint.ProcessContextWrapper
-
- Sto - Annotation Type in io.mats3.spring
-
Specifies that the annotated method parameter is an incoming State Transfer Object.
- stop(int) - Method in class io.mats3.impl.jms.JmsMatsEndpoint
-
- stop(int) - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- stop(int) - Method in class io.mats3.impl.jms.JmsMatsStage
-
- stop(int) - Method in interface io.mats3.impl.jms.JmsMatsStartStoppable
-
- stop(int) - Method in interface io.mats3.MatsConfig.StartStoppable
-
Will stop the entity - or the entities below it (the only "active" entity is a
MatsStage
Processor).
- stop(int) - Method in interface io.mats3.MatsEndpoint
-
- stop(int) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
-
- stop(int) - Method in interface io.mats3.MatsFactory
-
- stop(int) - Method in interface io.mats3.MatsStage
-
Stops this stage.
- stop() - Method in class io.mats3.spring.jms.factories.ConnectionFactoryWithStartStopWrapper
-
- stop() - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper
-
- stop(Runnable) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryWrapper
-
- stopPhase0_SetRunFlagFalse() - Method in interface io.mats3.impl.jms.JmsMatsStartStoppable
-
- stopPhase1_CloseSessionIfInReceive() - Method in interface io.mats3.impl.jms.JmsMatsStartStoppable
-
- stopPhase2_GracefulWaitAfterRunflagFalse(int) - Method in interface io.mats3.impl.jms.JmsMatsStartStoppable
-
- stopPhase3_InterruptIfStillAlive() - Method in interface io.mats3.impl.jms.JmsMatsStartStoppable
-
- stopPhase4_GracefulWaitAfterInterrupt() - Method in interface io.mats3.impl.jms.JmsMatsStartStoppable
-
- subscriptionTerminator(String, Class<S>, Class<I>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- subscriptionTerminator(String, Class<S>, Class<I>, Consumer<? super MatsEndpoint.EndpointConfig<Void, S>>, Consumer<? super MatsStage.StageConfig<Void, S, I>>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- subscriptionTerminator(String, Class<S>, Class<I>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
-
- subscriptionTerminator(String, Class<S>, Class<I>, Consumer<? super MatsEndpoint.EndpointConfig<Void, S>>, Consumer<? super MatsStage.StageConfig<Void, S, I>>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
-
- subscriptionTerminator(String, Class<S>, Class<I>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in interface io.mats3.MatsFactory
-
Special kind of terminator that, in JMS-style terms, subscribes to a topic instead of listening to a queue (i.e.
- subscriptionTerminator(String, Class<S>, Class<I>, Consumer<? super MatsEndpoint.EndpointConfig<Void, S>>, Consumer<? super MatsStage.StageConfig<Void, S, I>>, MatsEndpoint.ProcessTerminatorLambda<S, I>) - Method in interface io.mats3.MatsFactory
-
Variation of #subscriptionTerminator(String, Class, Class, ProcessTerminatorLambda)
that can be
configured "on the fly", but notice that the concurrency of a SubscriptionTerminator is always 1.
- SuggestedTimingHistogramsMeterFilter() - Constructor for class io.mats3.intercept.micrometer.MatsMicrometerInterceptor.SuggestedTimingHistogramsMeterFilter
-
- SUPPRESS_LOGGING_ENDPOINT_ALLOWS_ATTRIBUTE_KEY - Static variable in interface io.mats3.api.intercept.MatsInterceptable.MatsLoggingInterceptor
-
- SUPPRESS_LOGGING_INTERCEPT_CONTEXT_ATTRIBUTE - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
-
- SUPPRESS_LOGGING_TRACE_PROPERTY_KEY - Static variable in interface io.mats3.api.intercept.MatsInterceptable.MatsLoggingInterceptor
-
If this key is present on the
TraceProperties
of a Mats
Flow, with the value
Boolean.TRUE
, no ordinary log lines should be emitted while initiating or stage
processing the Mats Flow,
assuming that the implicated endpoints
allows
logging suppression.
- SUPPRESSION_MDC_KEY_PARTS_SEPARATOR - Static variable in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
-
- suppressionSummarizerThreadRunnable() - Method in class io.mats3.intercept.logging.MatsMetricsLoggingInterceptor
-
- SYSPROP_MATS_TEST_BROKER - Static variable in interface io.mats3.test.broker.MatsTestBroker
-
Which Broker client to use (which JMS ConnectionFactory
implementation): activemq (default), artemis or
rabbitmq - or if a class-name like String, assumes that it is an implementation of the present interface
(MatsTestBroker
) and instantiates that.
- SYSPROP_MATS_TEST_BROKER_VALUE_ACTIVEMQ - Static variable in interface io.mats3.test.broker.MatsTestBroker
-
DEFAULT: Use ActiveMQ as broker.
- SYSPROP_MATS_TEST_BROKER_VALUE_ARTEMIS - Static variable in interface io.mats3.test.broker.MatsTestBroker
-
Use Artemis (Apache ActiveMQ Artemis) as broker - this was formerly JBoss HornetQ.
- SYSPROP_MATS_TEST_BROKER_VALUE_RABBITMQ - Static variable in interface io.mats3.test.broker.MatsTestBroker
-
Use RabbitMQ as broker.
- SYSPROP_MATS_TEST_BROKERURL - Static variable in interface io.mats3.test.broker.MatsTestBroker
-
- SYSPROP_MATS_TEST_BROKERURL_VALUE_IN_VM - Static variable in interface io.mats3.test.broker.MatsTestBroker
-
- SYSPROP_MATS_TEST_BROKERURL_VALUE_LOCALHOST - Static variable in interface io.mats3.test.broker.MatsTestBroker
-
- 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
-
- valueOf(String) - Static method in enum io.mats3.api.intercept.MatsOutgoingMessage.DispatchType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum io.mats3.api.intercept.MatsOutgoingMessage.MessageType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext.ProcessResult
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum io.mats3.api.intercept.MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext.StagePreprocessAndDeserializeError
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyInitiator
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyStageProcessor
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum io.mats3.intercept.logging.MatsMetricsLoggingInterceptor.Level
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum io.mats3.MatsInitiator.KeepTrace
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum io.mats3.serial.MatsTrace.Call.CallType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum io.mats3.serial.MatsTrace.Call.MessagingModel
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum io.mats3.serial.MatsTrace.KeepMatsTrace
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum io.mats3.spring.jms.factories.MatsScenario
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum io.mats3.api.intercept.MatsOutgoingMessage.DispatchType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum io.mats3.api.intercept.MatsOutgoingMessage.MessageType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum io.mats3.api.intercept.MatsStageInterceptor.StageCompletedContext.ProcessResult
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum io.mats3.api.intercept.MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext.StagePreprocessAndDeserializeError
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyInitiator
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum io.mats3.impl.jms.JmsMatsJmsSessionHandler_Pooling.PoolingKeyStageProcessor
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum io.mats3.intercept.logging.MatsMetricsLoggingInterceptor.Level
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum io.mats3.MatsInitiator.KeepTrace
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum io.mats3.serial.MatsTrace.Call.CallType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum io.mats3.serial.MatsTrace.Call.MessagingModel
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum io.mats3.serial.MatsTrace.KeepMatsTrace
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum io.mats3.spring.jms.factories.MatsScenario
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- verifyNotInvoked() - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint
-
Verifies that this endpoint has not been invoked.
- WAIT_MILLIS_FOR_NON_OCCURRENCE - Static variable in class io.mats3.test.MatsTestLatch
-
Some tests needs to assert that something does not happen, i.e.
- waitForReceiving(int) - Method in class io.mats3.impl.jms.JmsMatsEndpoint
-
- waitForReceiving(int) - Method in class io.mats3.impl.jms.JmsMatsFactory
-
- waitForReceiving(int) - Method in class io.mats3.impl.jms.JmsMatsStage
-
- waitForReceiving(int) - Method in interface io.mats3.impl.jms.JmsMatsStartStoppable
-
- waitForReceiving(int) - Method in interface io.mats3.MatsConfig.StartStoppable
-
If the entity is stopped or starting, this method won't return until it has actually started the receive-loop
(i.e.
- waitForReceiving(int) - Method in interface io.mats3.MatsEndpoint
-
Waits till all stages of the endpoint has entered their receive-loops, i.e.
- waitForReceiving(int) - Method in class io.mats3.MatsFactory.MatsFactoryWrapper
-
- waitForReceiving(int) - Method in interface io.mats3.MatsFactory
-
Waits until all endpoints have fully entered the receive-loops, i.e.
- waitForReceiving(int) - Method in interface io.mats3.MatsStage
-
Will wait until at least one processor of the stage has entered its receive-loop.
- waitForRequest() - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint
-
Blocks and waits for the endpoint to be invoked, then returns the incoming message DTO of the type
(I
).
- waitForRequest(long) - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint
-
Blocks and waits for the endpoint to be invoked, then returns the incoming message DTO of the type
(I
).
- waitForRequests(int) - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint
-
Blocks and waits for the endpoint to be invoked x number of times, then returns the x number of corresponding
incoming message DTO's of the type (I
).
- waitForRequests(int, long) - Method in class io.mats3.test.abstractunit.AbstractMatsTestEndpoint
-
Blocks and waits for the endpoint to be invoked x number of times, then returns the x number of corresponding
incoming message DTO's of the type (I
).
- waitForResult() - Method in class io.mats3.test.MatsTestLatch
-
Convenience method of
MatsTestLatch.waitForResult(long)
meant for waiting for something that is expected to happen:
Waits for 30 seconds for the test-latch to be
resolved
.
- waitForResult(long) - Method in class io.mats3.test.MatsTestLatch
-
Waits for the specified time for #resolve(DetachedProcessContext, Object, Object)
resolve(..)} to be
invoked by some other thread, returning the result.
- withChildFlow(String, int) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- withChildFlow(String, int) - Method in interface io.mats3.serial.MatsTrace
-
If this newly created MatsTrace is a child-flow (initiated within a Stage) of an existing flow, then this method
should be invoked to set the parent MatsMessageId, and the "total call number" which is a "Call Overflow
protection" mechanism.
- withDebugInfo(String, String, String, String, String) - Method in class io.mats3.serial.impl.MatsTraceFieldImpl
-
- withDebugInfo(String, String, String, String, String) - Method in interface io.mats3.serial.MatsTrace
-
Can only be set once..
- withDefaultScenario(MatsScenario) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer
-
- withLocalhostConnectionFactory(ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer
-
Optional: Provide a ConnectionFactoryProvider lambda for the
LOCALHOST
scenario
(which only is meant to be used for development and possibly testing).
- withLocalVmConnectionFactory(ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer
-
Very optional: Provide a ConnectionFactoryProvider lambda for the
LOCALVM
scenario
(which only is meant to be used for development and testing).
- withRegularConnectionFactory(ScenarioConnectionFactoryWrapper.ConnectionFactoryProvider) - Static method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer
-
- withScenarioDecider(ScenarioConnectionFactoryWrapper.ScenarioDecider) - Method in class io.mats3.spring.jms.factories.ScenarioConnectionFactoryProducer
-
Can optionally be overridden should you decide to use a different decision-scheme than the
default
.
- wrap(DataSource) - Static method in class io.mats3.util.wrappers.DeferredConnectionProxyDataSourceWrapper
-
- wrapLazyConnectionDatasource(DataSource) - Static method in class io.mats3.spring.jms.tx.JmsMatsTransactionManager_JmsAndSpringManagedSqlTx
-
Creates a proxy/wrapper that has lazy connection getting, and monitoring of whether the connection was actually
retrieved.