API consistency with .NET client

* Prefer using `IQueueSpecification` and `IExchangeSpecification` instead of `string`

Author: lukebakken

examples/getting_started/main.go

@@ -48,7 +48,7 @@ func main() {
 	}
 	fmt.Printf("Exchange %s created.\n", exchangeInfo.GetName())
 
-	bindingSpec := management.Binding().SourceExchange(exchangeInfo.GetName()).DestinationQueue(queueInfo.GetName()).Key("routing-key")
+	bindingSpec := management.Binding().SourceExchange(exchangeSpec).DestinationQueue(queueSpec).Key("routing-key")
 
 	err = bindingSpec.Bind(context.Background())
 	if err != nil {

rabbitmq_amqp/amqp_binding.go

@@ -9,10 +9,10 @@ type AMQPBindingInfo struct {
 }
 
 type AMQPBinding struct {
-	sourceExchangeName string
-	destinationQueue   string
-	bindingKey         string
-	management         *AmqpManagement
+	sourceExchange   IExchangeSpecification
+	destinationQueue IQueueSpecification
+	bindingKey       string
+	management       *AmqpManagement
 }
 
 func newAMQPBinding(management *AmqpManagement) *AMQPBinding {
@@ -24,13 +24,13 @@ func (b *AMQPBinding) Key(bindingKey string) IBindingSpecification {
 	return b
 }
 
-func (b *AMQPBinding) SourceExchange(exchangeName string) IBindingSpecification {
-	b.sourceExchangeName = exchangeName
+func (b *AMQPBinding) SourceExchange(exchangeSpec IExchangeSpecification) IBindingSpecification {
+	b.sourceExchange = exchangeSpec
 	return b
 }
 
-func (b *AMQPBinding) DestinationQueue(queueName string) IBindingSpecification {
-	b.destinationQueue = queueName
+func (b *AMQPBinding) DestinationQueue(queueSpec IQueueSpecification) IBindingSpecification {
+	b.destinationQueue = queueSpec
 	return b
 }
 
@@ -39,16 +39,16 @@ func (b *AMQPBinding) Bind(ctx context.Context) error {
 	path := bindingPath()
 	kv := make(map[string]any)
 	kv["binding_key"] = b.bindingKey
-	kv["source"] = b.sourceExchangeName
-	kv["destination_queue"] = b.destinationQueue
+	kv["source"] = b.sourceExchange.GetName()
+	kv["destination_queue"] = b.destinationQueue.GetName()
 	kv["arguments"] = make(map[string]any)
 	_, err := b.management.Request(ctx, kv, path, commandPost, []int{responseCode204})
 	return err
 
 }
 
 func (b *AMQPBinding) Unbind(ctx context.Context) error {
-	bindingPathWithExchangeQueueKey := bindingPathWithExchangeQueueKey(b.sourceExchangeName, b.destinationQueue, b.bindingKey)
+	bindingPathWithExchangeQueueKey := bindingPathWithExchangeQueueKey(b.sourceExchange, b.destinationQueue, b.bindingKey)
 	_, err := b.management.Request(ctx, amqp.Null{}, bindingPathWithExchangeQueueKey, commandDelete, []int{responseCode204})
 	return err
 }

rabbitmq_amqp/common.go

@@ -86,11 +86,11 @@ func bindingPath() string {
 	return "/" + Bindings
 }
 
-func bindingPathWithExchangeQueueKey(exchangeName, queueName, key string) string {
+func bindingPathWithExchangeQueueKey(exchangeSpec IExchangeSpecification, queueSpec IQueueSpecification, key string) string {
 	//string path =
 	//$"/{Consts.Bindings}/src={Utils.EncodePathSegment(_sourceName)};{($"{destinationCharacter}={Utils.EncodePathSegment(_destinationName)};key={Utils.EncodePathSegment(_routingKey)};args=")}";
 
-	return fmt.Sprintf("/%s/src=%s;dstq=%s;key=%s;args=", Bindings, encodePathSegments(exchangeName), encodePathSegments(queueName), encodePathSegments(key))
+	return fmt.Sprintf("/%s/src=%s;dstq=%s;key=%s;args=", Bindings, encodePathSegments(exchangeSpec.GetName()), encodePathSegments(queueSpec.GetName()), encodePathSegments(key))
 
 }
 

rabbitmq_amqp/entities.go

@@ -86,8 +86,8 @@ type IExchangeSpecification interface {
 }
 
 type IBindingSpecification interface {
-	SourceExchange(exchangeName string) IBindingSpecification
-	DestinationQueue(queueName string) IBindingSpecification
+	SourceExchange(exchangeSpec IExchangeSpecification) IBindingSpecification
+	DestinationQueue(queueSpec IQueueSpecification) IBindingSpecification
 	Key(bindingKey string) IBindingSpecification
 	Bind(ctx context.Context) error
 	Unbind(ctx context.Context) error