fix: use different channel names in pubsub emulator integration tests (GoogleCloudPlatform#3878)

b/424814598

Author: JoeWang1127

spring-cloud-gcp-pubsub-stream-binder/src/test/java/com/google/cloud/spring/stream/binder/pubsub/PubSubEmulator.java

@@ -124,7 +124,7 @@ public String resolveParameter(
    * operation.
    */
   @Override
-  public void afterAll(ExtensionContext extensionContext) throws Exception {
+  public void afterAll(ExtensionContext extensionContext) {
     findAndDestroyEmulator();
   }
 
@@ -136,7 +136,7 @@ private void findAndDestroyEmulator() {
       LOGGER.warn("Emulator process null after tests; nothing to terminate.");
     }
 
-    // find destory emulator process spawned by gcloud
+    // find and destroy emulator process spawned by gcloud
     if (this.emulatorHostPort == null) {
       LOGGER.warn("Host/port null after the test.");
     } else {

spring-cloud-gcp-pubsub-stream-binder/src/test/java/com/google/cloud/spring/stream/binder/pubsub/PubSubMessageChannelBinderEmulatorIntegrationTests.java

@@ -106,15 +106,15 @@ void testSendAndReceiveWithHeaderMappingsConsumer() throws Exception {
     producerProps.getExtension().setAllowedHeaders(new String[]{"firstHeader", "secondHeader"});
 
     BindingProperties outputBindingProperties = createProducerBindingProperties(producerProps);
-    DirectChannel moduleOutputChannel = createBindableChannel("output", outputBindingProperties);
+    DirectChannel moduleOutputChannel = createBindableChannel("output-consumer-mapping", outputBindingProperties);
 
     BindingProperties inputBindingProperties = createConsumerBindingProperties(consumerProps);
-    DirectChannel moduleInputChannel = createBindableChannel("input", inputBindingProperties);
+    DirectChannel moduleInputChannel = createBindableChannel("input-consumer-mapping", inputBindingProperties);
 
     Binding<MessageChannel> producerBinding = binder.bindProducer(String.format("foo%s0", getDestinationNameDelimiter()),
             moduleOutputChannel, producerProps);
     Binding<MessageChannel> consumerBinding = binder.bindConsumer(String.format("foo%s0", getDestinationNameDelimiter()),
-            "test-group", moduleInputChannel,
+            "test-group-consumer", moduleInputChannel,
             consumerProps);
 
     Message<?> message = MessageBuilder.withPayload("insert some random stuff here")
@@ -124,7 +124,7 @@ void testSendAndReceiveWithHeaderMappingsConsumer() throws Exception {
     // Let the consumer actually bind to the producer before sending a msg
     binderBindUnbindLatency();
     CountDownLatch latch = new CountDownLatch(1);
-    AtomicReference<Message<byte[]>> inboundMessageRef = new AtomicReference<Message<byte[]>>();
+    AtomicReference<Message<byte[]>> inboundMessageRef = new AtomicReference<>();
     moduleInputChannel.subscribe(message1 -> {
       try {
         inboundMessageRef.set((Message<byte[]>) message1);
@@ -159,15 +159,15 @@ void testSendAndReceiveWithHeaderMappingsProducer() throws Exception {
     producerProps.getExtension().setAllowedHeaders(new String[]{"secondHeader"});
 
     BindingProperties outputBindingProperties = createProducerBindingProperties(producerProps);
-    DirectChannel moduleOutputChannel = createBindableChannel("output", outputBindingProperties);
+    DirectChannel moduleOutputChannel = createBindableChannel("output-producer-mapping", outputBindingProperties);
 
     BindingProperties inputBindingProperties = createConsumerBindingProperties(consumerProps);
-    DirectChannel moduleInputChannel = createBindableChannel("input", inputBindingProperties);
+    DirectChannel moduleInputChannel = createBindableChannel("input-producer-mapping", inputBindingProperties);
 
     Binding<MessageChannel> producerBinding = binder.bindProducer(String.format("foo%s0", getDestinationNameDelimiter()),
             moduleOutputChannel, producerProps);
     Binding<MessageChannel> consumerBinding = binder.bindConsumer(String.format("foo%s0", getDestinationNameDelimiter()),
-            "test-group", moduleInputChannel,
+            "test-group-producer", moduleInputChannel,
             consumerProps);
 
     Message<?> message = MessageBuilder.withPayload("insert some random stuff here")
@@ -177,7 +177,7 @@ void testSendAndReceiveWithHeaderMappingsProducer() throws Exception {
     // Let the consumer actually bind to the producer before sending a msg
     binderBindUnbindLatency();
     CountDownLatch latch = new CountDownLatch(1);
-    AtomicReference<Message<byte[]>> inboundMessageRef = new AtomicReference<Message<byte[]>>();
+    AtomicReference<Message<byte[]>> inboundMessageRef = new AtomicReference<>();
     moduleInputChannel.subscribe(message1 -> {
       try {
         inboundMessageRef.set((Message<byte[]>) message1);