summaryrefslogtreecommitdiff
path: root/data.c
diff options
context:
space:
mode:
Diffstat (limited to 'data.c')
-rw-r--r--data.c14
1 files changed, 13 insertions, 1 deletions
diff --git a/data.c b/data.c
index 2fbb49e..3f0ccf7 100644
--- a/data.c
+++ b/data.c
@@ -1064,7 +1064,7 @@ void enqueue_input(snac *snac, char *msg, char *req, int retries)
1064 1064
1065 1065
1066void enqueue_output(snac *snac, char *msg, char *inbox, int retries) 1066void enqueue_output(snac *snac, char *msg, char *inbox, int retries)
1067/* enqueues an output message for an actor */ 1067/* enqueues an output message to an inbox */
1068{ 1068{
1069 if (xs_startswith(inbox, snac->actor)) { 1069 if (xs_startswith(inbox, snac->actor)) {
1070 snac_debug(snac, 1, xs_str_new("refusing enqueue to myself")); 1070 snac_debug(snac, 1, xs_str_new("refusing enqueue to myself"));
@@ -1088,6 +1088,18 @@ void enqueue_output(snac *snac, char *msg, char *inbox, int retries)
1088} 1088}
1089 1089
1090 1090
1091void enqueue_output_by_actor(snac *snac, char *msg, char *actor, int retries)
1092/* enqueues an output message for an actor */
1093{
1094 xs *inbox = get_actor_inbox(snac, actor);
1095
1096 if (!xs_is_null(inbox))
1097 enqueue_output(snac, msg, inbox, retries);
1098 else
1099 snac_log(snac, xs_fmt("enqueue_output_by_actor cannot get inbox %s", actor));
1100}
1101
1102
1091void enqueue_email(snac *snac, char *msg, int retries) 1103void enqueue_email(snac *snac, char *msg, int retries)
1092/* enqueues an email message to be sent */ 1104/* enqueues an email message to be sent */
1093{ 1105{