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

def publish_events(self, events):

    queue = self.client.queue(self.queue_name)
    messages = [{'body': event.serialize(), 'ttl': self.ttl} for event in events]
    queue.post(messages)
