v2.1 extended analysis render update
This commit is contained in:
@@ -26,8 +26,8 @@ dependencies {
|
||||
implementation 'org.springframework.boot:spring-boot-starter-jersey'
|
||||
|
||||
// AWS SQS/SNS
|
||||
implementation 'io.awspring.cloud:spring-cloud-aws-starter-sqs:3.1.1'
|
||||
implementation 'io.awspring.cloud:spring-cloud-aws-starter-sns:3.1.1'
|
||||
implementation 'io.awspring.cloud:spring-cloud-aws-starter-sqs:3.3.0'
|
||||
implementation 'io.awspring.cloud:spring-cloud-aws-starter-sns:3.3.0'
|
||||
|
||||
compileOnly 'org.projectlombok:lombok'
|
||||
annotationProcessor 'org.projectlombok:lombok'
|
||||
|
||||
@@ -2,7 +2,7 @@ package click.kamil.ultimate.config;
|
||||
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
import org.springframework.statemachine.config.EnableStateMachine;
|
||||
import org.springframework.statemachine.config.EnumStateMachineConfigurerAdapter;
|
||||
import org.springframework.statemachine.config.StateMachineConfigurerAdapter;
|
||||
import org.springframework.statemachine.config.builders.StateMachineStateConfigurer;
|
||||
import org.springframework.statemachine.config.builders.StateMachineTransitionConfigurer;
|
||||
|
||||
@@ -10,7 +10,7 @@ import java.util.EnumSet;
|
||||
|
||||
@Configuration
|
||||
@EnableStateMachine
|
||||
public class UltimateStateMachineConfig extends EnumStateMachineConfigurerAdapter<String, String> {
|
||||
public class UltimateStateMachineConfig extends StateMachineConfigurerAdapter<String, String> {
|
||||
|
||||
@Override
|
||||
public void configure(StateMachineStateConfigurer<String, String> states) throws Exception {
|
||||
|
||||
@@ -1,17 +0,0 @@
|
||||
package click.kamil.ultimate.messaging;
|
||||
|
||||
import io.awspring.cloud.sns.annotation.SnsListener;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import org.springframework.statemachine.StateMachine;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@Component
|
||||
@RequiredArgsConstructor
|
||||
public class SnsTicketListener {
|
||||
private final StateMachine<String, String> stateMachine;
|
||||
|
||||
@SnsListener("ticket-sns-topic")
|
||||
public void onSnsMessage(String subject, String message) {
|
||||
stateMachine.sendEvent("SNS_UPDATE");
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,21 @@
|
||||
package click.kamil.ultimate.web;
|
||||
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import org.springframework.statemachine.StateMachine;
|
||||
import org.springframework.web.bind.annotation.PostMapping;
|
||||
import org.springframework.web.bind.annotation.RequestBody;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
@RestController
|
||||
@RequestMapping("/api/sns")
|
||||
@RequiredArgsConstructor
|
||||
public class SnsWebhookController {
|
||||
private final StateMachine<String, String> stateMachine;
|
||||
|
||||
@PostMapping("/webhook")
|
||||
public void onSnsMessage(@RequestBody String message) {
|
||||
// In a real app, you'd verify the SNS signature and handle SubscriptionConfirmation
|
||||
stateMachine.sendEvent("SNS_UPDATE");
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,3 @@
|
||||
spring.cloud.aws.credentials.access-key=dummy
|
||||
spring.cloud.aws.credentials.secret-key=dummy
|
||||
spring.cloud.aws.region.static=us-east-1
|
||||
Reference in New Issue
Block a user