Interface IConsumerBuilder.IStreamFilterOptions
Filter options for support of AMQP filter expressions.
AMQP filter expressions are supported only with streams. This a different filtering mechanism from stream filtering. Both mechanisms can be used together. Requires RabbitMQ 4.1 or more.
public interface IConsumerBuilder.IStreamFilterOptions
Methods
AbsoluteExpiryTime(DateTime)
Filter on absolute expiry time field.
IConsumerBuilder.IStreamFilterOptions AbsoluteExpiryTime(DateTime absoluteExpiryTime)
Parameters
absoluteExpiryTimeDateTimecorrelation ID
Returns
ContentEncoding(string)
Filter on content-encoding field.
IConsumerBuilder.IStreamFilterOptions ContentEncoding(string contentEncoding)
Parameters
contentEncodingstringcorrelation ID
Returns
ContentType(string)
Filter on content-type field.
IConsumerBuilder.IStreamFilterOptions ContentType(string contentType)
Parameters
contentTypestringcorrelation ID
Returns
CorrelationId(object)
Filter on correlation ID.
IConsumerBuilder.IStreamFilterOptions CorrelationId(object correlationId)
Parameters
correlationIdobjectcorrelation ID
Returns
CreationTime(DateTime)
Filter on creation time field.
IConsumerBuilder.IStreamFilterOptions CreationTime(DateTime creationTime)
Parameters
creationTimeDateTimecorrelation ID
Returns
GroupId(string)
Filter on group ID.
IConsumerBuilder.IStreamFilterOptions GroupId(string groupId)
Parameters
groupIdstringcorrelation ID
Returns
GroupSequence(uint)
Filter on group sequence.
IConsumerBuilder.IStreamFilterOptions GroupSequence(uint groupSequence)
Parameters
groupSequenceuintcorrelation ID
Returns
MessageId(object)
Filter on message ID.
IConsumerBuilder.IStreamFilterOptions MessageId(object id)
Parameters
idobjectmessage ID
Returns
Property(string, object)
Filter on an application property.
IConsumerBuilder.IStreamFilterOptions Property(string key, object value)
Parameters
Returns
PropertySymbol(string, string)
Filter on an application property as a Amqp.Types.Symbol
IConsumerBuilder.IStreamFilterOptions PropertySymbol(string key, string value)
Parameters
Returns
ReplyTo(string)
Filter on reply-to field.
IConsumerBuilder.IStreamFilterOptions ReplyTo(string replyTo)
Parameters
replyTostringcorrelation ID
Returns
ReplyToGroupId(string)
Filter on reply-to group.
IConsumerBuilder.IStreamFilterOptions ReplyToGroupId(string groupId)
Parameters
groupIdstringcorrelation ID
Returns
Sql(string)
SQL filter expression.
IConsumerBuilder.IStreamFilterOptions Sql(string sql)
Parameters
sqlstring
Returns
Stream()
Return the stream options.
IConsumerBuilder.IStreamOptions Stream()
Returns
Subject(string)
Filter on subject field.
IConsumerBuilder.IStreamFilterOptions Subject(string subject)
Parameters
subjectstringcorrelation ID
Returns
To(string)
Filter on to field.
IConsumerBuilder.IStreamFilterOptions To(string to)
Parameters
tostringcorrelation ID
Returns
UserId(byte[])
Filter on user ID.
IConsumerBuilder.IStreamFilterOptions UserId(byte[] userId)
Parameters
userIdbyte[]correlation ID