jadex.bdiv3x.features

Class BDIXMessageComponentFeature

java.lang.Object

MessageComponentFeature

jadex.bdiv3x.features.BDIXMessageComponentFeature

public class BDIXMessageComponentFeature
extends MessageComponentFeature

Extension to allow message injection in agent methods. // todo: call registerMessageEvent in sendMessage() methods

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	BDIXMessageComponentFeature.HandleBDIMessageStep Step to handle a message.
class	BDIXMessageComponentFeature.HandleBDIStreamStep Step to handle a message.

Field Summary

Fields

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>	sent_mevents Send message tracking (reply_with->Entry).

Constructor Summary

Constructors

Constructor and Description
BDIXMessageComponentFeature(IInternalAccess component, ComponentCreationInfo cinfo) Create the feature.

Method Summary

Modifier and Type	Method and Description
protected IComponentStep<java.lang.Void>	createHandleMessageStep(IMessageAdapter message) Helper method to override message handling.
protected IComponentStep<java.lang.Void>	createHandleStreamStep(IConnection con) Helper method to override stream handling.
RMessageEvent	getInReplyMessageEvent(IMessageAdapter message) Find a message event that the given native message is a reply to.
static boolean	isReply(RMessageEvent msg, RMessageEvent reply) Test is a message is a reply of another message.
boolean	match(MMessageEvent msgevent, java.util.Map<java.lang.String,java.lang.Object> msg, MessageType mt) 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, MessageType mt) Match message events with a message adapter.
protected void	registerMessageEvent(RMessageEvent msgevent) Register a conversation or reply-with to be able to send back answers to the source capability.

Methods inherited from class java.lang.Object

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

Field Detail

FACTORY

public static final IComponentFeatureFactory FACTORY

The factory.

sent_mevents

protected java.util.List<RMessageEvent> sent_mevents

Send message tracking (reply_with->Entry).

mevents_max

protected long mevents_max

The maximum number of outstanding messages.

Constructor Detail

BDIXMessageComponentFeature

public BDIXMessageComponentFeature(IInternalAccess component,
                                   ComponentCreationInfo cinfo)

Create the feature.

Method Detail

createHandleMessageStep

protected IComponentStep<java.lang.Void> createHandleMessageStep(IMessageAdapter message)

Helper method to override message handling. May be called from external threads.

createHandleStreamStep

protected IComponentStep<java.lang.Void> createHandleStreamStep(IConnection con)

Helper method to override stream handling. May be called from external threads.

matchMessageEvents

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,
                                 MessageType mt)

Match message events with a message adapter.

match

public boolean match(MMessageEvent msgevent,
                     java.util.Map<java.lang.String,java.lang.Object> msg,
                     MessageType mt)

Match a message with a message event.

Parameters:

msgevent - The message event.

Returns:

True, if message matches the message event.

registerMessageEvent

protected void registerMessageEvent(RMessageEvent msgevent)

Register a conversation or reply-with to be able to send back answers to the source capability.

Parameters:

msgevent - The message event. //@param replywith The reply-with tag. todo: indexing for msgevents for speed.

getInReplyMessageEvent

public RMessageEvent getInReplyMessageEvent(IMessageAdapter message)

Find a message event that the given native message is a reply to.

Parameters:

message - The (native) message.

isReply

public static boolean isReply(RMessageEvent msg,
                              RMessageEvent reply)

Test is a message is a reply of another message.

Parameters:

message - The (native) message.