Skip to main content

subscribe-bookmark-pause

Import the AMPS library:

import AMPS

Construct the command:

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

# set consistent subId for recovery purposes
cmd.set_sub_id(subId)

# Pause on a specific bookmark: all subscriptions to be
# resumed together should be entered paused at the same
# bookmark.

cmd.set_bookmark(pause_bookmark)

# Set pause (and any other options as needed)
set_options(AMPS.Message.Options.Pause)

The command can now be used in execute or execute_async.