|
async def schedule_message( self, to, body='', metadata={} ): |
|
# TODO: See if this can be done in a more elegant way ... |
|
msg = Message( to=to, body=body, metadata=deepcopy( metadata ) ) |
|
self.say( 'Sending message:', msg.metadata, msg.to ) |
|
await self.behaviour_output.send( deepcopy( msg ) ) |
|
try: |
|
self.input_ack.add( msg.metadata[ 'reply-with' ] ) |
|
except KeyError: |
|
pass |