public static interface MatsEndpoint.DetachedProcessContext
MatsEndpoint.ProcessContext
that exposes the "getter" side of the context, which enables it to be exposed
outside of the process lambda. It is effectively the "passive" parts of the context, i.e. not initiating new
messages, setting properties etc. Look for usage in the "MatsFuturizer" tool in the tools-lib.Modifier and Type | Method and Description |
---|---|
byte[] |
getBytes(java.lang.String key)
Get binary "sideloads" from the incoming message.
|
java.util.Set<java.lang.String> |
getBytesKeys() |
java.lang.String |
getEndpointId() |
java.lang.String |
getFromAppName() |
java.lang.String |
getFromAppVersion() |
java.lang.String |
getFromStageId() |
java.time.Instant |
getFromTimestamp() |
java.lang.String |
getInitiatingAppName() |
java.lang.String |
getInitiatingAppVersion() |
java.time.Instant |
getInitiatingTimestamp() |
java.lang.String |
getInitiatorId() |
java.lang.String |
getMatsMessageId() |
java.lang.String |
getStageId() |
java.lang.String |
getString(java.lang.String key)
Get
String "sideloads" from the incoming message. |
java.util.Set<java.lang.String> |
getStringKeys() |
java.lang.String |
getSystemMessageId() |
java.lang.String |
getTraceId() |
<T> T |
getTraceProperty(java.lang.String propertyName,
java.lang.Class<T> clazz)
Retrieves the Mats Trace property with the specified name, deserializing the value to the specified class,
using the active MATS serializer.
|
boolean |
isInteractive()
This is relevant if stashing or otherwise when a stage is accessing an external system (e.g.
|
boolean |
isNoAudit()
Hint to monitoring/logging/auditing systems that this call flow is not very valuable to fully audit,
typically because it is just a "getter" of information for display to a user, or is health check request to
see if the endpoint is up and answers in a timely manner.
|
boolean |
isNonPersistent()
This is relevant if stashing or otherwise when a stage is accessing an external system (e.g.
|
java.lang.String |
toString() |
java.lang.String getTraceId()
trace id
for the processed message.MatsInitiator.MatsInitiate.traceId(CharSequence)
java.lang.String getEndpointId()
java.lang.String getStageId()
getEndpointId()
for the first stage in multi-stage-endpoint, and for the sole stage of a
single-stage and terminator endpoint. Should probably never be necessary, but accessible for
introspection.java.lang.String getFromAppName()
AppName
of the MatsFactory from which the currently processing
message came. Thus, if this message is the result of a 'next' call, it will be yourself.java.lang.String getFromAppVersion()
AppVersion
of the MatsFactory from which the currently
processing message came. Thus, if this message is the result of a 'next' call, it will be yourself.java.lang.String getFromStageId()
getInitiatorId()
.java.time.Instant getFromTimestamp()
Instant
which this message was created on the sending stage.java.lang.String getInitiatingAppName()
AppName
of the MatsFactory that initiated the Flow which the
currently processing is a part of. Thus, if this endpoint is the initial target of the initiation,
this value is equal to getFromAppName()
.java.lang.String getInitiatingAppVersion()
AppVersion
of the MatsFactory that initiated the Flow which
the currently processing is a part of. Thus, if this endpoint is the initial target of the
initiation, this value is equal to getFromAppVersion()
.java.lang.String getInitiatorId()
MatsInitiator.MatsInitiate.from(String)
.java.time.Instant getInitiatingTimestamp()
Instant
which this message was initiated, i.e. sent from a MatsInitiator (or within a
Stage).java.lang.String getMatsMessageId()
java.lang.String getSystemMessageId()
getMatsMessageId()
. (For a JMS
Implementation, this will be the "JMSMessageID").boolean isNonPersistent()
MatsInitiator.MatsInitiate.nonPersistent()
.boolean isInteractive()
MatsInitiator.MatsInitiate.interactive()
.boolean isNoAudit()
MatsInitiator.MatsInitiate.noAudit()
.java.util.Set<java.lang.String> getBytesKeys()
bytes
lives.byte[] getBytes(java.lang.String key)
key
- the key for which to retrieve a binary payload from the incoming message.getBytesKeys()
,
MatsEndpoint.ProcessContext.addBytes(String, byte[])
,
getString(String)
,
getTraceProperty(String, Class)
java.util.Set<java.lang.String> getStringKeys()
strings
lives.java.lang.String getString(java.lang.String key)
String
"sideloads" from the incoming message.key
- the key for which to retrieve a String payload from the incoming message.getStringKeys()
,
MatsEndpoint.ProcessContext.addString(String, String)
,
getBytes(String)
,
getTraceProperty(String, Class)
<T> T getTraceProperty(java.lang.String propertyName, java.lang.Class<T> clazz)
MatsEndpoint.ProcessContext.setTraceProperty(String, Object)
.propertyName
- the name of the Mats Trace property to retrieve.clazz
- the class to which the value should be deserialized.MatsEndpoint.ProcessContext.setTraceProperty(String, Object)
java.lang.String toString()
toString
in class java.lang.Object