|
@@ -8,6 +8,7 @@ import (
|
|
|
"net/http"
|
|
"net/http"
|
|
|
"net/url"
|
|
"net/url"
|
|
|
"strconv"
|
|
"strconv"
|
|
|
|
|
+ "strings"
|
|
|
|
|
|
|
|
"github.com/smallnest/rpcx/protocol"
|
|
"github.com/smallnest/rpcx/protocol"
|
|
|
)
|
|
)
|
|
@@ -173,7 +174,7 @@ func getUrlParams(r *http.Request, metadata map[string]string) map[string]string
|
|
|
}
|
|
}
|
|
|
query := r.URL.Query()
|
|
query := r.URL.Query()
|
|
|
for k, v := range query {
|
|
for k, v := range query {
|
|
|
- if k != XMeta {
|
|
|
|
|
|
|
+ if !strings.HasPrefix(k, "X-RPCX-") && len(v) > 0 {
|
|
|
metadata[k] = v[0]
|
|
metadata[k] = v[0]
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|