Skip to main content

subscribe-queue-backlog

Import the AMPS library:

import AMPS

Construct the command:

cmd = AMPS.Command(AMPS.Message.Command.Subscribe)
cmd.set_topic(topic)

# request a backlog of no more than 100 -- queue may allow a lower number

cmd.set_options(AMPS.Message.Options.MaxBacklog(1000))

The command can now be used in execute or execute_async.