diff --git a/ceilometer/publisher/udp.py b/ceilometer/publisher/udp.py index fcee95657c..000183cf35 100644 --- a/ceilometer/publisher/udp.py +++ b/ceilometer/publisher/udp.py @@ -69,7 +69,7 @@ class UDPPublisher(publisher.ConfigPublisherBase): "%(host)s:%(port)d", {'msg': msg, 'host': host, 'port': port}) try: - self.socket.sendto(msgpack.dumps(msg), + self.socket.sendto(msgpack.dumps(msg, use_bin_type=True), (self.host, self.port)) except Exception as e: LOG.warning(_("Unable to send sample over UDP")) diff --git a/ceilometer/tests/unit/publisher/test_udp.py b/ceilometer/tests/unit/publisher/test_udp.py index f15ebcda7f..90f6f788fd 100644 --- a/ceilometer/tests/unit/publisher/test_udp.py +++ b/ceilometer/tests/unit/publisher/test_udp.py @@ -125,7 +125,7 @@ class TestUDPPublisher(base.BaseTestCase): sent_counters = [] for data, dest in self.data_sent: - counter = msgpack.loads(data, encoding="utf-8") + counter = msgpack.loads(data, raw=False) sent_counters.append(counter) # Check destination