CorrelationFilter Class

Represents the correlation filter expression.

Inheritance
CorrelationFilter

Constructor

CorrelationFilter(*, properties: Optional[Dict[str, str]] = None, correlation_id: Optional[str] = None, message_id: Optional[str] = None, to: Optional[str] = None, reply_to: Optional[str] = None, label: Optional[str] = None, session_id: Optional[str] = None, reply_to_session_id: Optional[str] = None, content_type: Optional[str] = None, requires_preprocessing: Optional[bool] = True, **kwargs)

Parameters

properties
dict[str, str]
Required

dictionary object for custom filters.

correlation_id
str
Required

Identifier of the correlation.

message_id
str
Required

Identifier of the message.

to
str
Required

Address to send to.

reply_to
str
Required

Address of the queue to reply to.

label
str
Required

Application specific label.

session_id
str
Required

Session identifier.

reply_to_session_id
str
Required

Session identifier to reply to.

content_type
str
Required

Content type of the message.

requires_preprocessing
bool
Required

Value that indicates whether the rule action requires preprocessing.