diff --git a/api/src/main/java/io/github/pavansharma36/workflow/api/adapter/base/BaseAdapter.java b/api/src/main/java/io/github/pavansharma36/workflow/api/adapter/base/BaseAdapter.java index 53490fc..f2f1fa4 100644 --- a/api/src/main/java/io/github/pavansharma36/workflow/api/adapter/base/BaseAdapter.java +++ b/api/src/main/java/io/github/pavansharma36/workflow/api/adapter/base/BaseAdapter.java @@ -1,7 +1,6 @@ package io.github.pavansharma36.workflow.api.adapter.base; import io.github.pavansharma36.workflow.api.adapter.Adapter; -import io.github.pavansharma36.workflow.api.serde.Serde; import io.github.pavansharma36.workflow.api.util.PollDelayGenerator; import lombok.AccessLevel; import lombok.RequiredArgsConstructor; diff --git a/api/src/main/java/io/github/pavansharma36/workflow/api/adapter/base/BasePersistenceAdapter.java b/api/src/main/java/io/github/pavansharma36/workflow/api/adapter/base/BasePersistenceAdapter.java index 24babf0..8c62ccc 100644 --- a/api/src/main/java/io/github/pavansharma36/workflow/api/adapter/base/BasePersistenceAdapter.java +++ b/api/src/main/java/io/github/pavansharma36/workflow/api/adapter/base/BasePersistenceAdapter.java @@ -3,9 +3,6 @@ import io.github.pavansharma36.workflow.api.adapter.PersistenceAdapter; import io.github.pavansharma36.workflow.api.adapter.WorkflowAdapter; import io.github.pavansharma36.workflow.api.model.ManagerInfo; -import io.github.pavansharma36.workflow.api.serde.Deserializer; -import io.github.pavansharma36.workflow.api.serde.Serde; -import io.github.pavansharma36.workflow.api.serde.Serializer; import io.github.pavansharma36.workflow.api.util.PollDelayGenerator; import java.util.Date; import java.util.List; diff --git a/api/src/main/java/io/github/pavansharma36/workflow/api/adapter/builder/BaseAdapterBuilder.java b/api/src/main/java/io/github/pavansharma36/workflow/api/adapter/builder/BaseAdapterBuilder.java index 15f18dd..448f029 100644 --- a/api/src/main/java/io/github/pavansharma36/workflow/api/adapter/builder/BaseAdapterBuilder.java +++ b/api/src/main/java/io/github/pavansharma36/workflow/api/adapter/builder/BaseAdapterBuilder.java @@ -1,8 +1,8 @@ package io.github.pavansharma36.workflow.api.adapter.builder; import io.github.pavansharma36.workflow.api.adapter.Adapter; -import io.github.pavansharma36.workflow.api.serde.jackson.JacksonSerde; import io.github.pavansharma36.workflow.api.serde.Serde; +import io.github.pavansharma36.workflow.api.serde.jackson.JacksonSerde; import io.github.pavansharma36.workflow.api.util.FixedPollDelayGenerator; import io.github.pavansharma36.workflow.api.util.PollDelayGenerator; import io.github.pavansharma36.workflow.api.util.WorkflowException; diff --git a/jedis/src/main/java/io/github/pavansharma36/workflow/jedis/adapter/builder/JedisWorkflowAdapterBuilder.java b/jedis/src/main/java/io/github/pavansharma36/workflow/jedis/adapter/builder/JedisWorkflowAdapterBuilder.java index 11f8fb7..513fcb1 100644 --- a/jedis/src/main/java/io/github/pavansharma36/workflow/jedis/adapter/builder/JedisWorkflowAdapterBuilder.java +++ b/jedis/src/main/java/io/github/pavansharma36/workflow/jedis/adapter/builder/JedisWorkflowAdapterBuilder.java @@ -2,8 +2,8 @@ import io.github.pavansharma36.workflow.api.adapter.WorkflowAdapter; import io.github.pavansharma36.workflow.api.adapter.builder.WorkflowAdapterBuilder; -import io.github.pavansharma36.workflow.api.serde.jackson.JacksonSerde; import io.github.pavansharma36.workflow.api.serde.Serde; +import io.github.pavansharma36.workflow.api.serde.jackson.JacksonSerde; import lombok.AccessLevel; import lombok.NoArgsConstructor; import redis.clients.jedis.JedisPool; diff --git a/mongodb/src/main/java/io/github/pavansharma36/workflow/mongodb/migration/PersistenceMigration.java b/mongodb/src/main/java/io/github/pavansharma36/workflow/mongodb/migration/PersistenceMigration.java index 2c06921..392cdfe 100644 --- a/mongodb/src/main/java/io/github/pavansharma36/workflow/mongodb/migration/PersistenceMigration.java +++ b/mongodb/src/main/java/io/github/pavansharma36/workflow/mongodb/migration/PersistenceMigration.java @@ -12,6 +12,9 @@ import org.bson.BsonInt32; import org.bson.Document; +/** + * migration to create indexes in mongo for mongopersistenceadapter. + */ @RequiredArgsConstructor public class PersistenceMigration implements Runnable { @@ -46,13 +49,11 @@ private void managerInfo() { private void taskInfo() { List indexes = new LinkedList<>(); - indexes.add(new IndexModel(new BsonDocument().append(MongoDbQueryHelper.TaskInfo.RUN_ID_KEY, - new BsonInt32(1)), - new IndexOptions().background(true).name("task_info_run_id_idx"))); - indexes.add(new IndexModel(new BsonDocument().append(MongoDbQueryHelper.TaskInfo.RUN_ID_KEY, - new BsonInt32(1)) + indexes.add(new IndexModel(new BsonDocument().append( + MongoDbQueryHelper.TaskInfo.RUN_ID_KEY, new BsonInt32(1)) .append(MongoDbQueryHelper.TaskInfo.TASK_ID_KEY, new BsonInt32(1)), - new IndexOptions().background(true).name("task_info_run_id_task_id_unique_idx").unique(true))); + new IndexOptions().background(true) + .name("task_info_run_id_task_id_unique_idx").unique(true))); collection(MongoDbQueryHelper.TaskInfo.collectionName(namespace)) .createIndexes(indexes);