This module contains registries.

class Filter(WithLogger)

This class implements the filter of an AEA.

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

@property
def resources() -> Resources

Get resources.

@property
def decision_maker_out_queue() -> AsyncFriendlyQueue

Get decision maker (out) queue.

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

def get_active_behaviours() -> List[Behaviour]

Get the active behaviours.

Returns:

the list of behaviours currently active

def handle_new_handlers_and_behaviours() -> None

Handle the messages from the decision maker.

async def get_internal_message() -> Optional[Message]

Get a message from decision_maker_out_queue.

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

Handle internal message.