отправка сообщений на основе json с использованием syslog-ng и amqp

Как правильно форматировать сообщения json и отправлять их через amqp с помощью syslog-ng?

Формат json должен выглядеть примерно так.

{"log":"This is the error message...", "date":"xxx", "source":"xxx"}

У меня проблема в том, что сообщение не всегда является допустимой строкой json.

например

"log":"This is a "serious" error message."

Как мне избежать сообщения?

Моя конфигурация syslog-ng выглядит примерно так.

destination d_amqp {
    amqp(
        vhost("/")
        host("127.0.0.1")
        port(5672)
        username("guest") # required option, no default
        password("guest") # required option, no default
        exchange("syslog")
        exchange_type("header")
        routing_key("my-routing-key")
        body("\{\"log\":\"${MSG}\"\}")
        persistent(yes)
        value-pairs(
            scope("selected-macros" "nv-pairs" "sdata")
        )
    );
};

Это всего лишь пример, поскольку сейчас у меня нет фактической конфигурации.