io.mats3.impl.jms

Class JmsMatsInternalExecutionContext

java.lang.Object

io.mats3.impl.jms.JmsMatsInternalExecutionContext

public class JmsMatsInternalExecutionContext
extends java.lang.Object

This is an internal context object, for execution of initiations and stage processing in JMS-Mats - one instance is made per initiation and per message reception. This is used to communicate back and forth between JmsMats proper, the JmsMatsJmsSessionHandler and JmsMatsTransactionManager.

Method Summary

Modifier and Type	Method and Description
long	getDbCommitNanos()
JmsMatsJmsSessionHandler.JmsSessionHolder	getJmsSessionHolder()
java.util.Optional<javax.jms.MessageConsumer>	getMessageConsumer()
long	getMessageSystemCommitNanos()
boolean	isUserLambdaExceptionLogged()
void	setDbCommitNanos(long dbCommitNanos)
void	setMessageSystemCommitNanos(long messageSystemCommitNanos)
void	setSqlTxConnectionSuppliers(java.util.function.Supplier<java.sql.Connection> sqlConnectionSupplier, java.util.function.Supplier<java.lang.Boolean> sqlConnectionEmployedSupplier) 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).
void	setUserLambdaExceptionLogged()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getJmsSessionHolder

public JmsMatsJmsSessionHandler.JmsSessionHolder getJmsSessionHolder()

getMessageConsumer

public java.util.Optional<javax.jms.MessageConsumer> getMessageConsumer()

Returns:

the MessageConsumer in effect if this is within a JmsMatsStageProcessor, returns Optional.empty() if this is within a JmsMatsInitiator.

setSqlTxConnectionSuppliers

public void setSqlTxConnectionSuppliers(java.util.function.Supplier<java.sql.Connection> sqlConnectionSupplier,
                                        java.util.function.Supplier<java.lang.Boolean> sqlConnectionEmployedSupplier)

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

Parameters:

sqlConnectionSupplier - a supplier for the current transactional SQL Connection

sqlConnectionEmployedSupplier - a supplier for whether the SQL Connection was actually employed (if this is not possible to determine, then return whether it was gotten).

setUserLambdaExceptionLogged

public void setUserLambdaExceptionLogged()

isUserLambdaExceptionLogged

public boolean isUserLambdaExceptionLogged()

setDbCommitNanos

public void setDbCommitNanos(long dbCommitNanos)

getDbCommitNanos

public long getDbCommitNanos()

setMessageSystemCommitNanos

public void setMessageSystemCommitNanos(long messageSystemCommitNanos)

getMessageSystemCommitNanos

public long getMessageSystemCommitNanos()