Represents the possible values for message options in an AMPS command. Options in a message are combined in to a comma-delimited list. Each of these option values is comma-terminated, so they can be easily combined by simple string concatenation. More...

Static Public Member Functions
static string	Conflation (String conflation)

static string	ConflationKey (String conflationKey)

static string	MaxBacklog (int maxBacklog)

static string	TopN (int topN)

static string	Rate (String rate)

static string	RateMaxGap (String rateMaxGap)

static string	Select (String selectList)

static string	Select (IEnumerable< String > selectList)

static string	SkipN (int skipN)

static string	Projection (String projection)

static string	Projection (IEnumerable< String > projections)

static string	Grouping (String grouping)

static string	Grouping (IEnumerable< String > groupings)

static string	AckConflationInterval (String interval)

Static Public Attributes
const string	None = null

const string	Live = "live,"

const string	OOF = "oof,"

const string	Replace = "replace,"

const string	NoEmpties = "no_empties,"

const string	SendKeys = "send_keys,"

const string	Timestamp = "timestamp,"

const string	NoSowKey = "no_sowkey,"

const string	Cancel = "cancel,"

const string	Expire = "expire,"

const string	Resume = "resume,"

const string	Pause = "pause,"

const string	FullyDurable = "fully_durable,"

Detailed Description

Represents the possible values for message options in an AMPS command. Options in a message are combined in to a comma-delimited list. Each of these option values is comma-terminated, so they can be easily combined by simple string concatenation.

For options that take a list of parameters, this class provides convenience constructors to format the list. AMPS.Client.Command::getOptions() AMPS.Client.Command::setOptions(string) AMPS.Client.Message::getOptions() AMPS.Client.Message::setOptions(string)

Member Function Documentation

◆ AckConflationInterval()

static string AMPS.Client.Message.Options.AckConflationInterval ( String interval )

inlinestatic

Formats the ack_conflation interval for a logon command. This option can be used to request that, for this connection, the server return persisted acknowledgements for publishes more frequently than the default 1s interval. Notice that, if the server replicates messages to other destinations, the effective conflation interval may depend on the replication configuration of this server and the replication configuration of the destinations that this server replicates to: AMPS will not provide a persisted acknowledgment for a message that has not been properly acknowledged by the applicable replication destinations.

This option is only valid on a logon command.

Parameters

interval the interval at which to conflate persisted publish acknowledgements for this connection

Returns: the formatted value

◆ Conflation()

static string AMPS.Client.Message.Options.Conflation ( String conflation )

inlinestatic

Formats the conflation option for a command. This option can be used with subscriptions to topics in the State-of-the-World to request that AMPS conflate publishes to the same record. This can reduce bandwidth and processing requirements for the the subscriber. If a large number of subscribers will use the same conflation setting for the same topic, consider configuring a ConflatedTopic on the server.

See the AMPS User Guide for details.

Parameters

conflation the conflation interval

Returns: the formatted value

◆ ConflationKey()

static string AMPS.Client.Message.Options.ConflationKey ( String conflationKey )

inlinestatic

Formats the conflation_key option for a command that uses the conflation option. This option can be used with subscriptions to topics in the State-of-the-World to request that AMPS conflate publishes to messages with a common value for a field or set of fields that is not the key for the topic.

This option must be used with the conflation option.

Parameters

conflationKey the field or fields to use as a conflation key

Returns: the formatted value

◆ Grouping() [1/2]

static string AMPS.Client.Message.Options.Grouping ( IEnumerable< String > groupings )

inlinestatic

Formats the grouping option for an aggregated subscription, which specifies how to determine which records to aggregate together. When this option is provided, a projection option must also be provided. This overload of the method expects a java.lang.Iterable that contains individual fields. This method formats the contents of the Iterable into a comma-delimited list. See the AMPS User Guide for details.

Parameters

grouping the list of fields to group by

Returns: the formatted value

◆ Grouping() [2/2]

static string AMPS.Client.Message.Options.Grouping ( String grouping )

inlinestatic

