jadex.bridge.service.types.message

Interface IMessageService

All Superinterfaces:

IService

public interface IMessageService
extends IService

The interface for the message service. It is responsible for managing the transports and sending/delivering messages.

Field Summary

Fields inherited from interface jadex.bridge.service.IService

EMPTY_SERVICES

Method Summary

Modifier and Type	Method and Description
jadex.commons.future.IFuture<java.lang.Void>	addContentCodec(IContentCodec codec) Add content codec type.
jadex.commons.future.IFuture<java.lang.Void>	addMessageCodec(java.lang.Class codec) Add message codec type.
jadex.commons.future.IFuture<java.lang.Void>	addMessageListener(IMessageListener listener, jadex.commons.IFilter filter) Add a message listener.
jadex.commons.future.IFuture<IInputConnection>	createInputConnection(IComponentIdentifier sender, IComponentIdentifier receiver, java.util.Map<java.lang.String,java.lang.Object> nonfunc) Create a virtual input connection.
jadex.commons.future.IFuture<IOutputConnection>	createOutputConnection(IComponentIdentifier sender, IComponentIdentifier receiver, java.util.Map<java.lang.String,java.lang.Object> nonfunc) Create a virtual output connection.
void	deliverMessage(java.lang.Object msg) Deliver a raw message to some components.
jadex.commons.future.IFuture<java.lang.String[]>	getAddresses() Get addresses of all transports.
java.lang.String[]	getAddressSchemes() Get addresses of all transports.
jadex.commons.future.IFuture<java.util.Map<java.lang.Byte,ICodec>>	getAllCodecs() Get the codecs with message codecs.
jadex.commons.future.IFuture<ICodec[]>	getDefaultCodecs() Get the default codecs.
MessageType	getMessageType(java.lang.String type) Get the message type.
jadex.commons.future.IFuture<java.lang.Void>	refreshAddresses() Announce that addresses of transports might have changed.
jadex.commons.future.IFuture<java.lang.Void>	removeContentCodec(IContentCodec codec) Remove content codec type.
jadex.commons.future.IFuture<java.lang.Void>	removeMessageCodec(java.lang.Class codec) Remove message codec type.
jadex.commons.future.IFuture<java.lang.Void>	removeMessageListener(IMessageListener listener) Remove a message listener.
jadex.commons.future.IFuture<java.lang.Void>	sendMessage(java.util.Map<java.lang.String,java.lang.Object> message, MessageType msgtype, IComponentIdentifier sender, IResourceIdentifier rid, IComponentIdentifier realrec, byte[] codecids) Send a message.

Methods inherited from interface jadex.bridge.service.IService

getPropertyMap, getServiceIdentifier, isValid

Method Detail

sendMessage

jadex.commons.future.IFuture<java.lang.Void> sendMessage(java.util.Map<java.lang.String,java.lang.Object> message,
                                                         MessageType msgtype,
                                                         IComponentIdentifier sender,
                                                         IResourceIdentifier rid,
                                                         IComponentIdentifier realrec,
                                                         byte[] codecids)

Send a message.

Parameters:

message - The message as key value pairs.

msgtype - The message type.

sender - The sender component identifier.

rid - The resource identifier used by the sending component (i.e. corresponding to classes of objects in the message map).

realrec - The real receiver if different from the message receiver (e.g. message to rms encapsulating service call to other component).

codecids - The codecs to use for encoding (if different from default).

nonfunc - The non functional properties that need to be preserved.

Returns:

Future that indicates an exception when messages could not be delivered to components.

deliverMessage

void deliverMessage(java.lang.Object msg)

Deliver a raw message to some components.

Parameters:

msg - Byte array containing a message in the form {prolog}{data}.

createOutputConnection

jadex.commons.future.IFuture<IOutputConnection> createOutputConnection(IComponentIdentifier sender,
                                                                       IComponentIdentifier receiver,
                                                                       java.util.Map<java.lang.String,java.lang.Object> nonfunc)

Create a virtual output connection.

createInputConnection

jadex.commons.future.IFuture<IInputConnection> createInputConnection(IComponentIdentifier sender,
                                                                     IComponentIdentifier receiver,
                                                                     java.util.Map<java.lang.String,java.lang.Object> nonfunc)

Create a virtual input connection.

addMessageListener

jadex.commons.future.IFuture<java.lang.Void> addMessageListener(IMessageListener listener,
                                                                jadex.commons.IFilter filter)

Add a message listener.

Parameters:

listener - The change listener.

filter - An optional filter to only receive notifications for matching messages.

removeMessageListener

jadex.commons.future.IFuture<java.lang.Void> removeMessageListener(IMessageListener listener)

Remove a message listener.

Parameters:

listener - The change listener.

addContentCodec

jadex.commons.future.IFuture<java.lang.Void> addContentCodec(IContentCodec codec)

Add content codec type.

Parameters:

codec - The codec type.

removeContentCodec

jadex.commons.future.IFuture<java.lang.Void> removeContentCodec(IContentCodec codec)

Remove content codec type.

Parameters:

codec - The codec type.

addMessageCodec

jadex.commons.future.IFuture<java.lang.Void> addMessageCodec(java.lang.Class codec)

Add message codec type.

Parameters:

codec - The codec type.

removeMessageCodec

jadex.commons.future.IFuture<java.lang.Void> removeMessageCodec(java.lang.Class codec)

Remove message codec type.

Parameters:

codec - The codec type.

refreshAddresses

jadex.commons.future.IFuture<java.lang.Void> refreshAddresses()

Announce that addresses of transports might have changed.

getAddresses

jadex.commons.future.IFuture<java.lang.String[]> getAddresses()

Get addresses of all transports.

Returns:

The addresses of all transports.

getAddressSchemes

java.lang.String[] getAddressSchemes()

Get addresses of all transports.

Returns:

The address schemes of all transports.

getMessageType

MessageType getMessageType(java.lang.String type)

Get the message type.

Parameters:

type - The type name.

Returns:

The message type.

getAllCodecs

jadex.commons.future.IFuture<java.util.Map<java.lang.Byte,ICodec>> getAllCodecs()

Get the codecs with message codecs.

Returns:

The codec factory.

getDefaultCodecs

jadex.commons.future.IFuture<ICodec[]> getDefaultCodecs()

Get the default codecs.

Returns:

The default codecs.