DecodeToBrokerMessage tries to parse a combination of json-encoded metadata and a marshalled protobuf.

DefaultURLMux returns the URLMux used by OpenTopic and OpenSubscription.

EncodeBrokerMessage just joins on the md+bytes raw data from a broker message.

EncodeProtoWithContext combines json-encoded context metadata and marshalled proto.Message into a unique []byte.

OpenQueue opens a Queue identified by the URL given.

TypeWithContext composes a generic type and a context.

URLMux is a URL opener multiplexer.

URLOpener represents types than can open Registries based on a URL.