public static interface MatsEndpoint.EndpointConfig<R,S> extends MatsConfig
MatsConfig.StartStoppable
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getEndpointId() |
java.lang.Class<?> |
getIncomingClass() |
java.lang.String |
getOrigin() |
java.lang.Class<R> |
getReplyClass() |
java.lang.Class<S> |
getStateClass() |
boolean |
isSubscription() |
MatsEndpoint.EndpointConfig<R,S> |
setAttribute(java.lang.String key,
java.lang.Object value)
Sets an attribute for this entity (factory, endpoint, stage) - can e.g.
|
MatsEndpoint.EndpointConfig<R,S> |
setConcurrency(int concurrency)
Changes the default concurrency of the Factory, or of the endpoint (which defaults to the concurrency of the
MatsFactory ), or of the process stage (which defaults to the concurrency of the MatsEndpoint ). |
MatsEndpoint.EndpointConfig<R,S> |
setInteractiveConcurrency(int concurrency)
Like
MatsConfig.setConcurrency(int) , but changes the "interactive concurrency" specifically - this is relevant for
the Mats Flows that are initiated with the interactive flag set. |
MatsEndpoint.EndpointConfig<R,S> |
setOrigin(java.lang.String info)
Sets the origin for this Endpoint, i.e.
|
getAttribute, getConcurrency, getInteractiveConcurrency, isConcurrencyDefault, isInteractiveConcurrencyDefault, isRunning
java.lang.String getEndpointId()
MatsEndpoint
.boolean isSubscription()
MatsFactory#subscriptionTerminator(String, Class, Class, ProcessTerminatorLambda)
.java.lang.Class<R> getReplyClass()
java.lang.Class<S> getStateClass()
java.lang.Class<?> getIncomingClass()
MatsStage
).MatsEndpoint.EndpointConfig<R,S> setOrigin(java.lang.String info)
automatically created creation info
is useless, as it is when Mats' SpringConfig defines
the endpoints (thus it employs this method to set something more informative). It should be a single line, no
line feeds, but tooling might split the String into multiple lines on the character ';'. It should definitely
be short, but informative.java.lang.String getOrigin()
setOrigin(String)
, as is done by
Mats' SpringConfig.MatsEndpoint.EndpointConfig<R,S> setAttribute(java.lang.String key, java.lang.Object value)
MatsConfig
null
, the mapping for the specified key is cleared.setAttribute
in interface MatsConfig
key
- the key name for this attribute. Not null
.value
- the value for this attribute. If the value is null
, the mapping for the specified key is
cleared.MatsEndpoint.EndpointConfig<R,S> setConcurrency(int concurrency)
MatsConfig
MatsFactory
), or of the process stage (which defaults to the concurrency of the MatsEndpoint
).
Will only have effect before the MatsStage
is started. Can be reset by stopping, setting, and restarting.
Setting to 0 will invoke default logic.setConcurrency
in interface MatsConfig
concurrency
- the concurrency for the Factory, or Endpoint, or Stage. If set to 0, default-logic is in effect.MatsConfig.getConcurrency()
MatsEndpoint.EndpointConfig<R,S> setInteractiveConcurrency(int concurrency)
MatsConfig
MatsConfig.setConcurrency(int)
, but changes the "interactive concurrency" specifically - this is relevant for
the Mats Flows that are initiated with the interactive
flag set.setInteractiveConcurrency
in interface MatsConfig
concurrency
- the interactive concurrency for the Factory, or Endpoint, or Stage. If set to 0, default-logic is in
effect.MatsConfig.getInteractiveConcurrency()