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