这是indexloc提供的服务，不要输入任何密码
Skip to content

Extract mq common as library #156

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 1 commit into from
Jul 21, 2021
Merged

Extract mq common as library #156

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 0 additions & 15 deletions src/functionalTest/java/co/com/bancolombia/PluginCleanFunctionalTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -870,7 +870,6 @@ public void shouldGenerateMQEntryPoint() {
new File(
"build/functionalTest/infrastructure/entry-points/mq-listener/src/main/java/co/com/bancolombia/mq/listener/SampleMQMessageListener.java")
.exists());
validateMQCommon();
assertEquals(result.task(":" + task).getOutcome(), TaskOutcome.SUCCESS);
}

Expand All @@ -891,23 +890,9 @@ public void shouldGenerateMQDrivenAdapter() {
new File(
"build/functionalTest/infrastructure/driven-adapters/mq-sender/src/main/java/co/com/bancolombia/mq/sender/SampleMQMessageSender.java")
.exists());
validateMQCommon();
assertEquals(result.task(":" + task).getOutcome(), TaskOutcome.SUCCESS);
}

private void validateMQCommon() {
assertTrue(
new File("build/functionalTest/infrastructure/helpers/mq-common/build.gradle").exists());
assertTrue(
new File(
"build/functionalTest/infrastructure/helpers/mq-common/src/main/java/co/com/bancolombia/mq/common/MQReactiveMessageListener.java")
.exists());
assertTrue(
new File(
"build/functionalTest/infrastructure/helpers/mq-common/src/main/java/co/com/bancolombia/mq/common/api/MQMessageSender.java")
.exists());
}

