public class MessageComponentFeature extends AbstractComponentFeature implements IMessageFeature, IInternalMessageFeature
Modifier and Type | Class and Description |
---|---|
class |
MessageComponentFeature.HandleMessageStep
Step to handle a message.
|
class |
MessageComponentFeature.HandleStreamStep
Step to handle a stream.
|
Modifier and Type | Field and Description |
---|---|
protected java.util.List<IMessageHandler> |
messagehandlers
The list of message handlers.
|
cinfo, component, guesser
Constructor and Description |
---|
MessageComponentFeature(IInternalAccess component,
ComponentCreationInfo cinfo)
Create the feature.
|
Modifier and Type | Method and Description |
---|---|
jadex.commons.future.IFuture<java.lang.Void> |
addMessageHandler(IMessageHandler handler)
Add a message handler.
|
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.
|
void |
messageArrived(IMessageAdapter message)
Inform the component that a message has arrived.
|
jadex.commons.future.IFuture<java.lang.Void> |
removeMessageHandler(IMessageHandler handler)
Remove a message handler.
|
jadex.commons.future.IFuture<java.lang.Void> |
sendMessage(java.util.Map<java.lang.String,java.lang.Object> me,
MessageType mt)
Send a message.
|
jadex.commons.future.IFuture<java.lang.Void> |
sendMessage(java.util.Map<java.lang.String,java.lang.Object> me,
MessageType mt,
byte[] codecids)
Send a message.
|
jadex.commons.future.IFuture<java.lang.Void> |
sendMessageAndWait(java.util.Map<java.lang.String,java.lang.Object> me,
MessageType mt,
IMessageHandler handler)
Send a message and wait for a reply.
|
void |
streamArrived(IConnection con)
Inform the component that a stream has arrived.
|
body, getComponent, getExternalFacade, getExternalFacadeType, getParameterGuesser, getValueFetcher, init, kill, shutdown
protected java.util.List<IMessageHandler> messagehandlers
public MessageComponentFeature(IInternalAccess component, ComponentCreationInfo cinfo)
public jadex.commons.future.IFuture<java.lang.Void> sendMessage(java.util.Map<java.lang.String,java.lang.Object> me, MessageType mt)
sendMessage
in interface IMessageFeature
me
- The message content (name value pairs).mt
- The message type describing the content.public jadex.commons.future.IFuture<java.lang.Void> sendMessage(java.util.Map<java.lang.String,java.lang.Object> me, MessageType mt, byte[] codecids)
sendMessage
in interface IMessageFeature
me
- The message content (name value pairs).mt
- The message type describing the content.public jadex.commons.future.IFuture<java.lang.Void> sendMessageAndWait(java.util.Map<java.lang.String,java.lang.Object> me, MessageType mt, IMessageHandler handler)
sendMessageAndWait
in interface IMessageFeature
me
- The message content (name value pairs).mt
- The message type describing the content.public jadex.commons.future.IFuture<java.lang.Void> addMessageHandler(IMessageHandler handler)
addMessageHandler
in interface IMessageFeature
The
- handler.public jadex.commons.future.IFuture<java.lang.Void> removeMessageHandler(IMessageHandler handler)
removeMessageHandler
in interface IMessageFeature
handler
- The handler.public void messageArrived(IMessageAdapter message)
messageArrived
in interface IInternalMessageFeature
message
- The message that arrived.protected IComponentStep<java.lang.Void> createHandleStreamStep(IConnection con)
public void streamArrived(IConnection con)
streamArrived
in interface IInternalMessageFeature
con
- The stream that arrived.protected IComponentStep<java.lang.Void> createHandleMessageStep(IMessageAdapter message)