112
112
info("Queueing a message with updated data watcher info "
113
113
"for %s.", format_object(self))
114
114
result = self.registry.broker.send_message(message, urgent=urgent)
115
116
def persist_data(message_id):
117
119
result.addCallback(persist_data)
118
120
result.addErrback(log_failure)