<?xml?>
<pal script = "amq_pal_gen">
This script echoes back arbitrary messages sent to the "echo server"
routing key. See echo_client.pal for usage.
<!-- Quit after having received this number of messages,
0=disable -->
<set name = "count" value = "10000" cmdline = "C" />
<!-- Log number of messages sent/received every N messages,
0=disable -->
<set name = "log_interval" value = "0" cmdline = "L" />
<set name = "received" value = "0" />
<set name = "total_received" value = "0" />
<if name = "count" test = "ne" value = "0" >
<echo>I: Waiting for $count messages ...</echo>
</if>
<session exchange = "amq.direct">
<queue_declare auto_delete = "1" />
<queue_bind queue = "$queue" routing_key = "echo server" />
<basic_consume queue = "$queue" auto_ack = "1" />
<repeat>
<wait />
<basic_arrived>
<if name = "total_received" value = "0" >
<timer />
</if>
<inc name = "total_received" />
<if name = "log_interval" test = "ne" value = "0" >
<inc name = "received" />
<if name = "received" value = "log_interval" >
<echo>I: Received $total_received messages</echo>
<set name = "received" value = "0" />
</if>
</if>
<basic_publish routing_key = "$reply_to" />
<if name = "total_received" value = "count" >
<echo>I: Received all messages</echo>
<exit />
</if>
</basic_arrived>
</repeat>
</session>
</pal>
