Cleanup

orkes-io · Nov 14, 2023 · 5743e74 · 5743e74
1 parent 5a0a562
commit 5743e74
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 33 deletions.
diff --git a/...uctor-queues/src/main/java/io/orkes/conductor/queue/config/ConfigurationHostSupplier.java b/...uctor-queues/src/main/java/io/orkes/conductor/queue/config/ConfigurationHostSupplier.java
@@ -34,12 +34,11 @@ public List<Host> getHosts() {
     }
 
     private List<Host> parseHostsFromConfig() {
-        System.out.println("\n\n\n\n\n\n\n\n parseHostsFromConfig" + properties.toString());
         String hosts = properties.getHosts();
         if (hosts == null) {
             // FIXME This type of validation probably doesn't belong here.
             String message =
-                    "Orkes 7 - Missing dynomite/redis hosts. Ensure 'workflow.dynomite.cluster.hosts' has been set in the supplied configuration.";
+                    "Missing dynomite/redis hosts. Ensure 'workflow.dynomite.cluster.hosts' has been set in the supplied configuration.";
             log.error(message);
             throw new RuntimeException(message);
         }

diff --git a/...-conductor-queues/src/main/java/io/orkes/conductor/queue/config/QueueRedisProperties.java b/...-conductor-queues/src/main/java/io/orkes/conductor/queue/config/QueueRedisProperties.java
@@ -291,32 +291,4 @@ public void setSsl(boolean ssl) {
         this.ssl = ssl;
     }
 
-    @Override
-    public String toString() {
-        return "QueueRedisProperties{" +
-                "conductorProperties=" + conductorProperties +
-                ", dataCenterRegion='" + dataCenterRegion + '\'' +
-                ", availabilityZone='" + availabilityZone + '\'' +
-                ", clusterName='" + clusterName + '\'' +
-                ", hosts='" + hosts + '\'' +
-                ", workflowNamespacePrefix='" + workflowNamespacePrefix + '\'' +
-                ", queueNamespacePrefix='" + queueNamespacePrefix + '\'' +
-                ", keyspaceDomain='" + keyspaceDomain + '\'' +
-                ", maxConnectionsPerHost=" + maxConnectionsPerHost +
-                ", database=" + database +
-                ", maxTimeoutWhenExhausted=" + maxTimeoutWhenExhausted +
-                ", maxRetryAttempts=" + maxRetryAttempts +
-                ", queuesNonQuorumPort=" + queuesNonQuorumPort +
-                ", taskDefCacheRefreshInterval=" + taskDefCacheRefreshInterval +
-                ", eventExecutionPersistenceTTL=" + eventExecutionPersistenceTTL +
-                ", metadataCacheRefreshInterval=" + metadataCacheRefreshInterval +
-                ", maxIdleConnections=" + maxIdleConnections +
-                ", minIdleConnections=" + minIdleConnections +
-                ", minEvictableIdleTimeMillis=" + minEvictableIdleTimeMillis +
-                ", timeBetweenEvictionRunsMillis=" + timeBetweenEvictionRunsMillis +
-                ", testWhileIdle=" + testWhileIdle +
-                ", numTestsPerEvictionRun=" + numTestsPerEvictionRun +
-                ", ssl=" + ssl +
-                '}';
-    }
 }
diff --git a/...nductor-queues/src/main/java/io/orkes/conductor/queue/config/RedisQueueConfiguration.java b/...nductor-queues/src/main/java/io/orkes/conductor/queue/config/RedisQueueConfiguration.java
@@ -19,11 +19,9 @@
 import io.orkes.conductor.queue.dao.RedisQueueDAO;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.autoconfigure.AutoConfiguration;
 import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Import;
 import org.springframework.context.annotation.Primary;
@@ -37,7 +35,6 @@
 @EnableAutoConfiguration
 @AutoConfiguration
 @Slf4j
-//@EnableConfigurationProperties(QueueRedisProperties.class)
 @Import({io.orkes.conductor.queue.config.QueueRedisProperties.class})
 public class RedisQueueConfiguration {