Remove and add a directive Delete the <instance_connection> tag. Then, within the <task> tag, add a self-closing <use_cache/> tag. Your agent.xml file will look like the following example: <?xml version="1.0" encoding="ISO-8859-1" standalone="no"?>
<config>
<agent>
<subscribe>
<task>
<task_name>example_subscribe</task_name>
<message_connection password="encrypted:XXXXX" queue="psp.out.replicator.example" use_basic_consume="true" user="exampleUser">amqps://example.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>exampleHost</database_server>
<database_port>3306</database_port>
<database_user>exampleUser</database_user>
<database_password>encrypted:XXXXX</database_password>
<database_params>characterEncoding=UTF-8</database_params>
<database>psp_repl</database>
<use_cache/>
</task>
</subscribe>
<max_reads_per_connect>4000</max_reads_per_connect>
<polling_interval>5</polling_interval>
<skip_message_set_processing/>
</agent>
</config> |
|