deltapub-correlation

Import the AMPS library:

import AMPS

Construct the command:

cmd = AMPS.Command(AMPS.Message.Command.DeltaPublish)

# set the topic and data (required)
cmd.set_topic(topic).set_data(data)

# set correlation id
cmd.set_correlation_id(cross_ref)

The command can now be used in execute_async with None for the message handler.