publish-correlation

Including the basic AMPS library:

import com.crankuptheamps.client.*;
import com.crankuptheamps.client.exception.*;

Constructing the command:

Command cmd = new Command(Message.Command.Publish);

// Set topic and data (required)
cmd.setTopic(topic).setData(data);

// Set correlation Id
cmd.setCorrelationId(crossRef);

The command can now be used in executeAsync with a null message handler.