public abstract class AbstractMessage extends AbstractPoolable
Modifier and Type | Field and Description |
---|---|
protected boolean |
consumerAdminFiltered_ |
protected boolean |
proxyConsumerFiltered_ |
protected boolean |
proxySupplierFiltered_ |
protected int |
referenced_
Internal Reference Counter.
|
protected boolean |
supplierAdminFiltered_ |
logger_
Constructor and Description |
---|
AbstractMessage() |
Modifier and Type | Method and Description |
---|---|
void |
addReference()
Add a reference on this NotificationEvent.
|
static String |
calcConstraintKey(String domain_name,
String type_name)
Provide a Uniform Mapping from domain_name and type_name to a Key that can be used to put
EventTypes into a Map.
|
protected void |
doReset() |
abstract EvaluationResult |
extractFilterableData(EvaluationContext context,
ComponentName componentRootNode,
String variable) |
EvaluationResult |
extractValue(EvaluationContext evaluationContext,
ComponentName componentRootNode) |
EvaluationResult |
extractValue(EvaluationContext context,
ComponentName componentRootNode,
RuntimeVariable runtimeVariable) |
abstract EvaluationResult |
extractVariableHeader(EvaluationContext context,
ComponentName componentRootNode,
String variable) |
abstract String |
getConstraintKey()
get the Constraint Key for this Event.
|
FilterStage |
getFilterStage() |
Message |
getHandle() |
abstract int |
getPriority() |
long |
getReceiveTimestamp() |
abstract long |
getStartTime() |
abstract long |
getStopTime() |
abstract long |
getTimeout() |
abstract int |
getType()
get the Type of this NotificationEvent.
|
abstract boolean |
hasStartTime() |
abstract boolean |
hasStopTime() |
abstract boolean |
hasTimeout() |
void |
initReceiveTimestamp() |
abstract boolean |
match(Filter filter) |
boolean |
match(FilterStage filterStage) |
abstract boolean |
match(MappingFilter filter,
AnyHolder value) |
protected void |
removeReference()
release this NotificationEvent.
|
void |
reset()
Reset the Object to an initial state.
|
void |
setFilterStage(FilterStage node) |
abstract Any |
toAny()
Access this NotificationEvent as Any.
|
abstract StructuredEvent |
toStructuredEvent()
Access this NotificationEvent as StructuredEvent.
|
abstract Property[] |
toTypedEvent()
convert this message to a TypedEvent.
|
dispose, setObjectPool
protected boolean proxyConsumerFiltered_
protected boolean supplierAdminFiltered_
protected boolean consumerAdminFiltered_
protected boolean proxySupplierFiltered_
protected int referenced_
public abstract String getConstraintKey()
String
valuepublic long getReceiveTimestamp()
public abstract Any toAny()
Any
valuepublic abstract Property[] toTypedEvent() throws NoTranslationException
NoTranslationException
- if the contents of the message cannot be translated into a TypedEvent.public abstract StructuredEvent toStructuredEvent()
StructuredEvent
valuepublic abstract int getType()
Message.TYPE_ANY
,Message.TYPE_STRUCTURED
, or Message.TYPE_TYPED
.public final void reset()
AbstractPoolable
reset
in class AbstractPoolable
protected void doReset()
public void addReference()
protected void removeReference()
public void setFilterStage(FilterStage node)
public FilterStage getFilterStage()
public EvaluationResult extractValue(EvaluationContext context, ComponentName componentRootNode, RuntimeVariable runtimeVariable) throws EvaluationException
EvaluationException
public abstract EvaluationResult extractFilterableData(EvaluationContext context, ComponentName componentRootNode, String variable) throws EvaluationException
EvaluationException
public abstract EvaluationResult extractVariableHeader(EvaluationContext context, ComponentName componentRootNode, String variable) throws EvaluationException
EvaluationException
public EvaluationResult extractValue(EvaluationContext evaluationContext, ComponentName componentRootNode) throws EvaluationException
EvaluationException
public Message getHandle()
public void initReceiveTimestamp()
public abstract boolean hasStartTime()
public abstract long getStartTime()
public abstract boolean hasStopTime()
public abstract long getStopTime()
public abstract boolean hasTimeout()
public abstract long getTimeout()
public abstract int getPriority()
public abstract boolean match(Filter filter) throws UnsupportedFilterableData
UnsupportedFilterableData
public boolean match(FilterStage filterStage)
public abstract boolean match(MappingFilter filter, AnyHolder value) throws UnsupportedFilterableData
UnsupportedFilterableData
public static String calcConstraintKey(String domain_name, String type_name)
domain_name
- a String
valuetype_name
- a String
valueCopyright © 2017 JacORB. All rights reserved.