Add extra options to be used by others that need them

broker/options.go

@@ -6,7 +6,10 @@ type Options struct {
 	Options map[string]string
 }
 
-type PublishOptions struct{}
+type PublishOptions struct {
+	// Other options to be used by broker implementations
+	Options map[string]string
+}
 
 type SubscribeOptions struct {
 	// AutoAck defaults to true. When a handler returns
@@ -16,6 +19,9 @@ type SubscribeOptions struct {
 	// will create a shared subscription where each
 	// receives a subset of messages.
 	Queue string
+
+	// Other options to be used by broker implementations
+	Options map[string]string
 }
 
 type Option func(*Options)

registry/options.go

@@ -6,6 +6,9 @@ import (
 
 type Options struct {
 	Timeout time.Duration
+
+	// Other options to be used by registry implementations
+	Options map[string]string
 }
 
 func Timeout(t time.Duration) Option {

selector/options.go

@@ -6,10 +6,16 @@ import (
 
 type Options struct {
 	Registry registry.Registry
+
+	// Other options to be used by broker implementations
+	Options map[string]string
 }
 
 type SelectOptions struct {
 	Filters []SelectFilter
+
+	// Other options to be used by broker implementations
+	Options map[string]string
 }
 
 // Option used to initialise the selector

transport/http_transport.go

@@ -87,7 +87,7 @@ func (h *httpTransportClient) Send(m *Message) error {
 
 func (h *httpTransportClient) Recv(m *Message) error {
 	var r *http.Request
-	if !h.dialOpts.stream {
+	if !h.dialOpts.Stream {
 		rc, ok := <-h.r
 		if !ok {
 			return io.EOF

transport/transport.go

@@ -29,10 +29,16 @@ type Transport interface {
 	String() string
 }
 
-type Options struct{}
+type Options struct {
+	// Other options to be used by broker implementations
+	Options map[string]string
+}
 
 type DialOptions struct {
-	stream bool
+	Stream bool
+
+	// Other options to be used by broker implementations
+	Options map[string]string
 }
 
 type Option func(*Options)
@@ -45,7 +51,7 @@ var (
 
 func WithStream() DialOption {
 	return func(o *DialOptions) {
-		o.stream = true
+		o.Stream = true
 	}
 }