kiwipy.local module

class kiwipy.local.LocalCommunicator

Bases: CommunicatorHelper

broadcast_send(body, sender=None, subject=None, correlation_id=None)

Broadcast a message to all subscribers

rpc_send(recipient_id, msg)

Initiate a remote procedure call on a recipient. This method returns a future representing the outcome of the call.

Parameters

• recipient_id – The recipient identifier

• msg – The body of the message

Returns

A future corresponding to the outcome of the call

Return type

kiwipy.Future

task_send(task, no_reply=False)

Send a task messages, this will be queued and picked up by a worker at some point in the future. The method returns a future representing the outcome of the task.

Parameters

• task – The task message

• no_reply (bool) – Do not send a reply containing the result of the task

Returns

A future corresponding to the outcome of the task