Changelog

0.1.0 (2018-07-05)

  • Forward Streaming API messages from one or more Salesforce orgs to one or more RabbitMQ brokers

  • Route incoming messages to a specific broker and exchange with the specified routing key and properties, with the help of routing rules defined as JSONPath expressions

  • Support for Salesforce’s replay extension for message reliability and durability by storing replay markers in a Redis database

  • Configurable error handling behavior, either fail instantly or try to recover from network and service outages

  • Message sources, sinks and routing configurable with JSON or YAML configuration files

  • Implemented using python asyncio for efficient handling of IO intensive operations