MicroAgent (Jadex Active Component Platform 2.2 API.)

java.lang.Object
- jadex.micro.MicroAgent

All Implemented Interfaces:

IInternalAccess, IMicroAgent

Direct Known Subclasses:

KernelComponentAgent, KernelMicroAgent, KernelMultiAgent, PojoMicroAgent
```
public class MicroAgent
extends Object
implements IMicroAgent, IInternalAccess
```
Base class for application agents.

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class MicroAgent.ExecuteWaitForStep
Step to execute a wait for entry.

Nested Classes
Modifier and Type	Class and Description
`static class`	`MicroAgent.ExecuteWaitForStep` Step to execute a wait for entry.

Constructor Summary

Constructors
Constructor and Description

MicroAgent()

Constructors
Constructor and Description
`MicroAgent()`

Method Summary

Methods
Modifier and Type	Method and Description
`IFuture<Void>`	`addComponentListener(IComponentListener listener)` Add an component listener.
`void`	`addMessageHandler(IMessageHandler handler)` Add a message handler.
`IFuture<Void>`	`addService(String name, Class<?> type, Object service)` Add a service to the platform.
`IFuture<Void>`	`addService(String name, Class<?> type, Object service, String proxytype)` Add a service to the platform.
`IFuture<Void>`	`agentCreated()` Called once after agent creation.
`IFuture<Void>`	`agentKilled()` Called just before the agent is removed from the platform.
`Map<String,Object>`	`createReply(Map<String,Object> msg, MessageType mt)` Create a reply to this message event.
`<T> IIntermediateResultListener<T>`	`createResultListener(IIntermediateResultListener<T> listener)` Create a result listener that is executed as an agent step.
`<T> IResultListener<T>`	`createResultListener(IResultListener<T> listener)` Create a result listener that is executed as an agent step.
`IServiceContainer`	`createServiceContainer(Map<String,Object> args)` May be overriden to provide a custom service container implementations.
`IFuture<Void>`	`executeBody()` Execute the functional body of the agent.
`IComponentAdapter`	`getAgentAdapter()` Get the agent adapter.
`String`	`getAgentName()` Get the agent name.
`Object`	`getArgument(String name)` Get an argument.
`Map<String,Object>`	`getArguments()` Get the arguments.
`IFuture<Collection<IExternalAccess>>`	`getChildrenAccesses()` Get the children (if any).
`IFuture<IComponentIdentifier[]>`	`getChildrenIdentifiers()` Get the children (if any).
`ClassLoader`	`getClassLoader()` Get the class loader of the component.
`IComponentAdapter`	`getComponentAdapter()` Get the agent adapter.
`IComponentDescription`	`getComponentDescription()` Get the component description.
`IComponentIdentifier`	`getComponentIdentifier()` Get the agent identifier.
`String`	`getConfiguration()` Get the configuration.
`IExternalAccess`	`getExternalAccess()` Get the external access for this agent.
`IValueFetcher`	`getFetcher()` Get the fetcher.
`MicroAgentInterpreter`	`getInterpreter()` Get the interpreter.
`Logger`	`getLogger()` Get the logger.
`IModelInfo`	`getModel()` Get the model of the component.
`IExternalAccess`	`getParentAccess()` Get the parent component.
`Object`	`getProperty(String name)` Get a property.
`Object`	`getRawService(Class<?> type)` Get a raw reference to a provided service implementation.
`Object`	`getRawService(String name)` Get a raw reference to a provided service implementation.
`Object[]`	`getRawServices(Class<?> type)` Get a raw reference to a provided service implementation.
`<T> IFuture<T>`	`getRequiredService(String name)` Get a required service of a given name.
`<T> IIntermediateFuture<T>`	`getRequiredServices(String name)` Get a required services of a given name.
`Map<String,Object>`	`getResults()` Get the component results.
`IServiceContainer`	`getServiceContainer()` Get the service container.
`IServiceProvider`	`getServiceProvider()` Get the service provider.
`IFuture<Long>`	`getTime()` Get the current time.
`void`	`init(MicroAgentInterpreter interpreter)` Init the micro agent with the interpreter.
`boolean`	`isAtBreakpoint(String[] breakpoints)` Test if the agent's execution is currently at one of the given breakpoints.
`boolean`	`isComponentThread()` Test if current thread is the component thread.
`IFuture<Map<String,Object>>`	`killAgent()` Kill the agent.
`IFuture<Map<String,Object>>`	`killComponent()` Kill the component.
`void`	`messageArrived(Map<String,Object> msg, MessageType mt)` Called, whenever a message is received.
`IFuture<Void>`	`removeComponentListener(IComponentListener listener)` Remove a component listener.
`void`	`removeMessageHandler(IMessageHandler handler)` Remove a message handler.
`IFuture<Void>`	`removeService(IServiceIdentifier sid)` Removes a service from the platform (shutdowns also the service).
`<T> IFuture<T>`	`scheduleStep(IComponentStep<T> step)` Schedule a step of the agent.
`IFuture<Void>`	`sendMessage(Map<String,Object> me, MessageType mt)` Send a message.
`IFuture<Void>`	`sendMessage(Map<String,Object> me, MessageType mt, byte[] codecids)` Send a message.
`IFuture<Void>`	`sendMessageAndWait(Map<String,Object> me, MessageType mt, IMessageHandler handler)` Send a message and wait for a reply.
`void`	`setResultValue(String name, Object value)` Set a result value.
`void`	`streamArrived(IConnection con)` Called, whenever a stream is received.
`IFuture<MicroAgent.TimerWrapper>`	`waitFor(long time, IComponentStep<Void> step)` Wait for an specified amount of time.
`<T> IFuture<T>`	`waitForDelay(long delay, IComponentStep<T> step)` Wait for some time and execute a component step afterwards.
`IFuture<MicroAgent.TimerWrapper>`	`waitForTick(IComponentStep<Void> run)` Wait for the next tick.

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - MicroAgent
```
public MicroAgent()
```
- Method Detail
  - init