Formats the grouping option for an aggregated subscription, which specifies how to determine which records to aggregate together. When this option is provided, a projection option must also be provided. This overload of the method expects a String that contains a comma-delimited list of fields to group by. See the AMPS User Guide for details.

Parameters

grouping the fields to group by

Returns: the formatted value

◆ MaxBacklog()

static string AMPS.Client.Message.Options.MaxBacklog ( int maxBacklog )

inlinestatic

Formats the max_backlog option for a command, used when subscribing to a queue. When consuming from a queue, this option sets the maximum number of messages the client is willing to have outstanding at a given time. (The actual number of messages provided is determined by both this parameter and the server configuration.) See the AMPS User Guide and the AMPS Command Reference for details.

Parameters

maxBacklog the maximum number of messages to provide to this subscription at a given time

Returns: the formatted value

◆ Projection() [1/2]

static string AMPS.Client.Message.Options.Projection ( IEnumerable< String > projections )

inlinestatic

Formats the projection option for an aggregated subscription, which specifies the fields produced by the aggregation. When this option is provided, a grouping option must also be provided. This overload of the method expects a java.lang.Iterable that contains individual field projections. The method formats the field projections into a comma-delimited list.

See the AMPS User Guide for details.

Parameters

projection a list of fields to produce

Returns: the formatted value

◆ Projection() [2/2]

static string AMPS.Client.Message.Options.Projection ( String projection )

inlinestatic

Formats the projection option for an aggregated subscription, which specifies the fields produced by the aggregation. When this option is provided, a grouping option must also be provided. This overload of the method expects a string that contains a comma-delimited list of projections. See the AMPS User Guide for details.

Parameters

projection the fields to produce

Returns: the formatted value

◆ Rate()

static string AMPS.Client.Message.Options.Rate ( String rate )

inlinestatic

Formats the rate option for a command, used to slow down the rate of a bookmark replay. When used with a bookmark replay, this option directs AMPS to slow down the replay to approximately the rate specified. See the AMPS Command Reference for details.

Parameters

rate	the requested rate limit for the bookmark replay

Returns: the formatted value

◆ RateMaxGap()

static string AMPS.Client.Message.Options.RateMaxGap ( String rateMaxGap )

inlinestatic

Formats the rate_max_gap option for a command, which can be used when a bookmark replay specifies a relative rate. When used with a bookmark replay that specifies a relative rate (for example, that the replay should be slowed down to no more than 2X the original publish rate), this option sets the maximum amount of time for the replay to go without producing a message. See the AMPS User Guide for details.

Parameters

rateMaxGap the maximum amount of time without producing a message

Returns: the formatted value

◆ Select() [1/2]

static string AMPS.Client.Message.Options.Select ( IEnumerable< String > selectList )

inlinestatic

Formats the select option for a subscription or SOW query, which specifies the fields produced in the delivered messages. This overload of the method expects a java.lang.Iterable that contains individual field directives. The method formats the field directives into a comma-delimited list.

See the AMPS User Guide for details.

Parameters

selectList a list of fields to produce

Returns: the formatted value

◆ Select() [2/2]

static string AMPS.Client.Message.Options.Select ( String selectList )

inlinestatic

Formats the select option for a subscription or SOW query, which specifies the fields produced in the delivered messages. This overload of the method expects a string that contains a comma-delimited list of field directives.

See the AMPS User Guide for details.

Parameters

selectList the list of fields to produce

Returns: the formatted value

◆ SkipN()

static string AMPS.Client.Message.Options.SkipN ( int skipN )

inlinestatic

Formats the skip_n option for a sow or sow_and_subscribe command. When this option is provided, AMPS will skip the specified number of messages before returning the top_n records specified. See the AMPS Command Reference and the Developer Guide for details.

Parameters

skipN the number of results to skip before beginning to return results

Returns: the formatted value

◆ TopN()

static string AMPS.Client.Message.Options.TopN ( int topN )

inlinestatic

Formats the top_n option for a command. When this option is specified, AMPS will return the specified number of messages from the results. See the AMPS Command Reference for details.

