SOL-78484: merged changes from dev branch

Signed-off-by: Chris Morgan <[email protected]>
SolaceDev · Nov 20, 2023 · e4c0fa1 · e4c0fa1
2 parents 611af89 + 911e818
commit e4c0fa1
Show file tree

Hide file tree

Showing 2 changed files with 321 additions and 310 deletions.
diff --git a/test/helpers/resource_helpers.go b/test/helpers/resource_helpers.go
@@ -64,17 +64,17 @@ func CreateNonExclusiveQueue(queueName string, topics ...string) {
 
 // CreatePartitionedQueue function
 func CreatePartitionedQueue(queueName string, partitionCount int32, partitionRebalanceDelay int64, topics ...string) {
-    _, _, err := testcontext.SEMP().Config().QueueApi.CreateMsgVpnQueue(testcontext.SEMP() .ConfigCtx(), sempconfig.MsgVpnQueue{
-        QueueName:      queueName,
-        AccessType:     "non-exclusive",
-        Permission:     "modify-topic",
-        IngressEnabled: True,
-        EgressEnabled:  True,
-        PartitionCount: partitionCount,
-        PartitionRebalanceDelay: partitionRebalanceDelay,
-		Owner:          "default",
-    }, testcontext.Messaging().VPN, nil)
-    ExpectWithOffset(1, err).ToNot(HaveOccurred(), "Failed to create queue with name "+queueName) 
+	_, _, err := testcontext.SEMP().Config().QueueApi.CreateMsgVpnQueue(testcontext.SEMP().ConfigCtx(), sempconfig.MsgVpnQueue{
+		QueueName:               queueName,
+		AccessType:              "non-exclusive",
+		Permission:              "modify-topic",
+		IngressEnabled:          True,
+		EgressEnabled:           True,
+		PartitionCount:          partitionCount,
+		PartitionRebalanceDelay: partitionRebalanceDelay,
+		Owner:                   "default",
+	}, testcontext.Messaging().VPN, nil)
+	ExpectWithOffset(1, err).ToNot(HaveOccurred(), "Failed to create queue with name "+queueName)
 	for _, topic := range topics {
 		_, _, err = testcontext.SEMP().Config().QueueApi.CreateMsgVpnQueueSubscription(testcontext.SEMP().ConfigCtx(),
 			sempconfig.MsgVpnQueueSubscription{