```
public void init(MicroAgentInterpreter interpreter)
```
    Init the micro agent with the interpreter.
    
    Parameters:
    interpreter - The interpreter.
  - agentCreated
```
public IFuture<Void> agentCreated()
```
    Called once after agent creation.
    
    Specified by:
    
    agentCreated in interface IMicroAgent
  - executeBody
```
public IFuture<Void> executeBody()
```
    Execute the functional body of the agent. Is only called once.
    
    Specified by:
    
    executeBody in interface IMicroAgent
  - messageArrived
```
public void messageArrived(Map<String,Object> msg,
                  MessageType mt)
```
    Called, whenever a message is received.
    
    Specified by:
    
    messageArrived in interface IMicroAgent
    
    Parameters:
    msg - The message.
    mt - The message type.
  - streamArrived
```
public void streamArrived(IConnection con)
```
    Called, whenever a stream is received.
    
    Parameters:
    con - The stream.
  - agentKilled
```
public IFuture<Void> agentKilled()
```
    Called just before the agent is removed from the platform.
    
    Specified by:
    
    agentKilled in interface IMicroAgent
    
    Returns:
    The result of the component.
  - getProperty
```
public Object getProperty(String name)
```
    Get a property.
    
    Parameters:
    name - The name of the property.
    
    Returns:
    The property value or null.
  - getServiceProvider
```
public IServiceProvider getServiceProvider()
```
    Get the service provider.
    
    Returns:
    The service provider.
  - getServiceContainer
```
public IServiceContainer getServiceContainer()
```
    Get the service container. Internal method for accessing the service container.
    
    Specified by:
    
    getServiceContainer in interface IInternalAccess
    
    Returns:
    The service container.
  - isAtBreakpoint
```
public boolean isAtBreakpoint(String[] breakpoints)
```
    Test if the agent's execution is currently at one of the given breakpoints. If yes, the agent will be suspended by the platform. Available breakpoints can be specified in the micro agent meta info.
    
    Parameters:
    breakpoints - An array of breakpoints.
    
    Returns:
    True, when some breakpoint is triggered.
  - getExternalAccess
```
public IExternalAccess getExternalAccess()
```
    Get the external access for this agent.
    
    Specified by:
    
    getExternalAccess in interface IInternalAccess
    
    Returns:
    The external access.
  - getParentAccess
```
public IExternalAccess getParentAccess()
```
    Get the parent component.
    
    Specified by:
    
    getParentAccess in interface IInternalAccess
    
    Returns:
    The parent (if any).
  - getAgentAdapter
```
public IComponentAdapter getAgentAdapter()
```
    Get the agent adapter.
    
    Returns:
    The agent adapter. // todo: deprecated, all kernels should have getComponentAdapter?
  - getComponentAdapter
```
public IComponentAdapter getComponentAdapter()
```
    Get the agent adapter.
    
    Returns:
    The agent adapter.
  - getComponentDescription
```
public IComponentDescription getComponentDescription()
```
    Get the component description.
    
    Specified by:
    
    getComponentDescription in interface IInternalAccess
    
    Returns:
    The component description.
  - getArguments
```
public Map<String,Object> getArguments()
```
    Get the arguments.
    
    Specified by:
    
    getArguments in interface IInternalAccess
    
    Returns:
    The arguments.
  - getResults
