Minor test updates (#122)

Author: Tim Middleton

.github/workflows/streaming-jakarta.yaml

@@ -65,7 +65,7 @@ jobs:
       with:
         go-version: '${{ matrix.go-version }}'
 
-    - name: Verify Examples
+    - name: Verify
       shell: bash
       run: |
         go get google.golang.org/grpc/cmd/[email protected]

.github/workflows/streaming.yaml

@@ -66,7 +66,7 @@ jobs:
       with:
         go-version: '${{ matrix.go-version }}'
 
-    - name: Verify Examples
+    - name: Verify
       shell: bash
       run: |
         go get google.golang.org/grpc/cmd/[email protected]

coherence/processors/processors.go

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2022, 2024 Oracle and/or its affiliates.
+ * Copyright (c) 2022, 2025 Oracle and/or its affiliates.
  * Licensed under the Universal Permissive License v 1.0 as shown at
  * https://oss.oracle.com/licenses/upl.
  */
@@ -15,7 +15,6 @@ import (
 const (
 	processorPrefix = "processor."
 	extractorPrefix = "extractor."
-	queuePrefix     = "internal.net.queue.processor."
 
 	compositeProcessorType         = processorPrefix + "CompositeProcessor"
 	conditionalProcessorType       = processorPrefix + "ConditionalProcessor"

test/e2e/perf/suite_test.go

@@ -155,7 +155,8 @@ func InitializeCoherence(ctx context.Context, address string) (Config, error) {
 	)
 
 	// create a new Session to the default gRPC port of 1408 using plain text
-	config.Session, err = coherence.NewSession(ctx, coherence.WithPlainText(), coherence.WithAddress(address))
+	config.Session, err = coherence.NewSession(ctx, coherence.WithPlainText(), coherence.WithAddress(address),
+		coherence.WithRequestTimeout(300*time.Minute))
 	if err != nil {
 		return config, err
 	}

test/e2e/queues/queues_test.go

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2024 Oracle and/or its affiliates.
+ * Copyright (c) 2024, 2025 Oracle and/or its affiliates.
  * Licensed under the Universal Permissive License v 1.0 as shown at
  * https://oss.oracle.com/licenses/upl.
  */
@@ -455,11 +455,6 @@ func runTestQueueCompatability(g *gomega.WithT, queueName string, firstQueueType
 	g.Expect(queue.Destroy(ctx)).ShouldNot(gomega.HaveOccurred())
 
 	utils.Sleep(5)
-
-	//g.Expect(errorOccurred).To(gomega.Equal(shouldError))
-	//if !shouldError {
-	//	g.Expect(queue.Destroy(ctx)).ShouldNot(gomega.HaveOccurred())
-	//}
 }
 
 func testQueue(ctx context.Context, g *gomega.WithT, queue coherence.NamedQueue[string]) {

test/e2e/streaming/streaming_test.go

@@ -48,8 +48,6 @@ var (
 func TestStreamingConcurrency(t *testing.T) {
 	g := gomega.NewWithT(t)
 
-	_ = os.Setenv("COHERENCE_CLIENT_REQUEST_TIMEOUT", "300000")
-
 	osCacheCount := os.Getenv("COHERENCE_CACHE_COUNT")
 	if os.Getenv(osCacheCount) != "" {
 		v, err := strconv.Atoi(osCacheCount)
@@ -58,7 +56,7 @@ func TestStreamingConcurrency(t *testing.T) {
 		}
 	}
 
-	session, err := utils.GetSession()
+	session, err := utils.GetSession(coherence.WithRequestTimeout(5 * time.Minute))
 	g.Expect(err).ShouldNot(gomega.HaveOccurred())
 	defer session.Close()