WIP

mkuratczyk · mkuratczyk · commit 6ed55e02553b · 2024-10-03T09:56:42.000+02:00
diff --git a/pkg/amqp10_client/consumer.go b/pkg/amqp10_client/consumer.go
@@ -247,6 +247,8 @@ func buildLinkFilters(cfg config.Config) []amqp.LinkFilter {
 	if cfg.StreamFilterValues != "" {
 		filters = append(filters, amqp.NewLinkFilter("rabbitmq:stream-filter", 0, cfg.StreamFilterValues))
 	}
+
+	filters = append(filters, amqp.NewLinkFilter("amqp:properties-filter", 0, map[string]any{"subject": "foo"}))
 	return filters
 }
 

Original file line number	Diff line number	Diff line change
`@@ -247,6 +247,8 @@ func buildLinkFilters(cfg config.Config) []amqp.LinkFilter {`
`247`	`247`	`if cfg.StreamFilterValues != "" {`
`248`	`248`	`filters = append(filters, amqp.NewLinkFilter("rabbitmq:stream-filter", 0, cfg.StreamFilterValues))`
`249`	`249`	`}`
	`250`	`+`
	`251`	`+ filters = append(filters, amqp.NewLinkFilter("amqp:properties-filter", 0, map[string]any{"subject": "foo"}))`
`250`	`252`	`return filters`
`251`	`253`	`}`
`252`	`254`