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

def publish_samples(self, samples):

    for sample in samples:
        msg = utils.meter_message_from_counter(sample, self.conf.publisher.telemetry_secret)
        host = self.host
        port = self.port
        LOG.debug('Publishing    sample    %(msg)s    over    UDP    to    %(host)s:%(port)d', {'msg': msg, 'host': host, 'port': port})
        try:
            self.socket.sendto(msgpack.dumps(msg), (self.host, self.port))
        except Exception as e:
            LOG.warning(_('Unable    to    send    sample    over    UDP'))
            LOG.exception(e)
