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

Fields

Modifier and Type	Field	Description
static final int	EXTRA_GRACE_MILLIS	Number of milliseconds to "extra wait" after timeoutMillis or gracefulShutdownMillis is gone.
static final String	ILLEGAL_CALL_FLOWS	Log prefix (after LOG_PREFIX) for flows that are illegal.
static final String	JMS_MSG_PROP_AUDIT
static final String	JMS_MSG_PROP_DISPATCH_TYPE
static final String	JMS_MSG_PROP_FROM
static final String	JMS_MSG_PROP_INITIALIZING_APP
static final String	JMS_MSG_PROP_INITIATOR_ID
static final String	JMS_MSG_PROP_MATS_MESSAGE_ID
static final String	JMS_MSG_PROP_MESSAGE_TYPE
static final String	JMS_MSG_PROP_TO
static final String	JMS_MSG_PROP_TRACE_ID
static final String	LOG_PREFIX
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.
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.
static final String	MDC_MATS_APP_NAME
static final String	MDC_MATS_APP_VERSION
static final String	MDC_MATS_CALL_NUMBER
static final String	MDC_MATS_IN_MESSAGE_SYSTEM_ID
static final String	MDC_MATS_INIT
static final String	MDC_MATS_OUT_MATS_MESSAGE_ID
static final String	MDC_MATS_STAGE
static final String	MDC_MATS_STAGE_ID
static final String	MDC_TRACE_ID
static final String	NO_INVOCATION_POINT
static final String	RANDOM_ALPHABET
static final String	THREAD_PREFIX
static final int	TOTAL_JMS_MSG_PROPS_SIZE

Method Summary

Modifier and Type	Method	Description
default String	createFlowId(long creationTimeMillis)
default String	getInvocationPoint()	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	id(Object obj)
default String	id(String what, Object obj)
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 of JmsMatsMessages.
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 log
default String	stageOrInit(JmsMatsTransactionManager.JmsMatsTxContextKey txContextKey)

Field Details

LOG_PREFIX

static final String LOG_PREFIX

See Also:

• Constant Field Values

THREAD_PREFIX

static final String THREAD_PREFIX

See Also:

• Constant Field Values

MDC_TRACE_ID

static final String MDC_TRACE_ID

See Also:

• Constant Field Values

MDC_MATS_CALL_NUMBER

static final String MDC_MATS_CALL_NUMBER

See Also:

• Constant Field Values

MDC_MATS_APP_NAME

static final String MDC_MATS_APP_NAME

See Also:

• Constant Field Values

MDC_MATS_APP_VERSION

static final String MDC_MATS_APP_VERSION

See Also:

• Constant Field Values

MDC_MATS_INIT

static final String MDC_MATS_INIT

See Also:

• Constant Field Values

MDC_MATS_STAGE

static final String MDC_MATS_STAGE

See Also:

• Constant Field Values

MDC_MATS_STAGE_ID

static final String MDC_MATS_STAGE_ID

See Also:

• Constant Field Values

MDC_MATS_IN_MESSAGE_SYSTEM_ID

static final String MDC_MATS_IN_MESSAGE_SYSTEM_ID

See Also:

• Constant Field Values

MDC_MATS_OUT_MATS_MESSAGE_ID

static final String MDC_MATS_OUT_MATS_MESSAGE_ID

See Also:

• Constant Field Values

JMS_MSG_PROP_TRACE_ID

static final String JMS_MSG_PROP_TRACE_ID

See Also:

• Constant Field Values

JMS_MSG_PROP_MATS_MESSAGE_ID

static final String JMS_MSG_PROP_MATS_MESSAGE_ID

See Also:

• Constant Field Values

JMS_MSG_PROP_DISPATCH_TYPE

static final String JMS_MSG_PROP_DISPATCH_TYPE

See Also:

• Constant Field Values

JMS_MSG_PROP_MESSAGE_TYPE

static final String JMS_MSG_PROP_MESSAGE_TYPE

See Also:

• Constant Field Values

JMS_MSG_PROP_FROM

static final String JMS_MSG_PROP_FROM

See Also:

• Constant Field Values

JMS_MSG_PROP_INITIALIZING_APP

static final String JMS_MSG_PROP_INITIALIZING_APP

See Also:

• Constant Field Values

JMS_MSG_PROP_INITIATOR_ID

static final String JMS_MSG_PROP_INITIATOR_ID

See Also:

• Constant Field Values

JMS_MSG_PROP_TO

static final String JMS_MSG_PROP_TO

See Also:

• Constant Field Values

JMS_MSG_PROP_AUDIT

static final 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 String ILLEGAL_CALL_FLOWS

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

See Also:

• Constant Field Values

RANDOM_ALPHABET

static final String RANDOM_ALPHABET

See Also:

• Constant Field Values

NO_INVOCATION_POINT

static final String NO_INVOCATION_POINT

See Also:

• Constant Field Values

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

Throws:

JmsMatsException.JmsMatsJmsException

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

default String randomString(int length)

Parameters:

length - the desired length of the returned random string.

Returns:

a random string of the specified length.

createFlowId

default String createFlowId(long creationTimeMillis)

id

default String id(String what,
 Object obj)

id

default String id(Object obj)

idThis

default String idThis()

stageOrInit

default String stageOrInit(JmsMatsTransactionManager.JmsMatsTxContextKey txContextKey)

ms3

default double ms3(double ms)

Truncate milliseconds to 3 decimals.

getInvocationPoint

default 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,
 String what,
 Supplier<Integer> getter,
 Supplier<Boolean> isDefault,
 Consumer<Integer> setter,
 int newConcurrency)

Set concurrency on entity, printing log