Skip to main content

sow-and-delta-aggreggated

Including the basic AMPS library:

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

Constructing the command:

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


cmd.setTopic(topic).setOptions(Message.Options.Projection("/id as /id, COUNT(/values) as /valueCount") +
Message.Options.Grouping("/id") +
Message.Options.OOF +
Message.Options.NoEmpties);

The command can now be used in execute or executeAsync.