AMPS C/C++ Client Class Reference AMPS C/C++ Client Version 5.3.5.7

Public Member Functions | List of all members
AMPS::Message::Options Class Reference

Class for constructing the options string to pass to AMPS in a Message. More...

`#include <Message.hpp>`

## Public Member Functions
| Options (std::string options_="")
| ctor - default to None
void | setNone (void)
| Clear any previously set options and set the options to an empty string (AMPS_OPTIONS_NONE).
void | setLive (void)
| Set the live option for a bookmark subscription, which requests that the subscription receives messages before they are persisted to the transaction log after replay is complete. More...
void | setOOF (void)
| Set the option to receive out of focus (OOF) messages on a subscription, where applicable. More...
void | setReplace (void)
| Set the option to replace a current subscription with this one. More...
void | setNoEmpties (void)
| Set the option to not send empty messages on a delta subscription. More...
void | setSendKeys (void)
| Set the option to send key fields with a delta subscription. More...
void | setTimestamp (void)
| Set the option to send a timestamp that the message was processed on a subscription or query. More...
void | setNoSowKey (void)
| Set the option to not set the SowKey header on messages. More...
void | setCancel (void)
| Set the cancel option, used on a sow_delete command to return a message to the queue.
void | setResume (void)
| Set the option to resume a subscription. More...
void | setPause (void)
| Set the option to pause a bookmark subscription. More...
void | setFullyDurable (void)
| Set the option to only provide messages that have been persisted to all replication destinations that use synchronous acknowledgements. More...
void | setMaxBacklog (int maxBacklog_)
| Set the option for maximum backlog this subscription is willing to accept. More...
void | setConflation (const char *conflation_)
| Set the options for conflation on a subscription. More...
void | setConflationKey (const char *conflationKey_)
| Set the options for the conflation key, the identifiers for the field or fields used by AMPS to determine which changes to the underlying topic are considered to be changes to a distinct record. More...
void | setTopN (int topN_)
| Set the top N option, which specifies the maximum number of messages to return for this command. More...
void | setRate (const char *rate_)
| Set the option for the maximum rate at which messages are provided to the subscription. More...
void | setRateMaxGap (const char *rateMaxGap_)
| Set the option for the maximum amount of time that a bookmark replay with a specified rate will allow the subscription to go without producing messages. More...
void | setSkipN (int skipN_)
| Set the option for skip N, the number of messages in the result set to skip before returning messages to a client. More...
void | setProjection (const std::string &projection_)
| Set the option for projecting the results of an aggregated query or subscription. More...
template<class Iterator >
void | setProjection (Iterator begin_, Iterator end_)
| Set the option for projecting the results of an aggregated query or subscription. More...
void | setGrouping (const std::string &grouping_)
| Set the option for grouping the results of an aggregated query or subscription. More...
template<class Iterator >
void | setGrouping (Iterator begin_, Iterator end_)
| Set the option for grouping the results of an aggregated query or subscription. More...
void | setBookmarkNotFound (const char *action_)
| Set the option for the action to take if the requested bookmark to start the subscription is ot found. More...
void | setBookmarkNotFoundNow ()
| Set the option for the action to take if the requested bookmark to start the subscription is not found to start at NOW instead.
void | setBookmarkNotFoundEpoch ()
| Set the option for the action to take if the requested bookmark to start the subscription is not found to start at EPOCH instead.
void | setBookmarkNotFoundFail ()
| Set the option for the action to take if the requested bookmark to start the subscription is not found to fail the command.
| operator std::string ()
| Convert this object to a std::string, allows you to pass an Options object as the options_ argument directly.
size_t | getLength () const
| Return the length of this Options object as a string. More...
const char * | getStr () const
| Return this Options object as a non-NULL-terminated string. More...

## Detailed Description

Class for constructing the options string to pass to AMPS in a Message.

This class can provide a convenient way to format an options string in a command provided to AMPS. Notice that this class is only intended to help with correctly formatting the options string and to provide constant values for option names. The class does not validate the values provided to options, or that the combination of options provided is useful or valid for any particular command.

