Merge pull request #537 from CSCfi/CSCFAIRMETA-470-Error-updating-dat…

…aset

 CSCFAIRMETA-470-Error-updating-dataset: fix to datetime serialization.

src/metax_api/services/rabbitmq_service.py

@@ -12,6 +12,7 @@
 
 import pika
 from django.conf import settings as django_settings
+from django.core.serializers.json import DjangoJSONEncoder
 
 from metax_api.utils.utils import executing_test_case, executing_travis
 
@@ -84,7 +85,9 @@ def publish(self, body, routing_key='', exchange=None, persistent=True):
         try:
             for message in messages:
                 if isinstance(message, dict):
-                    message = json_dumps(message)
+                    message = json_dumps(
+                        message,
+                        cls=DjangoJSONEncoder)
                 self._channel.basic_publish(body=message, routing_key=routing_key, exchange=exchange, **additional_args)
         except Exception as e:
             _logger.error(e)