diff --git a/context/context.go b/context/context.go
index 51ad509..3c44e90 100644
--- a/context/context.go
+++ b/context/context.go
@@ -283,10 +283,11 @@ type SyncRequest struct {
 }
 
 type Input struct {
-	Uri           string            `json:"uri,omitempty"`
-	ComponentName string            `json:"componentName"`
-	ComponentType string            `json:"componentType"`
-	Metadata      map[string]string `json:"metadata,omitempty"`
+	Uri               string             `json:"uri,omitempty"`
+	ComponentName     string             `json:"componentName"`
+	ComponentType     string             `json:"componentType"`
+	Metadata          map[string]string  `json:"metadata,omitempty"`
+	PubSubRoutingRule *PubSubRoutingRule `json:"pubSubRoutingRule,omitempty"`
 }
 
 // GetType will be called after the context has been parsed correctly,
@@ -331,6 +332,12 @@ type TracingProvider struct {
 	OapServer string `json:"oapServer" yaml:"oapServer"`
 }
 
+type PubSubRoutingRule struct {
+	Route    string `json:"route"`
+	Match    string `json:"match"`
+	Priority int    `json:"priority"`
+}
+
 type ResponseWriterWrapper struct {
 	http.ResponseWriter
 	statusCode int
diff --git a/runtime/async/async.go b/runtime/async/async.go
index 3c7b85f..3158fc9 100644
--- a/runtime/async/async.go
+++ b/runtime/async/async.go
@@ -125,6 +125,11 @@ func (r *Runtime) RegisterOpenFunction(
 						PubsubName: input.ComponentName,
 						Topic:      input.Uri,
 					}
+					if input.PubSubRoutingRule != nil && input.PubSubRoutingRule.Match != "" {
+						sub.Route = input.PubSubRoutingRule.Route
+						sub.Match = input.PubSubRoutingRule.Match
+						sub.Priority = input.PubSubRoutingRule.Priority
+					}
 					funcErr = r.handler.AddTopicEventHandler(sub, func(c context.Context, e *dapr.TopicEvent) (retry bool, err error) {
 						rm := runtime.NewRuntimeManager(ctx, prePlugins, postPlugins)
 						rm.FuncContext.SetEvent(name, e)