Ack a successfully handled message by the matching {@link JmsMessageID}. <p>Acking means removing the message from the pending messages collections,

Ack a message. @param msgId the message id

Activate a topology. @param topologyName the name of the topology to activate @throws TException on any error from nimbus

Parameters: - name

Parameters: - name

Add an event into the window, with {@link System#currentTimeMillis()} as the tracking ts. @param event the event to add

Adds a list of worker hook definitions. Optionally overriding existing definitions if one with the same ID already exists. @param workerHooks worker h

A helper method to extract avro serialization configurations from the topology configuration and register specific kryo serializers as necessary. A d

Add configuration for this spout. This method is called from YAML file: <p></p> ``` className: "org.apache.storm.flux.wrappers.bolts.FluxShellSpout" c

Add configuration for this bolt. This method is called from YAML file: <p/> ``` className: "org.apache.storm.flux.wrappers.bolts.FluxShellBolt" constr

Set --device option. @param sourceDevice the source device @param destinationDevice the destination device @return the self

add a process to cgroup. @param pid the PID of the process to add

Add generic resources for this component.

Add generic resources for this component.