Describe what you would like us to do:

I am sending messages to fedora messaging but I am not seeing those in datagrepper:

topic: org.centos.prod.gitlab.redhat.centos-stream.rpms.time.push
username: gitlab-centos
exchange: amq.topic
virtual host: /pubsub
queue: gitlab-centos

I am using the fedora_messaging library to parse the message, sample code (to make sure it is using the expected schema):

from fedora_messaging import message
def fedora_messaging(data, topic, headers, **kwargs):
  """Return a parsed message for fedora messaging."""
  msg = message.Message(
    topic=topic,
    headers=headers,
    body=data)
  msg.queue = kwargs.get('queue')
  return json.loads(message.dumps(msg).rstrip())

Am I missing something so that datagrepper is not recognizing it as a valid message body?

Thanks