* Formatting

* Rename `Exclusive` getter to `IsExclusive`

Author: lukebakken

rabbitmq_amqp/amqp_queue.go

@@ -45,7 +45,7 @@ func (a *AmqpQueueInfo) IsAutoDelete() bool {
 	return a.isAutoDelete
 }
 
-func (a *AmqpQueueInfo) Exclusive() bool {
+func (a *AmqpQueueInfo) IsExclusive() bool {
 	return a.isExclusive
 }
 
@@ -121,9 +121,7 @@ func newAmqpQueue(management *AmqpManagement, queueName string) IQueueSpecificat
 }
 
 func (a *AmqpQueue) validate() error {
-
 	if a.arguments["max-length-bytes"] != nil {
-
 		err := validatePositive("max length", a.arguments["max-length-bytes"].(int64))
 		if err != nil {
 			return err
@@ -133,12 +131,12 @@ func (a *AmqpQueue) validate() error {
 }
 
 func (a *AmqpQueue) Declare(ctx context.Context) (IQueueInfo, error) {
-
 	if Quorum == a.GetQueueType() ||
 		Stream == a.GetQueueType() {
 		// mandatory arguments for quorum queues and streams
 		a.Exclusive(false).AutoDelete(false)
 	}
+
 	if err := a.validate(); err != nil {
 		return nil, err
 	}

rabbitmq_amqp/amqp_queue_test.go

@@ -36,7 +36,7 @@ var _ = Describe("AMQP Queue test ", func() {
 		Expect(queueInfo.GetName()).To(Equal(queueName))
 		Expect(queueInfo.IsDurable()).To(BeTrue())
 		Expect(queueInfo.IsAutoDelete()).To(BeFalse())
-		Expect(queueInfo.Exclusive()).To(BeFalse())
+		Expect(queueInfo.IsExclusive()).To(BeFalse())
 		Expect(queueInfo.Type()).To(Equal(Classic))
 		err = queueSpec.Delete(context.TODO())
 		Expect(err).To(BeNil())
@@ -56,7 +56,7 @@ var _ = Describe("AMQP Queue test ", func() {
 		Expect(queueInfo.GetName()).To(Equal(queueName))
 		Expect(queueInfo.IsDurable()).To(BeTrue())
 		Expect(queueInfo.IsAutoDelete()).To(BeTrue())
-		Expect(queueInfo.Exclusive()).To(BeTrue())
+		Expect(queueInfo.IsExclusive()).To(BeTrue())
 		Expect(queueInfo.Type()).To(Equal(Classic))
 		Expect(queueInfo.GetLeader()).To(ContainSubstring("rabbit"))
 		Expect(len(queueInfo.GetReplicas())).To(BeNumerically(">", 0))
@@ -82,7 +82,7 @@ var _ = Describe("AMQP Queue test ", func() {
 		Expect(queueInfo.GetName()).To(Equal(queueName))
 		Expect(queueInfo.IsDurable()).To(BeTrue())
 		Expect(queueInfo.IsAutoDelete()).To(BeFalse())
-		Expect(queueInfo.Exclusive()).To(BeFalse())
+		Expect(queueInfo.IsExclusive()).To(BeFalse())
 		Expect(queueInfo.Type()).To(Equal(Quorum))
 		err = queueSpec.Delete(context.TODO())
 		Expect(err).To(BeNil())
@@ -101,7 +101,7 @@ var _ = Describe("AMQP Queue test ", func() {
 		Expect(queueInfo.GetName()).To(Equal(queueName))
 		Expect(queueInfo.IsDurable()).To(BeTrue())
 		Expect(queueInfo.IsAutoDelete()).To(BeFalse())
-		Expect(queueInfo.Exclusive()).To(BeFalse())
+		Expect(queueInfo.IsExclusive()).To(BeFalse())
 		Expect(queueInfo.Type()).To(Equal(Stream))
 		err = queueSpec.Delete(context.TODO())
 		Expect(err).To(BeNil())

rabbitmq_amqp/entities.go

@@ -46,7 +46,7 @@ type IQueueInfo interface {
 	GetName() string
 	IsDurable() bool
 	IsAutoDelete() bool
-	Exclusive() bool
+	IsExclusive() bool
 	Type() TQueueType
 	GetLeader() string
 	GetReplicas() []string