♻️ refactor: update codebase #4

plugin/src/main/groovy/org/rmq4j/service/Rmq4jInsService.java

@@ -0,0 +1,4 @@
+package org.rmq4j.service;
+
+public interface Rmq4jInsService {
+}

plugin/src/main/groovy/org/rmq4j/service/Rmq4jService.java

@@ -3,6 +3,7 @@
 import com.rabbitmq.client.ConnectionFactory;
 import org.rmq4j.config.props.Rmq4jProperties;
 import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
+import org.springframework.amqp.rabbit.core.RabbitAdmin;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 
 import java.util.Optional;
@@ -23,5 +24,7 @@ public interface Rmq4jService {
 
     Optional<RabbitTemplate> dispatch(Rmq4jProperties.Node node);
 
+    Optional<RabbitAdmin> createAdm(Rmq4jProperties.Node node);
+
     String getURLConnSchema(Rmq4jProperties.Node node);
 }

plugin/src/main/groovy/org/rmq4j/service/impl/Rmq4jInsServiceImpl.java

@@ -0,0 +1,21 @@
+package org.rmq4j.service.impl;
+
+import org.rmq4j.service.Rmq4jInsService;
+import org.rmq4j.service.Rmq4jService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@SuppressWarnings({"FieldCanBeLocal", "DuplicatedCode"})
+@Service
+public class Rmq4jInsServiceImpl implements Rmq4jInsService {
+    protected static final Logger logger = LoggerFactory.getLogger(Rmq4jInsServiceImpl.class);
+
+    protected final Rmq4jService rmq4jService;
+
+    @Autowired
+    public Rmq4jInsServiceImpl(Rmq4jService rmq4jService) {
+        this.rmq4jService = rmq4jService;
+    }
+}

plugin/src/main/groovy/org/rmq4j/service/impl/Rmq4jServiceImpl.java

@@ -6,6 +6,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
+import org.springframework.amqp.rabbit.core.RabbitAdmin;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -175,6 +176,31 @@ public Optional<RabbitTemplate> dispatch(Rmq4jProperties.Node node) {
         return Optional.of(new RabbitTemplate(factory.get()));
     }
 
+    /**
+     * Creates a {@link RabbitAdmin} for RabbitMQ based on the provided cluster configuration.
+     * <p>
+     * This method first uses {@link #createCacheConnFactory(Rmq4jProperties.Node)} to create a
+     * {@link CachingConnectionFactory} from the given cluster configuration. If the creation of the
+     * {@link CachingConnectionFactory} is successful, it wraps the factory in a {@link RabbitAdmin}
+     * and returns it as an {@link Optional}.
+     * <p>
+     * If the {@link CachingConnectionFactory} could not be created (e.g., due to invalid configuration),
+     * it returns an empty {@link Optional}.
+     *
+     * @param node The cluster configuration used to create the {@link CachingConnectionFactory}.
+     * @return An {@link Optional} containing the {@link RabbitAdmin} if the {@link CachingConnectionFactory}
+     * was created successfully; otherwise, an empty {@link Optional}.
+     */
+    @SuppressWarnings({"OptionalIsPresent"})
+    @Override
+    public Optional<RabbitAdmin> createAdm(Rmq4jProperties.Node node) {
+        Optional<CachingConnectionFactory> factory = this.createCacheConnFactory(node);
+        if (!factory.isPresent()) {
+            return Optional.empty();
+        }
+        return Optional.of(new RabbitAdmin(factory.get()));
+    }
+
     /**
      * Generates the connection URL schema for RabbitMQ based on the provided cluster configuration.
      * <p>