Made changes to create a new channel when it is closed while publishing (#263)

Co-authored-by: Vishnu <vishnu.alapati@ericsson.com>

Author: vishnu-alapati

CHANGELOG.md

@@ -1,6 +1,7 @@
 ## 2.0.28
 - Made changes to override AMQP Basic properties.
 - Swagger don't display default status codes
+- Made changes to create a new RabbitMQ Channel when it is closed in the middle of publishing.
 
 ## 2.0.27
 - Degraded the spring-boot-maven-plugin version to 2.7.5

publish-common/src/main/java/com/ericsson/eiffel/remrem/publish/helper/RabbitMqProperties.java

@@ -540,7 +540,20 @@ private Channel giveMeRandomChannel() throws RemRemPublishException {
         if ((rabbitConnection == null || !rabbitConnection.isOpen())) {
             createRabbitMqConnection();
         }
-        return rabbitChannels.get(random.nextInt(rabbitChannels.size()));
+        for (Channel channel : rabbitChannels) {
+            if (channel.isOpen()) {
+                return channel;
+            }
+        }
+        try {
+            Channel channel = rabbitConnection.createChannel();
+            channel.confirmSelect();
+            rabbitChannels.add(channel);
+            return channel;
+        } catch (IOException e) {
+            log.error(e.getMessage(), e);
+            throw new RemRemPublishException("Failed to create new channel for Rabbitmq :: ",
+                    factory, e);
+        }
     }
-
 }