def METHOD_NAME(self, resources, event=None):
    session = utils.local_session(self.manager.session_factory)
    subscription_id = session.get_subscription_id()
    message = {
        'event': event,
        'execution_id': self.manager.ctx.execution_id,
        'execution_start': self.manager.ctx.start_time,
        'version': version,
        'account_id': subscription_id,
        'account': subscription_id,
        'region': 'all',
        'policy': self.manager.data}
    message['action'] = self.expand_variables(message)
    for batch in utils.chunks(resources, self.batch_size):
        message['resources'] = batch
        receipt = self.send_data_message(message, session)
        self.log.info("sent message:%s policy:%s template:%s count:%s" % (
            receipt, self.manager.data['name'],
            self.data.get('template', 'default'), len(batch)))