public class BDIXMessageComponentFeature extends MessageComponentFeature implements IInternalBDIXMessageFeature
Modifier and Type | Field and Description |
---|---|
static IComponentFeatureFactory |
FACTORY
The factory.
|
protected long |
mevents_max
The maximum number of outstanding messages.
|
protected java.util.List<RMessageEvent<java.lang.Object>> |
sent_meventlist
Sent message tracking (insertion order).
|
protected java.util.Map<RMessageEvent<java.lang.Object>,java.lang.Integer> |
sent_mevents
Sent message tracking (msg->cnt).
|
Constructor and Description |
---|
BDIXMessageComponentFeature(IInternalAccess component,
ComponentCreationInfo cinfo)
Create the feature.
|
Modifier and Type | Method and Description |
---|---|
void |
deregisterMessageEvent(RMessageEvent<java.lang.Object> msgevent)
Deregister a conversation or reply-with.
|
RMessageEvent<java.lang.Object> |
getInReplyMessageEvent(java.lang.Object message)
Find a message event that the given native message is a reply to.
|
protected boolean |
match(MMessageEvent msgevent,
java.util.Map<java.lang.String,java.lang.Object> msg)
Match a message with a message event.
|
protected int |
matchMessageEvents(java.util.Map<java.lang.String,java.lang.Object> message,
java.util.List<MMessageEvent> mevents,
java.util.List<MMessageEvent> matched,
java.util.List<MMessageEvent> events,
int degree,
boolean checkscope,
java.lang.String scope)
Match message events with a message adapter.
|
protected void |
processUnhandledMessage(ISecurityInfo secinf,
IMsgHeader header,
java.lang.Object body)
Test if there are matching message events in XML description.
|
void |
registerMessageEvent(RMessageEvent<java.lang.Object> msgevent)
Register a conversation or reply-with to be able
to send back answers to the source capability.
|
public static final IComponentFeatureFactory FACTORY
protected java.util.Map<RMessageEvent<java.lang.Object>,java.lang.Integer> sent_mevents
protected java.util.List<RMessageEvent<java.lang.Object>> sent_meventlist
protected long mevents_max
public BDIXMessageComponentFeature(IInternalAccess component, ComponentCreationInfo cinfo)
protected void processUnhandledMessage(ISecurityInfo secinf, IMsgHeader header, java.lang.Object body)
protected int matchMessageEvents(java.util.Map<java.lang.String,java.lang.Object> message, java.util.List<MMessageEvent> mevents, java.util.List<MMessageEvent> matched, java.util.List<MMessageEvent> events, int degree, boolean checkscope, java.lang.String scope)
protected boolean match(MMessageEvent msgevent, java.util.Map<java.lang.String,java.lang.Object> msg)
msgevent
- The message event.public void registerMessageEvent(RMessageEvent<java.lang.Object> msgevent)
registerMessageEvent
in interface IInternalBDIXMessageFeature
msgevent
- The message event.public void deregisterMessageEvent(RMessageEvent<java.lang.Object> msgevent)
deregisterMessageEvent
in interface IInternalBDIXMessageFeature
msgevent
- The message event.public RMessageEvent<java.lang.Object> getInReplyMessageEvent(java.lang.Object message)
message
- The (native) message.