## Member Function Documentation

## ◆ getLength()

size_t AMPS::Message::Options::getLength | ( |  | ) | const
| inline

Return the length of this Options object as a string.

Returns
  The length of the string representation of self.

## ◆ getStr()

const char* AMPS::Message::Options::getStr | ( |  | ) | const
| inline

Return this Options object as a non-NULL-terminated string.

Returns
  The pointer to the beginning of self as a string. Only use this in conjunction with getLength

## ◆ setBookmarkNotFound()

void AMPS::Message::Options::setBookmarkNotFound | ( | const char * | action_ | ) |
| inline

Set the option for the action to take if the requested bookmark to start the subscription is ot found.

Parameters

  action_ | Can be one of "now", "epoch", or "fail".

## ◆ setConflation()

void AMPS::Message::Options::setConflation | ( | const char * | conflation_ | ) |
| inline

Set the options for conflation on a subscription.

See the AMPS User Guide for a description of conflation, and see the AMPS Command Reference for details on this option.

Parameters

  conflation_ | The conflation interval, auto, or none.

## ◆ setConflationKey()

void AMPS::Message::Options::setConflationKey | ( | const char * | conflationKey_ | ) |
| inline

Set the options for the conflation key, the identifiers for the field or fields used by AMPS to determine which changes to the underlying topic are considered to be changes to a distinct record.

The conflation key does not need to be the same as the keys configured for the topic. See the AMPS User Guide for details on conflation, and see the AMPS Command Reference for details on this option.

Parameters

  conflationKey_ | The message key to use for conflation.

## ◆ setFullyDurable()

void AMPS::Message::Options::setFullyDurable | ( | void |  | ) |
| inline

Set the option to only provide messages that have been persisted to all replication destinations that use synchronous acknowledgements.

This option is only valid for bookmark subscriptions that do not use the "live" option. See the AMPS User Guide and AMPS Command Reference for details.

## ◆ setGrouping() [1/2]

void AMPS::Message::Options::setGrouping | ( | const std::string & | grouping_ | ) |
| inline

Set the option for grouping the results of an aggregated query or subscription.

Parameters

  grouping_ | The comma-separated list of grouping field names.

## ◆ setGrouping() [2/2]

template<class Iterator >

void AMPS::Message::Options::setGrouping | ( | Iterator | begin_,
|  | Iterator | end_
| ) |  |
| inline

Set the option for grouping the results of an aggregated query or subscription.

Parameters

  begin_ | The starting forward iterator for field descriptions.
  end_ | The ending forward iterator for field descriptions.

## ◆ setLive()

void AMPS::Message::Options::setLive | ( | void |  | ) |
| inline

Set the live option for a bookmark subscription, which requests that the subscription receives messages before they are persisted to the transaction log after replay is complete.

This can, in case of a simultaneous AMPS failure and publisher failure, lead to an application receiving messages that do not appear in the transaction log. See the AMPS User Guide and the AMPS Command Reference for details.

## ◆ setMaxBacklog()

void AMPS::Message::Options::setMaxBacklog | ( | int | maxBacklog_ | ) |
| inline

Set the option for maximum backlog this subscription is willing to accept.

This option only applies to subscriptions to queue topics, and the server will only grant a backlog up to the maximum per subscription backlog configured for the queue. See the AMPS User Guide and the AMPS Command Reference for a description of queue backlogs, and see the AMPS Configuration Reference for details on configuring the queue.

Parameters

  maxBacklog_ | The max unacked queue messages in backlog.

## ◆ setNoEmpties()

void AMPS::Message::Options::setNoEmpties | ( | void |  | ) |
| inline

Set the option to not send empty messages on a delta subscription.

See the AMPS Command Reference for details.

## ◆ setNoSowKey()

void AMPS::Message::Options::setNoSowKey | ( | void |  | ) |
| inline

Set the option to not set the SowKey header on messages.

See the AMPS Command Reference for details.

## ◆ setOOF()

