The SQL Subscriber agent can be configured to consume replicated Salesforce records and write them to a database table. The agent.xml file shown below is an example of the necessary configuration.

<?xml version="1.0" encoding="ISO-8859-1" standalone="no"?>
<config>
    <agent>
      <max_reads_per_connect>4000</max_reads_per_connect>
      <polling_interval>30</polling_interval>
 
        <subscribe>
            <task>
                <task_name>salesForce</task_name>
                <message_connection queue="psp.out.replicator.mysalesforce" password="encrypted:iTOCp4deP7rJNgFkf2AEMA==" user="admin">amqp://perspectiumdemo1-amqp.perspectium.net</message_connection>
                <handler>com.perspectium.replicator.sql.SQLSubscriber</handler>
                <decryption_key>The cow jumped over the moon</decryption_key>
                <database_type>mysql</database_type>
                <database_server>localhost</database_server>
                <database_port>3306</database_port>
                <database_user>root</database_user>
                <database_password></database_password>
                <database_params>characterEncoding=UTF-8</database_params>
                <database>solutions</database>
 
                <schema_connection user="your_sfuser@yourcompany.com" password="salesforce1NxOwgnOlIH11JIfXC9Ob57Dc"
                    client_id="3MVG9uudbyLbNPZO0CYuZCvodrGD7QFWe6aPZY54i2cn4BqjhcuaSCYM2hgWI297gwSCr.5XEfy3WlyB4zXcI"
                    client_secret="8290250609080749993">https://login.salesforce.com/services/oauth2/token</schema_connection>
 
                <primary_key>Id</primary_key>
                <skip_database_creation/>
            </task>
      </subscribe>
   </agent>
</config>