public interface JmsMatsStatics
Modifier and Type | Field and Description |
---|---|
static int |
EXTRA_GRACE_MILLIS
Number of milliseconds to "extra wait" after timeoutMillis or gracefulShutdownMillis is gone.
|
static java.lang.String |
ILLEGAL_CALL_FLOWS
Log prefix (after
LOG_PREFIX ) for flows that are illegal. |
static java.lang.String |
JMS_MSG_PROP_AUDIT |
static java.lang.String |
JMS_MSG_PROP_DISPATCH_TYPE |
static java.lang.String |
JMS_MSG_PROP_FROM |
static java.lang.String |
JMS_MSG_PROP_INITIALIZING_APP |
static java.lang.String |
JMS_MSG_PROP_INITIATOR_ID |
static java.lang.String |
JMS_MSG_PROP_MATS_MESSAGE_ID |
static java.lang.String |
JMS_MSG_PROP_MESSAGE_TYPE |
static java.lang.String |
JMS_MSG_PROP_TO |
static java.lang.String |
JMS_MSG_PROP_TRACE_ID |
static java.lang.String |
LOG_PREFIX |
static int |
MAX_STACK_HEIGHT
If an outgoing message has
MatsTrace.Call.getReplyStackHeight() higher than this (25), the processing will be
refused (i.e. |
static int |
MAX_TOTAL_CALL_NUMBER
If an outgoing message has
MatsTrace.getTotalCallNumber() higher than this (100), the processing will be
refused (i.e. |
static java.lang.String |
MDC_MATS_APP_NAME |
static java.lang.String |
MDC_MATS_APP_VERSION |
static java.lang.String |
MDC_MATS_CALL_NUMBER |
static java.lang.String |
MDC_MATS_IN_MESSAGE_SYSTEM_ID |
static java.lang.String |
MDC_MATS_INIT |
static java.lang.String |
MDC_MATS_OUT_MATS_MESSAGE_ID |
static java.lang.String |
MDC_MATS_STAGE |
static java.lang.String |
MDC_MATS_STAGE_ID |
static java.lang.String |
MDC_TRACE_ID |
static java.lang.String |
NO_INVOCATION_POINT |
static java.lang.String |
RANDOM_ALPHABET |
static java.lang.String |
THREAD_PREFIX |
static int |
TOTAL_JMS_MSG_PROPS_SIZE |
Modifier and Type | Method and Description |
---|---|
default java.lang.String |
createFlowId(long creationTimeMillis) |
default java.lang.String |
getInvocationPoint()
Inspired from Stackoverflow - Denys Séguret.
|
static <I,Z> I |
handleIncomingMessageMatsObject(MatsSerializer<Z> matsSerializer,
java.lang.Class<I> incomingMessageClass,
Z data) |
static <S,Z> S |
handleIncomingState(MatsSerializer<Z> matsSerializer,
java.lang.Class<S> stateClass,
MatsTrace.StackState<Z> stackState) |
default java.lang.String |
id(java.lang.Object obj) |
default java.lang.String |
id(java.lang.String what,
java.lang.Object obj) |
default java.lang.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,
java.util.List<JmsMatsMessage<Z>> messagesToSend)
Send a bunch of
JmsMatsMessage s. |
default java.lang.String |
randomString(int length) |
default void |
setConcurrencyWithLog(org.slf4j.Logger log,
java.lang.String what,
java.util.function.Supplier<java.lang.Integer> getter,
java.util.function.Supplier<java.lang.Boolean> isDefault,
java.util.function.Consumer<java.lang.Integer> setter,
int newConcurrency)
Set concurrency on entity, printing log
|
default java.lang.String |
stageOrInit(JmsMatsTransactionManager.JmsMatsTxContextKey txContextKey) |
static final java.lang.String LOG_PREFIX
static final java.lang.String THREAD_PREFIX
static final java.lang.String MDC_TRACE_ID
static final java.lang.String MDC_MATS_CALL_NUMBER
static final java.lang.String MDC_MATS_APP_NAME
static final java.lang.String MDC_MATS_APP_VERSION
static final java.lang.String MDC_MATS_INIT
static final java.lang.String MDC_MATS_STAGE
static final java.lang.String MDC_MATS_STAGE_ID
static final java.lang.String MDC_MATS_IN_MESSAGE_SYSTEM_ID
static final java.lang.String MDC_MATS_OUT_MATS_MESSAGE_ID
static final java.lang.String JMS_MSG_PROP_TRACE_ID
static final java.lang.String JMS_MSG_PROP_MATS_MESSAGE_ID
static final java.lang.String JMS_MSG_PROP_DISPATCH_TYPE
static final java.lang.String JMS_MSG_PROP_MESSAGE_TYPE
static final java.lang.String JMS_MSG_PROP_FROM
static final java.lang.String JMS_MSG_PROP_INITIALIZING_APP
static final java.lang.String JMS_MSG_PROP_INITIATOR_ID
static final java.lang.String JMS_MSG_PROP_TO
static final java.lang.String JMS_MSG_PROP_AUDIT
static final int TOTAL_JMS_MSG_PROPS_SIZE
static final int EXTRA_GRACE_MILLIS
static final int MAX_TOTAL_CALL_NUMBER
MatsTrace.getTotalCallNumber()
higher than this (100), the processing will be
refused (i.e. MatsEndpoint.MatsRefuseMessageException
will be thrown).static final int MAX_STACK_HEIGHT
MatsTrace.Call.getReplyStackHeight()
higher than this (25), the processing will be
refused (i.e. MatsEndpoint.MatsRefuseMessageException
will be thrown).static final java.lang.String ILLEGAL_CALL_FLOWS
LOG_PREFIX
) for flows that are illegal.static final java.lang.String RANDOM_ALPHABET
static final java.lang.String NO_INVOCATION_POINT
default <Z> void produceAndSendMsgSysMessages(org.slf4j.Logger log, JmsMatsJmsSessionHandler.JmsSessionHolder jmsSessionHolder, JmsMatsFactory<Z> jmsMatsFactory, java.util.List<JmsMatsMessage<Z>> messagesToSend) throws JmsMatsException.JmsMatsJmsException
JmsMatsMessage
s.static <S,Z> S handleIncomingState(MatsSerializer<Z> matsSerializer, java.lang.Class<S> stateClass, MatsTrace.StackState<Z> stackState)
static <I,Z> I handleIncomingMessageMatsObject(MatsSerializer<Z> matsSerializer, java.lang.Class<I> incomingMessageClass, Z data)
default java.lang.String randomString(int length)
length
- the desired length of the returned random string.default java.lang.String createFlowId(long creationTimeMillis)
default java.lang.String id(java.lang.String what, java.lang.Object obj)
default java.lang.String id(java.lang.Object obj)
default java.lang.String idThis()
default java.lang.String stageOrInit(JmsMatsTransactionManager.JmsMatsTxContextKey txContextKey)
default double ms3(double ms)
default java.lang.String getInvocationPoint()
default void setConcurrencyWithLog(org.slf4j.Logger log, java.lang.String what, java.util.function.Supplier<java.lang.Integer> getter, java.util.function.Supplier<java.lang.Boolean> isDefault, java.util.function.Consumer<java.lang.Integer> setter, int newConcurrency)