Interface IConsumerBuilder.IStreamOptions
public interface IConsumerBuilder.IStreamOptionsMethods
Builder()
Return the consumer builder.
IConsumerBuilder Builder()Returns
Filter()
Options for AMQP filter expressions.
Requires RabbitMQ 4.1 or more.
This a different filtering mechanism from stream filtering. Both mechanisms can be used together.
IConsumerBuilder.IStreamFilterOptions Filter()Returns
FilterMatchUnfiltered(bool)
Whether messages without a filter value should be sent.
Default is
falseThis a different filtering mechanism from AMQP filter expressions. Both mechanisms can be used together.
IConsumerBuilder.IStreamOptions FilterMatchUnfiltered(bool matchUnfiltered)Parameters
matchUnfilteredbooltrueto send messages without a filter value
Returns
FilterValues(params string[])
Filter values for stream filtering.
This a different filtering mechanism from AMQP filter expressions. Both mechanisms can be used together.
IConsumerBuilder.IStreamOptions FilterValues(params string[] values)Parameters
valuesstring[]filter values
Returns
Offset(StreamOffsetSpecification)
The offset from which to start consuming.
IConsumerBuilder.IStreamOptions Offset(StreamOffsetSpecification specification)Parameters
specificationStreamOffsetSpecificationthe offset specification
Returns
Offset(DateTime)
A point in time from which to start consuming.
Be aware consumers can receive messages published a bit before the specified timestamp.
IConsumerBuilder.IStreamOptions Offset(DateTime timestamp)Parameters
timestampDateTimethe timestamp
Returns
Offset(long)
The offset from which to start consuming.
IConsumerBuilder.IStreamOptions Offset(long offset)Parameters
offsetlongthe offset
Returns
Offset(string)
The offset from which to start consuming as an interval string value.
Valid units are Y, M, D, h, m, s. Examples:
7D12hIConsumerBuilder.IStreamOptions Offset(string interval)Parameters
intervalstringthe interval