Commit 3ac4e098 authored by Jonas Waeber's avatar Jonas Waeber
Browse files

change topic name

parent 2e6ed06b
......@@ -146,7 +146,7 @@ class MonitorDrupalJsonApiInstitution(Resource):
value_serializer=lambda m: json.dumps(m, ensure_ascii=False)
.encode('utf-8'))
key = bytes(topic_value.get('field_memobase_id'), encoding='utf-8')
producer.send('drupal-json-api-input', topic_value, key)
producer.send('mb-gi-drupal-export-prod', topic_value, key)
except Exception as ex:
msg = 'Exception for ' + institutionId + ': ' + str(ex) + '\n' + \
traceback.format_exc()
......
......@@ -211,7 +211,7 @@ class MonitorDrupalJsonApiRecordSet(Resource):
value_serializer=lambda m: json.dumps(m, ensure_ascii=False)
.encode('utf-8'))
key = bytes(topicValue.get('field_memobase_id'), encoding='utf-8')
producer.send('drupal-json-api-input', topicValue, key=key)
producer.send('mb-gi-drupal-export-prod', topicValue, key=key)
except Exception as ex:
msg = 'Exception for ' + recordSetId + ': ' + str(ex) + '\n' +\
traceback.format_exc()
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment