diff --git a/2-metadata-processor.py b/2-metadata-processor.py
index 60473d1408e2c5867535bb0cb175a98b3829ab8a..3635f19058fd51b2220f6dce8ba49a2ba022b9b9 100644
--- a/2-metadata-processor.py
+++ b/2-metadata-processor.py
@@ -280,6 +280,7 @@ def process_page( channel, method, properties, body, **kwargs):
                     #featurePages = getWFS(link) #
                     full_version = metadata_record.copy() # including metadata AND data
                     full_version['uuid'] = metadata_record['metadata-fr']['geonet:info']['uuid'] + '.full'
+                    full_version['type'] = metadata_record['metadata-fr']['type']
 
                     msg = {'header': {'wfs_info': link, 'offset': 0, 'session_id': session_id, 'dest_index': dest_index}, 'body': full_version}
                     the_body = msgpack.packb(msg, use_bin_type=True)
@@ -294,6 +295,7 @@ def process_page( channel, method, properties, body, **kwargs):
 
             meta_version = metadata_record.copy() # including metadata ONLY
             meta_version['uuid'] = metadata_record['metadata-fr']['geonet:info']['uuid'] + '.meta'
+            meta_version['type'] = metadata_record['metadata-fr']['type']
 
             msg = {'header': { "index" : { "_index" : dest_index, "_type" : "_doc" } }, 'body': meta_version}
             the_body = msgpack.packb(msg, use_bin_type=True)