Package io.mats3.impl.jms
Interface JmsMatsStatics
- All Known Subinterfaces:
JmsMatsStartStoppable
- All Known Implementing Classes:
JmsMatsEndpoint
,JmsMatsFactory
,JmsMatsJmsSessionHandler_Pooling
,JmsMatsJmsSessionHandler_Pooling.ConnectionWithSessionPool
,JmsMatsJmsSessionHandler_Pooling.JmsSessionHolderImpl
,JmsMatsJmsSessionHandler_Simple
,JmsMatsProcessContext
,JmsMatsStage
,JmsMatsTransactionManager_Jms
,JmsMatsTransactionManager_Jms.TransactionalContext_Jms
,JmsMatsTransactionManager_JmsAndJdbc
,JmsMatsTransactionManager_JmsAndJdbc.TransactionalContext_JmsAndJdbc
,JmsMatsTransactionManager_JmsAndSpringManagedSqlTx
public interface JmsMatsStatics
Common "static" stash, hacked up as an interface to be implemented if you need it.
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final int
Number of milliseconds to "extra wait" after timeoutMillis or gracefulShutdownMillis is gone.static final String
Log prefix (afterLOG_PREFIX
) for flows that are illegal.static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final int
If an outgoing message hasMatsTrace.Call.getReplyStackHeight()
higher than this (25), the processing will be refused (i.e.static final int
If an outgoing message hasMatsTrace.getTotalCallNumber()
higher than this (100), the processing will be refused (i.e.static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final int
-
Method Summary
Modifier and TypeMethodDescriptiondefault String
createFlowId
(long creationTimeMillis) default String
Inspired from Stackoverflow - Denys Séguret.static <I,
Z> I handleIncomingMessageMatsObject
(MatsSerializer<Z> matsSerializer, Class<I> incomingMessageClass, Z data) static <S,
Z> S handleIncomingState
(MatsSerializer<Z> matsSerializer, Class<S> stateClass, MatsTrace.StackState<Z> stackState) default String
default String
default String
idThis()
default double
ms3
(double ms) Truncate milliseconds to 3 decimals.default <Z> void
produceAndSendMsgSysMessages
(org.slf4j.Logger log, JmsMatsJmsSessionHandler.JmsSessionHolder jmsSessionHolder, JmsMatsFactory<Z> jmsMatsFactory, List<JmsMatsMessage<Z>> messagesToSend) Send a bunch ofJmsMatsMessage
s.default String
randomString
(int length) default void
setConcurrencyWithLog
(org.slf4j.Logger log, String what, Supplier<Integer> getter, Supplier<Boolean> isDefault, Consumer<Integer> setter, int newConcurrency) Set concurrency on entity, printing logdefault String
stageOrInit
(JmsMatsTransactionManager.JmsMatsTxContextKey txContextKey)
-
Field Details
-
LOG_PREFIX
- See Also:
-
THREAD_PREFIX
- See Also:
-
MDC_TRACE_ID
- See Also:
-
MDC_MATS_CALL_NUMBER
- See Also:
-
MDC_MATS_APP_NAME
- See Also:
-
MDC_MATS_APP_VERSION
- See Also:
-
MDC_MATS_INIT
- See Also:
-
MDC_MATS_STAGE
- See Also:
-
MDC_MATS_STAGE_ID
- See Also:
-
MDC_MATS_STAGE_INDEX
- See Also:
-
MDC_MATS_IN_MESSAGE_SYSTEM_ID
- See Also:
-
MDC_MATS_OUT_MATS_MESSAGE_ID
- See Also:
-
JMS_MSG_PROP_TRACE_ID
- See Also:
-
JMS_MSG_PROP_MATS_MESSAGE_ID
- See Also:
-
JMS_MSG_PROP_DISPATCH_TYPE
- See Also:
-
JMS_MSG_PROP_MESSAGE_TYPE
- See Also:
-
JMS_MSG_PROP_FROM
- See Also:
-
JMS_MSG_PROP_INITIALIZING_APP
- See Also:
-
JMS_MSG_PROP_INITIATOR_ID
- See Also:
-
JMS_MSG_PROP_TO
- See Also:
-
JMS_MSG_PROP_AUDIT
- See Also:
-
TOTAL_JMS_MSG_PROPS_SIZE
static final int TOTAL_JMS_MSG_PROPS_SIZE -
EXTRA_GRACE_MILLIS
static final int EXTRA_GRACE_MILLISNumber of milliseconds to "extra wait" after timeoutMillis or gracefulShutdownMillis is gone.- See Also:
-
MAX_TOTAL_CALL_NUMBER
static final int MAX_TOTAL_CALL_NUMBERIf an outgoing message hasMatsTrace.getTotalCallNumber()
higher than this (100), the processing will be refused (i.e.MatsEndpoint.MatsRefuseMessageException
will be thrown).- See Also:
-
MAX_STACK_HEIGHT
static final int MAX_STACK_HEIGHTIf an outgoing message hasMatsTrace.Call.getReplyStackHeight()
higher than this (25), the processing will be refused (i.e.MatsEndpoint.MatsRefuseMessageException
will be thrown).- See Also:
-
ILLEGAL_CALL_FLOWS
Log prefix (afterLOG_PREFIX
) for flows that are illegal.- See Also:
-
RANDOM_ALPHABET
- See Also:
-
NO_INVOCATION_POINT
- See Also:
-
-
Method Details
-
produceAndSendMsgSysMessages
default <Z> void produceAndSendMsgSysMessages(org.slf4j.Logger log, JmsMatsJmsSessionHandler.JmsSessionHolder jmsSessionHolder, JmsMatsFactory<Z> jmsMatsFactory, List<JmsMatsMessage<Z>> messagesToSend) throws JmsMatsException.JmsMatsJmsException Send a bunch ofJmsMatsMessage
s. -
handleIncomingState
static <S,Z> S handleIncomingState(MatsSerializer<Z> matsSerializer, Class<S> stateClass, MatsTrace.StackState<Z> stackState) -
handleIncomingMessageMatsObject
static <I,Z> I handleIncomingMessageMatsObject(MatsSerializer<Z> matsSerializer, Class<I> incomingMessageClass, Z data) -
randomString
- Parameters:
length
- the desired length of the returned random string.- Returns:
- a random string of the specified length.
-
createFlowId
-
id
-
id
-
idThis
-
stageOrInit
-
ms3
default double ms3(double ms) Truncate milliseconds to 3 decimals. -
getInvocationPoint
Inspired from Stackoverflow - Denys Séguret.- Returns:
- a String showing where the Mats-code was invoked from, like "Test.java.123;com.example.Test;methodName()"
-
setConcurrencyWithLog
default void setConcurrencyWithLog(org.slf4j.Logger log, String what, Supplier<Integer> getter, Supplier<Boolean> isDefault, Consumer<Integer> setter, int newConcurrency) Set concurrency on entity, printing log
-