'Send a metering message for publishing
:param samples: Samples from pipeline after transformation'

def publish_samples(self, samples):

    queue = self.client.queue(self.queue_name)
    messages = [{'body': sample.as_dict(), 'ttl': self.ttl} for sample in samples]
    queue.post(messages)
