jadex.platform.service.message.transport.localmtp

Class LocalTransport

java.lang.Object

jadex.platform.service.message.transport.localmtp.LocalTransport

All Implemented Interfaces:

ITransport

public class LocalTransport
extends java.lang.Object
implements ITransport

The local transport for sending messages on the same platform (just calls the local deliver method).

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String[]	addresses The addresses.
protected jadex.bridge.IInternalAccess	component The platform.
protected jadex.bridge.service.types.message.IMessageService	msgservice The message service.
static java.lang.String[]	SCHEMAS The schema name.

Constructor Summary

Constructors

Constructor and Description
LocalTransport(jadex.bridge.IInternalAccess component) Init the transport.

Method Summary

Modifier and Type	Method and Description
java.lang.String[]	getAddresses() Get the addresses of this transport.
java.lang.String[]	getServiceSchemas() Returns the prefix of this transport
boolean	isApplicable(java.lang.String address) Test if a transport is applicable for the target address.
boolean	isNonFunctionalSatisfied(java.util.Map<java.lang.String,java.lang.Object> nonfunc, java.lang.String address) Test if a transport satisfies the non-functional requirements.
void	sendMessage(java.lang.String address, ISendTask task) Send a message to the given address.
jadex.commons.future.IFuture<java.lang.Void>	shutdown() Perform cleanup operations (if any).
jadex.commons.future.IFuture<java.lang.Void>	start() Start the transport.

Methods inherited from class java.lang.Object

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

Field Detail

SCHEMAS

public static final java.lang.String[] SCHEMAS

The schema name.

msgservice

protected jadex.bridge.service.types.message.IMessageService msgservice

The message service.

addresses

protected java.lang.String[] addresses

The addresses.

component

protected jadex.bridge.IInternalAccess component

The platform.

Constructor Detail

LocalTransport

public LocalTransport(jadex.bridge.IInternalAccess component)

Init the transport.

Method Detail

start

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

Start the transport.

Specified by:

start in interface ITransport

shutdown

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

Perform cleanup operations (if any).

Specified by:

shutdown in interface ITransport

isApplicable

public boolean isApplicable(java.lang.String address)

Test if a transport is applicable for the target address.

Specified by:

isApplicable in interface ITransport

Returns:

True, if the transport is applicable for the address.

isNonFunctionalSatisfied

public boolean isNonFunctionalSatisfied(java.util.Map<java.lang.String,java.lang.Object> nonfunc,
                                        java.lang.String address)

Test if a transport satisfies the non-functional requirements.

Specified by:

isNonFunctionalSatisfied in interface ITransport

Parameters:

nonfunc - The non-functional requirements (name, value).

address - The transport address.

Returns:

True, if the transport satisfies the non-functional requirements.

sendMessage

public void sendMessage(java.lang.String address,
                        ISendTask task)

Send a message to the given address. This method is called multiple times for the same message, i.e. once for each applicable transport / address pair. The transport should asynchronously try to connect to the target address (or reuse an existing connection) and afterwards call-back the ready() method on the send task. The send manager calls the obtained send commands of the transports and makes sure that the message gets sent only once (i.e. call send commands sequentially and stop, when a send command finished successfully). All transports may keep any established connections open for later messages.

Specified by:

sendMessage in interface ITransport

Parameters:

address - The address to send to.

task - A task representing the message to send.

getServiceSchemas

public java.lang.String[] getServiceSchemas()

Returns the prefix of this transport

Specified by:

getServiceSchemas in interface ITransport

Returns:

Transport prefix.

getAddresses

public java.lang.String[] getAddresses()

Get the addresses of this transport.

Specified by:

getAddresses in interface ITransport

Returns:

An array of strings representing the addresses of this message transport mechanism.