```
public Map<String,Object> getResults()
```
    Get the component results.
    
    Specified by:
    
    getResults in interface IInternalAccess
    
    Returns:
    The results.
  - setResultValue
```
public void setResultValue(String name,
                  Object value)
```
    Set a result value.
    
    Specified by:
    
    setResultValue in interface IInternalAccess
    
    Parameters:
    name - The result name.
    value - The result value.
  - getArgument
```
public Object getArgument(String name)
```
    Get an argument.
    
    Parameters:
    name - The argument name.
    
    Returns:
    The value.
  - getConfiguration
```
public String getConfiguration()
```
    Get the configuration.
    
    Specified by:
    
    getConfiguration in interface IInternalAccess
    
    Returns:
    the Configuration.
  - getRawService
```
public Object getRawService(String name)
```
    Get a raw reference to a provided service implementation.
  - getRawService
```
public Object getRawService(Class<?> type)
```
    Get a raw reference to a provided service implementation.
  - getRawServices
```
public Object[] getRawServices(Class<?> type)
```
    Get a raw reference to a provided service implementation.
  - createResultListener
```
public <T> IResultListener<T> createResultListener(IResultListener<T> listener)
```
    Create a result listener that is executed as an agent step.
    
    Specified by:
    
    createResultListener in interface IInternalAccess
    
    Parameters:
    listener - The listener to be executed as an agent step.
  - createResultListener
```
public <T> IIntermediateResultListener<T> createResultListener(IIntermediateResultListener<T> listener)
```
    Create a result listener that is executed as an agent step.
    
    Specified by:
    
    createResultListener in interface IInternalAccess
    
    Parameters:
    listener - The listener to be executed as an agent step.
  - getTime
```
public IFuture<Long> getTime()
```
    Get the current time.
    
    Returns:
    The current time.
  - waitFor
```
public IFuture<MicroAgent.TimerWrapper> waitFor(long time,
                                       IComponentStep<Void> step)
```
    Wait for an specified amount of time.
    
    Parameters:
    time - The time.
    step - The runnable.
  - waitForTick
```
public IFuture<MicroAgent.TimerWrapper> waitForTick(IComponentStep<Void> run)
```
    Wait for the next tick.
    
    Parameters:
    time - The time.
  - getLogger
```
public Logger getLogger()
```
    Get the logger.
    
    Specified by:
    
    getLogger in interface IInternalAccess
    
    Returns:
    The logger.
  - killAgent
```
public IFuture<Map<String,Object>> killAgent()
```
    Kill the agent.
  - sendMessage
```
public IFuture<Void> sendMessage(Map<String,Object> me,
                        MessageType mt)
```
    Send a message.
    
    Parameters:
    me - The message content (name value pairs).
    mt - The message type describing the content.
  - sendMessage
```
public IFuture<Void> sendMessage(Map<String,Object> me,
                        MessageType mt,
                        byte[] codecids)
```
    Send a message.
    
    Parameters:
    me - The message content (name value pairs).
    mt - The message type describing the content.
  - sendMessageAndWait
```
public IFuture<Void> sendMessageAndWait(Map<String,Object> me,
                               MessageType mt,
                               IMessageHandler handler)
```
    Send a message and wait for a reply.
    
    Parameters:
    me - The message content (name value pairs).
    mt - The message type describing the content.
  - addMessageHandler
```
public void addMessageHandler(IMessageHandler handler)
```
    Add a message handler.
    
    Parameters:
    The - handler.
  - removeMessageHandler
```
public void removeMessageHandler(IMessageHandler handler)
```
    Remove a message handler.
    
    Parameters:
    handler - The handler.
  - createReply
```
public Map<String,Object> createReply(Map<String,Object> msg,
                             MessageType mt)
```
    Create a reply to this message event.
    
    Parameters:
    msgeventtype - The message event type.
    
    Returns:
    The reply event.
  - getAgentName
```
public String getAgentName()
```
    Get the agent name.
    
    Returns:
    The agent name.
  - getComponentIdentifier
```
public IComponentIdentifier getComponentIdentifier()
```
    Get the agent identifier.
    
    Specified by:
    
    getComponentIdentifier in interface IInternalAccess
    
    Returns:
    The agent identifier.
  - scheduleStep
```
public <T> IFuture<T> scheduleStep(IComponentStep<T> step)
```
    Schedule a step of the agent. May safely be called from external threads.
    
    Parameters:
    step - Code to be executed as a step of the agent.
  - addService
