'Send an event message for publishing
:param events: events from pipeline after transformation'

def publish_events(self, events):

    ev_list = [utils.message_from_event(event, self.conf.publisher.telemetry_secret) for event in events]
    topic = self.conf.publisher_notifier.event_topic
    self.local_queue.append((topic, ev_list))
    self.flush()
