(flink-connector-rabbitmq) branch v3.0 updated: [FLINK-30417][Connectors/RabbitMQ] Add "RabbitMQ" to the error while creating the channel and failing. This closes #4

[martijnvisser]

This is an automated email from the ASF dual-hosted git repository.

martijnvisser pushed a commit to branch v3.0
in repository https://gitbox.apache.org/repos/asf/flink-connector-rabbitmq.git


The following commit(s) were added to refs/heads/v3.0 by this push:
     new 702f0bd  [FLINK-30417][Connectors/RabbitMQ] Add "RabbitMQ" to the 
error while creating the channel and failing. This closes #4
702f0bd is described below

commit 702f0bd687eca2ca1f460fef9229f3db213c1803
Author: Yaron Shani <yaron.sh...@gmail.com>
AuthorDate: Tue Dec 20 17:06:27 2022 +0200

    [FLINK-30417][Connectors/RabbitMQ] Add "RabbitMQ" to the error while 
creating the channel and failing. This closes #4
    
    (cherry picked from commit 967f713257bf7e933c04808c857b0e549071b863)
---
 .../java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java
 
b/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java
index d0eb0ef..6ebeb1f 100644
--- 
a/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java
+++ 
b/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java
@@ -181,7 +181,7 @@ public class RMQSink<IN> extends RichSinkFunction<IN> {
                 channel.addReturnListener(returnListener);
             }
         } catch (IOException e) {
-            throw new RuntimeException("Error while creating the channel", e);
+            throw new RuntimeException("Error while creating the RabbitMQ 
channel", e);
         }
     }