private void writeString(File file, String string) throws IOException {
try (Writer writer = new FileWriter(file)) {
writer.write(string);
Expand Down
2 changes: 1 addition & 1 deletion src/main/java/co/com/bancolombia/Constants.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ public class Constants {
public static final String GRADLE_WRAPPER_VERSION = "6.7";
public static final String TOMCAT_EXCLUSION =
"compile.exclude group: \"org.springframework.boot\", module:\"spring-boot-starter-tomcat\"";
public static final String MQ_CLIENT_VERSION = "2.5.0";
public static final String COMMONS_JMS_VERSION = "0.0.1";

public enum BooleanOption {
TRUE,
Expand Down
2 changes: 1 addition & 1 deletion src/main/java/co/com/bancolombia/factory/ModuleBuilder.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ public ModuleBuilder(Project project) {
params.put("objectMapperVersion", Constants.RCOMMONS_OBJECT_MAPPER_VERSION);
params.put("coberturaVersion", Constants.COBERTURA_VERSION);
params.put("lombokVersion", Constants.LOMBOK_VERSION);
params.put("mqVersion", Constants.MQ_CLIENT_VERSION);
params.put("commonsJmsVersion", Constants.COMMONS_JMS_VERSION);
try {
loadPackage();
} catch (IOException e) {
Expand Down
2 changes: 0 additions & 2 deletions src/main/java/co/com/bancolombia/factory/adapters/DrivenAdapterKms.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,10 +4,8 @@
import co.com.bancolombia.factory.ModuleBuilder;
import co.com.bancolombia.factory.ModuleFactory;
import java.io.IOException;
import lombok.AllArgsConstructor;
import org.gradle.api.logging.Logger;

@AllArgsConstructor
public class DrivenAdapterKms implements ModuleFactory {

@Override
Expand Down
12 changes: 8 additions & 4 deletions src/main/java/co/com/bancolombia/factory/adapters/DrivenAdapterMQ.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,12 +3,9 @@
import co.com.bancolombia.exceptions.CleanException;
import co.com.bancolombia.factory.ModuleBuilder;
import co.com.bancolombia.factory.ModuleFactory;
import co.com.bancolombia.factory.commons.MQCommonFactory;
import co.com.bancolombia.factory.validations.ReactiveTypeValidation;
import java.io.IOException;
import lombok.AllArgsConstructor;

@AllArgsConstructor
public class DrivenAdapterMQ implements ModuleFactory {

@Override
Expand All @@ -17,6 +14,13 @@ public void buildModule(ModuleBuilder builder) throws IOException, CleanExceptio
builder.setupFromTemplate("driven-adapter/mq-sender");
builder.appendToSettings("mq-sender", "infrastructure/driven-adapters");
builder.appendDependencyToModule("app-service", "implementation project(':mq-sender')");
new MQCommonFactory().buildModule(builder);

builder
.appendToProperties("commons.jms")
.put("output-concurrency", 10)
.put("output-queue", "DEV.QUEUE.1")
.put("producer-ttl", 0)
.put("reactive", builder.isReactive());
builder.appendToProperties("ibm.mq").put("channel", "DEV.APP.SVRCONN").put("user", "app");
}
}
2 changes: 0 additions & 2 deletions src/main/java/co/com/bancolombia/factory/adapters/DrivenAdapterRedis.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,8 @@
import co.com.bancolombia.factory.ModuleFactory;
import co.com.bancolombia.factory.commons.ObjectMapperFactory;
import java.io.IOException;
import lombok.AllArgsConstructor;
import org.gradle.api.logging.Logger;

@AllArgsConstructor
public class DrivenAdapterRedis implements ModuleFactory {
public static final String PARAM_MODE = "task-param-mode";

Expand Down
2 changes: 0 additions & 2 deletions src/main/java/co/com/bancolombia/factory/adapters/DrivenAdapterS3.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,10 +4,8 @@
import co.com.bancolombia.factory.ModuleBuilder;
import co.com.bancolombia.factory.ModuleFactory;
import java.io.IOException;
import lombok.AllArgsConstructor;
import org.gradle.api.logging.Logger;

@AllArgsConstructor
public class DrivenAdapterS3 implements ModuleFactory {

@Override
Expand Down
22 changes: 0 additions & 22 deletions src/main/java/co/com/bancolombia/factory/commons/MQCommonFactory.java
View file
Open in desktop

This file was deleted.

10 changes: 8 additions & 2 deletions src/main/java/co/com/bancolombia/factory/entrypoints/EntryPointMQ.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@
import co.com.bancolombia.exceptions.CleanException;
import co.com.bancolombia.factory.ModuleBuilder;
import co.com.bancolombia.factory.ModuleFactory;
import co.com.bancolombia.factory.commons.MQCommonFactory;
import co.com.bancolombia.factory.validations.ReactiveTypeValidation;
import java.io.IOException;

Expand All @@ -15,6 +14,13 @@ public void buildModule(ModuleBuilder builder) throws IOException, CleanExceptio
builder.setupFromTemplate("entry-point/mq-listener");
builder.appendToSettings("mq-listener", "infrastructure/entry-points");
builder.appendDependencyToModule("app-service", "implementation project(':mq-listener')");
new MQCommonFactory().buildModule(builder);

builder
.appendToProperties("commons.jms")
.put("input-concurrency", 10)
.put("input-queue", "DEV.QUEUE.2")
.put("input-queue-alias", "")
.put("reactive", builder.isReactive());
builder.appendToProperties("ibm.mq").put("channel", "DEV.APP.SVRCONN").put("user", "app");
}
}
8 changes: 0 additions & 8 deletions src/main/resources/commons/mq-common/api/mq-destination-provider.java.mustache
View file
Open in desktop

This file was deleted.

9 changes: 0 additions & 9 deletions src/main/resources/commons/mq-common/api/mq-message-creator.java.mustache
View file
Open in desktop

This file was deleted.

11 changes: 0 additions & 11 deletions src/main/resources/commons/mq-common/api/mq-message-sender.java.mustache
View file
Open in desktop

This file was deleted.

9 changes: 0 additions & 9 deletions src/main/resources/commons/mq-common/api/mq-temporary-queues-container.java.mustache
View file
Open in desktop

This file was deleted.

4 changes: 0 additions & 4 deletions src/main/resources/commons/mq-common/build.gradle.mustache
View file
Open in desktop

This file was deleted.

7 changes: 0 additions & 7 deletions ...ain/resources/commons/mq-common/config/exceptions/mq-invalid-listener-setup.java.mustache
View file
Open in desktop

This file was deleted.

134 changes: 0 additions & 134 deletions src/main/resources/commons/mq-common/config/mq-listener-annotation-processor.java.mustache
View file
Open in desktop

This file was deleted.

Loading