```
public IFuture<Void> addService(String name,
                       Class<?> type,
                       Object service,
                       String proxytype)
```
    Add a service to the platform. If under the same name and type a service was contained, the old one is removed and shutdowned.
    
    Parameters:
    type - The public service interface.
    service - The service.
    type - The proxy type (@see{BasicServiceInvocationHandler}).
  - addService
```
public IFuture<Void> addService(String name,
                       Class<?> type,
                       Object service)
```
    Add a service to the platform. If under the same name and type a service was contained, the old one is removed and shutdowned.
    
    Parameters:
    type - The public service interface.
    service - The service.
  - removeService
```
public IFuture<Void> removeService(IServiceIdentifier sid)
```
    Removes a service from the platform (shutdowns also the service).
    
    Parameters:
    service - The service.
  - waitForDelay
```
public <T> IFuture<T> waitForDelay(long delay,
                          IComponentStep<T> step)
```
    Wait for some time and execute a component step afterwards.
    
    Specified by:
    
    waitForDelay in interface IInternalAccess
  - getModel
```
public IModelInfo getModel()
```
    Get the model of the component.
    
    Specified by:
    
    getModel in interface IInternalAccess
    
    Returns:
    The model.
  - getChildrenAccesses
```
public IFuture<Collection<IExternalAccess>> getChildrenAccesses()
```
    Get the children (if any).
    
    Specified by:
    
    getChildrenAccesses in interface IInternalAccess
    
    Returns:
    The children.
  - getChildrenIdentifiers
```
public IFuture<IComponentIdentifier[]> getChildrenIdentifiers()
```
    Get the children (if any).
    
    Specified by:
    
    getChildrenIdentifiers in interface IInternalAccess
    
    Returns:
    The children.
  - killComponent
```
public IFuture<Map<String,Object>> killComponent()
```
    Kill the component.
    
    Specified by:
    
    killComponent in interface IInternalAccess
  - addComponentListener
```
public IFuture<Void> addComponentListener(IComponentListener listener)
```
    Add an component listener.
    
    Specified by:
    
    addComponentListener in interface IInternalAccess
    
    Parameters:
    listener - The listener.
  - removeComponentListener
```
public IFuture<Void> removeComponentListener(IComponentListener listener)
```
    Remove a component listener.
    
    Specified by:
    
    removeComponentListener in interface IInternalAccess
    
    Parameters:
    listener - The listener.
  - getRequiredService
```
public <T> IFuture<T> getRequiredService(String name)
```
    Get a required service of a given name.
    
    Parameters:
    name - The service name.
    
    Returns:
    The service.
  - getRequiredServices
```
public <T> IIntermediateFuture<T> getRequiredServices(String name)
```
    Get a required services of a given name.
    
    Parameters:
    name - The services name.
    
    Returns:
    The service.
  - createServiceContainer
```
public IServiceContainer createServiceContainer(Map<String,Object> args)
```
    May be overriden to provide a custom service container implementations.
  - getFetcher
```
public IValueFetcher getFetcher()
```
    Get the fetcher.
    
    Specified by:
    
    getFetcher in interface IInternalAccess
    
    Returns:
    The fetcher.
  - getClassLoader
```
public ClassLoader getClassLoader()
```
    Get the class loader of the component.
    
    Specified by:
    
    getClassLoader in interface IInternalAccess
  - getInterpreter
```
public MicroAgentInterpreter getInterpreter()
```
    Get the interpreter.
    
    Returns:
    The interpreter.
  - isComponentThread
```
public boolean isComponentThread()
```
    Test if current thread is the component thread.
    
    Specified by:
    
    isComponentThread in interface IInternalAccess
    
    Returns:
    True if the current thread is the component thread.

Class MicroAgent

Nested Class Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

MicroAgent

Method Detail

init

agentCreated

executeBody

messageArrived

streamArrived

agentKilled

getProperty

getServiceProvider

getServiceContainer

isAtBreakpoint

getExternalAccess

getParentAccess

getAgentAdapter

getComponentAdapter

getComponentDescription

getArguments

getResults

setResultValue

getArgument

getConfiguration

getRawService

getRawService

getRawServices

createResultListener

createResultListener

getTime

waitFor

waitForTick

getLogger

killAgent

sendMessage

sendMessage

sendMessageAndWait

addMessageHandler

removeMessageHandler

createReply

getAgentName

getComponentIdentifier

scheduleStep

addService

addService

removeService

waitForDelay

getModel

getChildrenAccesses

getChildrenIdentifiers

killComponent

addComponentListener

removeComponentListener

getRequiredService

getRequiredServices

createServiceContainer

getFetcher

getClassLoader

getInterpreter

isComponentThread