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