Parameters

topN	the number of messages to return from the result set

Returns: the formatted value

Member Data Documentation

◆ Cancel

const string AMPS.Client.Message.Options.Cancel = "cancel,"

static

Constant string for the cancel option, used when acknowledging (sow_delete) a leased message to return the message to the queue rather than acknowledging the message as processed.

◆ Expire

const string AMPS.Client.Message.Options.Expire = "expire,"

static

Constant string for the expire option, used when acknowledging (sow_delete) a leased message to immediately expire the message from the queue rather than acknowledging the message as processed.

◆ FullyDurable

const string AMPS.Client.Message.Options.FullyDurable = "fully_durable,"

static

Constant string for the fully_durable option. This option specifies that a message will not be provided to a bookmark replay until it has been acknowledged as persisted by all synchronous replication destinations. The option is used to provide increased repeatability of bookmark subscriptions, although it may increase the latency for current publishes to be delivered to the subscriber.

◆ Live

const string AMPS.Client.Message.Options.Live = "live,"

static

Constant string for the live option. which requests that a bookmark subscription should receive messages before they are written to the transaction log once replay is complete. This could potentially slightly reduce latency in some configurations, although subscriptions using this option increase the risk of inconsistent data in failover situations.

◆ NoEmpties

const string AMPS.Client.Message.Options.NoEmpties = "no_empties,"

static

Constant string for the no_empties option. When used with a delta subscription, this option specifies that AMPS will not create a message to this subscription when a publish happens that does not change the value of any field in the message.

◆ NoSowKey

const string AMPS.Client.Message.Options.NoSowKey = "no_sowkey,"

static

Constant string for the no_sow_key option. When specified on a command, AMPS will not provide the SOW key field on messages provided in response to the command.

◆ OOF

const string AMPS.Client.Message.Options.OOF = "oof,"

static

Constant string for the oof (out of focus) option. When used with a subscription, the oof option requests notification messages when a message that previously matched the subscription no longer matches the subscription.

◆ Pause

const string AMPS.Client.Message.Options.Pause = "pause,"

static

Constant string for the pause option. This option is used to group bookmark subscriptions so that a set of independent subscriptions can be started simultaneously and proceed through replay together, typically used for testing or auditing purposes. See the AMPS User Guide for details.

◆ Replace

const string AMPS.Client.Message.Options.Replace = "replace,"

static

Constant string for the replace option. When this option is provided on a command, AMPS updates the existing subscription specified in the

SubId

for the command rather than creating a new subscription. See the AMPS User Guide for details.

◆ Resume

const string AMPS.Client.Message.Options.Resume = "resume,"

static

Constant string for the resume option. This option is to start a set of bookmark subscriptions that have been entered in a paused state. See the AMPS User Guide for details.

◆ SendKeys

const string AMPS.Client.Message.Options.SendKeys = "send_keys,"

static

Constant string for the send_keys option. This option is the current server default, and does not need to be specified. When set, AMPS provides the key fields for a message along with changed fields in messages to a delta subscription.

◆ Timestamp

const string AMPS.Client.Message.Options.Timestamp = "timestamp,"

static

Constant string for the timestamp option. When specified on a command, AMPS will include the timestamp header on data messages sent in response to that command.

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

AMPS.Client/Message.cs

Static Public Member Functions

Static Public Attributes

Detailed Description

Member Function Documentation

◆ AckConflationInterval()

◆ Conflation()

◆ ConflationKey()

◆ Grouping() [1/2]

◆ Grouping() [2/2]

◆ MaxBacklog()

◆ Projection() [1/2]

◆ Projection() [2/2]

◆ Rate()

◆ RateMaxGap()

◆ Select() [1/2]

◆ Select() [2/2]

◆ SkipN()

◆ TopN()

Member Data Documentation

◆ Cancel

◆ Expire

◆ FullyDurable

◆ Live

◆ NoEmpties

◆ NoSowKey

◆ OOF

◆ Pause

◆ Replace

◆ Resume

◆ SendKeys

◆ Timestamp