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

Fields

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

Method Summary

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 JmsMatsMessages.
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)

Field Detail

LOG_PREFIX

static final java.lang.String LOG_PREFIX

See Also:

Constant Field Values

THREAD_PREFIX

static final java.lang.String THREAD_PREFIX

See Also:

Constant Field Values

MDC_TRACE_ID

static final java.lang.String MDC_TRACE_ID

See Also:

Constant Field Values

MDC_MATS_CALL_NUMBER

static final java.lang.String MDC_MATS_CALL_NUMBER

See Also:

Constant Field Values

MDC_MATS_APP_NAME

static final java.lang.String MDC_MATS_APP_NAME

See Also:

Constant Field Values

MDC_MATS_APP_VERSION

static final java.lang.String MDC_MATS_APP_VERSION

See Also:

Constant Field Values

MDC_MATS_INIT

static final java.lang.String MDC_MATS_INIT

See Also:

Constant Field Values

MDC_MATS_STAGE

static final java.lang.String MDC_MATS_STAGE

See Also:

Constant Field Values

MDC_MATS_STAGE_ID

static final java.lang.String MDC_MATS_STAGE_ID

See Also:

Constant Field Values

MDC_MATS_IN_MESSAGE_SYSTEM_ID

static final java.lang.String MDC_MATS_IN_MESSAGE_SYSTEM_ID

See Also:

Constant Field Values

MDC_MATS_OUT_MATS_MESSAGE_ID

static final java.lang.String MDC_MATS_OUT_MATS_MESSAGE_ID

See Also:

Constant Field Values

JMS_MSG_PROP_TRACE_ID

static final java.lang.String JMS_MSG_PROP_TRACE_ID

See Also:

Constant Field Values

JMS_MSG_PROP_MATS_MESSAGE_ID

static final java.lang.String JMS_MSG_PROP_MATS_MESSAGE_ID

See Also:

Constant Field Values

JMS_MSG_PROP_DISPATCH_TYPE

static final java.lang.String JMS_MSG_PROP_DISPATCH_TYPE

See Also:

Constant Field Values

JMS_MSG_PROP_MESSAGE_TYPE

static final java.lang.String JMS_MSG_PROP_MESSAGE_TYPE

See Also:

Constant Field Values

JMS_MSG_PROP_FROM

static final java.lang.String JMS_MSG_PROP_FROM

See Also:

Constant Field Values

JMS_MSG_PROP_INITIALIZING_APP

static final java.lang.String JMS_MSG_PROP_INITIALIZING_APP

See Also:

Constant Field Values

JMS_MSG_PROP_INITIATOR_ID

static final java.lang.String JMS_MSG_PROP_INITIATOR_ID

See Also:

Constant Field Values

JMS_MSG_PROP_TO

static final java.lang.String JMS_MSG_PROP_TO

See Also:

Constant Field Values

JMS_MSG_PROP_AUDIT

static final java.lang.String JMS_MSG_PROP_AUDIT

See Also:

Constant Field Values

TOTAL_JMS_MSG_PROPS_SIZE

static final int TOTAL_JMS_MSG_PROPS_SIZE

EXTRA_GRACE_MILLIS

static final int EXTRA_GRACE_MILLIS

Number of milliseconds to "extra wait" after timeoutMillis or gracefulShutdownMillis is gone.

See Also:

Constant Field Values

MAX_TOTAL_CALL_NUMBER

static final int MAX_TOTAL_CALL_NUMBER

If an outgoing message has MatsTrace.getTotalCallNumber() higher than this (100), the processing will be refused (i.e. MatsEndpoint.MatsRefuseMessageException will be thrown).

See Also:

Constant Field Values

MAX_STACK_HEIGHT

static final int MAX_STACK_HEIGHT

If an outgoing message has MatsTrace.Call.getReplyStackHeight() higher than this (25), the processing will be refused (i.e. MatsEndpoint.MatsRefuseMessageException will be thrown).

See Also:

Constant Field Values

ILLEGAL_CALL_FLOWS

static final java.lang.String ILLEGAL_CALL_FLOWS

Log prefix (after LOG_PREFIX) for flows that are illegal.

See Also:

Constant Field Values

RANDOM_ALPHABET

static final java.lang.String RANDOM_ALPHABET

See Also:

Constant Field Values

NO_INVOCATION_POINT

static final java.lang.String NO_INVOCATION_POINT

See Also:

Constant Field Values

Method Detail

produceAndSendMsgSysMessages

default <Z> void produceAndSendMsgSysMessages(org.slf4j.Logger log,
                                              JmsMatsJmsSessionHandler.JmsSessionHolder jmsSessionHolder,
                                              JmsMatsFactory<Z> jmsMatsFactory,
                                              java.util.List<JmsMatsMessage<Z>> messagesToSend)
                                       throws JmsMatsException.JmsMatsJmsException

Send a bunch of JmsMatsMessages.

Throws:

JmsMatsException.JmsMatsJmsException

handleIncomingState

static <S,Z> S handleIncomingState(MatsSerializer<Z> matsSerializer,
                                   java.lang.Class<S> stateClass,
                                   MatsTrace.StackState<Z> stackState)

handleIncomingMessageMatsObject

static <I,Z> I handleIncomingMessageMatsObject(MatsSerializer<Z> matsSerializer,
                                               java.lang.Class<I> incomingMessageClass,
                                               Z data)

randomString

default java.lang.String randomString(int length)

Parameters:

length - the desired length of the returned random string.

Returns:

a random string of the specified length.

createFlowId

default java.lang.String createFlowId(long creationTimeMillis)

id

default java.lang.String id(java.lang.String what,
                            java.lang.Object obj)

id

default java.lang.String id(java.lang.Object obj)

idThis

default java.lang.String idThis()

stageOrInit

default java.lang.String stageOrInit(JmsMatsTransactionManager.JmsMatsTxContextKey txContextKey)

ms3

default double ms3(double ms)

Truncate milliseconds to 3 decimals.

getInvocationPoint

default java.lang.String 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,
                                   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