Skip to content

aea.registries.filter

This module contains registries.

Filter Objects

class Filter(WithLogger)

This class implements the filter of an AEA.

__init__

def __init__(resources: Resources,
             decision_maker_out_queue: AsyncFriendlyQueue) -> None

Instantiate the filter.

Arguments:

  • resources: the resources
  • decision_maker_out_queue: the decision maker queue

resources

@property
def resources() -> Resources

Get resources.

decision_maker_out_queue

@property
def decision_maker_out_queue() -> AsyncFriendlyQueue

Get decision maker (out) queue.

get_active_handlers

def get_active_handlers(protocol_id: PublicId,
                        skill_id: Optional[PublicId] = None) -> List[Handler]

Get active handlers based on protocol id and optional skill id.

Arguments:

  • protocol_id: the protocol id
  • skill_id: the skill id

Returns:

the list of handlers currently active

get_active_behaviours

def get_active_behaviours() -> List[Behaviour]

Get the active behaviours.

Returns:

the list of behaviours currently active

handle_new_handlers_and_behaviours

def handle_new_handlers_and_behaviours() -> None

Handle the messages from the decision maker.

get_internal_message

async def get_internal_message() -> Optional[Message]

Get a message from decision_maker_out_queue.

handle_internal_message

def handle_internal_message(internal_message: Optional[Message]) -> None

Handle internal message.