void AMPS::Message::Options::setOOF | ( | void |  | ) |
| inline

Set the option to receive out of focus (OOF) messages on a subscription, where applicable.

See the AMPS User Guide and the AMPS Command Reference for details.

## ◆ setPause()

void AMPS::Message::Options::setPause | ( | void |  | ) |
| inline

Set the option to pause a bookmark subscription.

This option is typically used when entering a number of subscriptions for synchronized replay (for example, when duplicating message flow for analysis or testing purposes). The subscriptions are registered with the "pause" option one-by-one, and then simultaneously resumed to begin the replay. This option is only valid for bookmark subscriptions that do not use the "live" option. See the AMPS User Guide and AMPS Command Reference for details.

## ◆ setProjection() [1/2]

void AMPS::Message::Options::setProjection | ( | const std::string & | projection_ | ) |
| inline

Set the option for projecting the results of an aggregated query or subscription.

Parameters

  projection_ | A string containing the projection specification, either a single field description or a comma-separated list of field descriptions.

## ◆ setProjection() [2/2]

template<class Iterator >

void AMPS::Message::Options::setProjection | ( | Iterator | begin_,
|  | Iterator | end_
| ) |  |
| inline

Set the option for projecting the results of an aggregated query or subscription.

Parameters

  begin_ | The starting forward iterator for field descriptions.
  end_ | The ending forward iterator for field descriptions.

## ◆ setRate()

void AMPS::Message::Options::setRate | ( | const char * | rate_ | ) |
| inline

Set the option for the maximum rate at which messages are provided to the subscription.

This option is only valid for bookmark subscriptions. See the AMPS Command Reference for details.

Parameters

  rate_ | The rate for sending messages on the bookmark subscription.

## ◆ setRateMaxGap()

void AMPS::Message::Options::setRateMaxGap | ( | const char * | rateMaxGap_ | ) |
| inline

Set the option for the maximum amount of time that a bookmark replay with a specified rate will allow the subscription to go without producing messages.

This option is only valid for bookmark subscriptions when a "rate" is specified, and prevents situations where a subscription would be idle for an extended period of time. For example, if a replay has a specified rate of "2x" and there is a quiet period in the transaction logs (overnight, weekends) where no matching messages were received for the subscription for 8 hours, the subscription would be idle for 4 hours unless a shorter maximum gap is specified using this option. See the AMPS Command Reference for details.

Parameters

  rateMaxGap_ | The max gap between messages on the subscription.

## ◆ setReplace()

void AMPS::Message::Options::setReplace | ( | void |  | ) |
| inline

Set the option to replace a current subscription with this one.

See the AMPS User Guide and the AMPS Command Reference for details.

## ◆ setResume()

void AMPS::Message::Options::setResume | ( | void |  | ) |
| inline

Set the option to resume a subscription.

This option is only valid for bookmark subscriptions that do not use the "live" option that have been previously paused. See the AMPS User Guide and the AMPS Command Reference for details.

## ◆ setSendKeys()

void AMPS::Message::Options::setSendKeys | ( | void |  | ) |
| inline

Set the option to send key fields with a delta subscription.

See the AMPS Command Reference for details.

## ◆ setSkipN()

void AMPS::Message::Options::setSkipN | ( | int | skipN_ | ) |
| inline

Set the option for skip N, the number of messages in the result set to skip before returning messages to a client.

See the AMPS Command Reference for details.

Parameters

  skipN_ | The number of messages to skip before sending to client.

## ◆ setTimestamp()

void AMPS::Message::Options::setTimestamp | ( | void |  | ) |
| inline

Set the option to send a timestamp that the message was processed on a subscription or query.

See the AMPS Command Reference for details.

## ◆ setTopN()

void AMPS::Message::Options::setTopN | ( | int | topN_ | ) |
| inline

Set the top N option, which specifies the maximum number of messages to return for this command.

See the AMPS Command Reference for details.

Parameters

  topN_ | The max number of messages to return.

The documentation for this class was generated from the following file:

- include/amps/Message.hpp