jadex.bridge.service.component.multiinvoke

Class SimpleMultiplexDistributor

java.lang.Object

jadex.bridge.service.component.multiinvoke.SimpleMultiplexDistributor

All Implemented Interfaces:

IMultiplexDistributor

Direct Known Subclasses:

SequentialMultiplexDistributor

public class SimpleMultiplexDistributor
extends Object
implements IMultiplexDistributor

Simple multiplex call distributor. It determines: - which services are called: all services found one time - with which arguments: all with the same single argument set - when finished: after each service has been called once

Constructor Summary

Constructors

Constructor and Description
SimpleMultiplexDistributor()

Method Summary

Methods

Modifier and Type	Method and Description
void	addService(IService service) Add a new service.
void	checkPerformCall(IService service) Check perform call.
Object[]	getArguments() Get the arguments for a call.
IIntermediateFuture<Object>	init(Method method, Object[] args, IFilter<Tuple2<IService,Object[]>> filter, IParameterConverter conv) Start the distributor.
Object	performCall(IService service, Object[] args) Perform a call on given service with given arguments.
void	serviceSearchFinished() Notify that the search has finished.

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleMultiplexDistributor

public SimpleMultiplexDistributor()

Method Detail

init

public IIntermediateFuture<Object> init(Method method,
                               Object[] args,
                               IFilter<Tuple2<IService,Object[]>> filter,
                               IParameterConverter conv)

Start the distributor.

Specified by:

init in interface IMultiplexDistributor

addService

public void addService(IService service)

Add a new service.

Specified by:

addService in interface IMultiplexDistributor

Parameters:

service - The service.

serviceSearchFinished

public void serviceSearchFinished()

Notify that the search has finished.

Specified by:

serviceSearchFinished in interface IMultiplexDistributor

getArguments

public Object[] getArguments()

Get the arguments for a call.

Returns:

The arguments.

checkPerformCall

public void checkPerformCall(IService service)

Check perform call.

performCall

public Object performCall(IService service,
                 Object[] args)
                   throws Exception

Perform a call on given service with given arguments.

Throws:

Exception