attempt to adding spring bean registry
This commit is contained in:
@@ -0,0 +1,58 @@
|
||||
package click.kamil.examples.statemachine.extended.config;
|
||||
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
import org.springframework.statemachine.config.EnableStateMachine;
|
||||
import org.springframework.statemachine.config.StateMachineConfigurerAdapter;
|
||||
import org.springframework.statemachine.config.builders.StateMachineStateConfigurer;
|
||||
import org.springframework.statemachine.config.builders.StateMachineTransitionConfigurer;
|
||||
|
||||
@Configuration
|
||||
@EnableStateMachine(name = "paymentStateMachine")
|
||||
public class PaymentStateMachineConfig extends StateMachineConfigurerAdapter<String, String> {
|
||||
|
||||
@Override
|
||||
public void configure(StateMachineStateConfigurer<String, String> states) throws Exception {
|
||||
states
|
||||
.withStates()
|
||||
.initial("NEW")
|
||||
.state("AUTHORIZED")
|
||||
.state("CAPTURED")
|
||||
.state("DECLINED")
|
||||
.state("QUIRK1")
|
||||
.state("QUIRK2")
|
||||
.state("QUIRK3")
|
||||
.state("QUIRK4");
|
||||
}
|
||||
|
||||
@Override
|
||||
public void configure(StateMachineTransitionConfigurer<String, String> transitions) throws Exception {
|
||||
transitions
|
||||
.withExternal()
|
||||
.source("NEW").target("AUTHORIZED")
|
||||
.event("AUTHORIZE")
|
||||
.and()
|
||||
.withExternal()
|
||||
.source("AUTHORIZED").target("CAPTURED")
|
||||
.event("CAPTURE")
|
||||
.and()
|
||||
.withExternal()
|
||||
.source("NEW").target("DECLINED")
|
||||
.event("DECLINE")
|
||||
.and()
|
||||
.withExternal()
|
||||
.source("NEW").target("QUIRK1")
|
||||
.event("PRIMARY_EVENT")
|
||||
.and()
|
||||
.withExternal()
|
||||
.source("NEW").target("QUIRK2")
|
||||
.event("NAMED_EVENT")
|
||||
.and()
|
||||
.withExternal()
|
||||
.source("NEW").target("QUIRK3")
|
||||
.event("QUALIFIER_EVENT")
|
||||
.and()
|
||||
.withExternal()
|
||||
.source("NEW").target("QUIRK4")
|
||||
.event("FALLBACK_EVENT");
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,19 @@
|
||||
package click.kamil.examples.statemachine.extended.service;
|
||||
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.beans.factory.annotation.Qualifier;
|
||||
import org.springframework.statemachine.StateMachine;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
@Service
|
||||
public class FallbackQuirkService implements QuirkService {
|
||||
|
||||
@Autowired
|
||||
@Qualifier("paymentStateMachine")
|
||||
private StateMachine<String, String> stateMachine;
|
||||
|
||||
@Override
|
||||
public void doQuirk() {
|
||||
stateMachine.sendEvent("FALLBACK_EVENT");
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,19 @@
|
||||
package click.kamil.examples.statemachine.extended.service;
|
||||
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.beans.factory.annotation.Qualifier;
|
||||
import org.springframework.statemachine.StateMachine;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
@Service("customName")
|
||||
public class NamedQuirkService implements QuirkService {
|
||||
|
||||
@Autowired
|
||||
@Qualifier("paymentStateMachine")
|
||||
private StateMachine<String, String> stateMachine;
|
||||
|
||||
@Override
|
||||
public void doQuirk() {
|
||||
stateMachine.sendEvent("NAMED_EVENT");
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,6 @@
|
||||
package click.kamil.examples.statemachine.extended.service;
|
||||
|
||||
public interface PaymentService {
|
||||
void processPayment(String paymentId);
|
||||
void capturePayment(String paymentId);
|
||||
}
|
||||
@@ -0,0 +1,37 @@
|
||||
package click.kamil.examples.statemachine.extended.service;
|
||||
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.beans.factory.annotation.Qualifier;
|
||||
import org.springframework.statemachine.StateMachine;
|
||||
import org.springframework.statemachine.persist.StateMachinePersister;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
@Service
|
||||
public class PaymentServiceImpl implements PaymentService {
|
||||
|
||||
@Autowired
|
||||
@Qualifier("paymentStateMachine")
|
||||
private StateMachine<String, String> stateMachine;
|
||||
|
||||
@Autowired
|
||||
private StateMachinePersister<String, String, String> persister;
|
||||
|
||||
@Override
|
||||
public void processPayment(String paymentId) {
|
||||
// Send a trigger mapped strictly to PaymentStateMachineConfig
|
||||
stateMachine.sendEvent("AUTHORIZE");
|
||||
}
|
||||
|
||||
@Override
|
||||
public void capturePayment(String paymentId) {
|
||||
try {
|
||||
persister.restore(stateMachine, paymentId);
|
||||
} catch (Exception e) {}
|
||||
|
||||
org.springframework.messaging.Message<String> msg = org.springframework.messaging.support.MessageBuilder
|
||||
.withPayload("CAPTURE")
|
||||
.setHeader("paymentId", paymentId)
|
||||
.build();
|
||||
stateMachine.sendEvent(msg);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,21 @@
|
||||
package click.kamil.examples.statemachine.extended.service;
|
||||
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.beans.factory.annotation.Qualifier;
|
||||
import org.springframework.context.annotation.Primary;
|
||||
import org.springframework.statemachine.StateMachine;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
@Service
|
||||
@Primary
|
||||
public class PrimaryQuirkService implements QuirkService {
|
||||
|
||||
@Autowired
|
||||
@Qualifier("paymentStateMachine")
|
||||
private StateMachine<String, String> stateMachine;
|
||||
|
||||
@Override
|
||||
public void doQuirk() {
|
||||
stateMachine.sendEvent("PRIMARY_EVENT");
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,21 @@
|
||||
package click.kamil.examples.statemachine.extended.service;
|
||||
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.beans.factory.annotation.Qualifier;
|
||||
import org.springframework.context.annotation.Profile;
|
||||
import org.springframework.statemachine.StateMachine;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
@Service
|
||||
@Profile("nonexistent")
|
||||
public class ProfiledQuirkService implements QuirkService {
|
||||
|
||||
@Autowired
|
||||
@Qualifier("paymentStateMachine")
|
||||
private StateMachine<String, String> stateMachine;
|
||||
|
||||
@Override
|
||||
public void doQuirk() {
|
||||
stateMachine.sendEvent("PROFILED_EVENT");
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,19 @@
|
||||
package click.kamil.examples.statemachine.extended.service;
|
||||
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.beans.factory.annotation.Qualifier;
|
||||
import org.springframework.statemachine.StateMachine;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
@Service
|
||||
public class QualifierQuirkService implements QuirkService {
|
||||
|
||||
@Autowired
|
||||
@Qualifier("paymentStateMachine")
|
||||
private StateMachine<String, String> stateMachine;
|
||||
|
||||
@Override
|
||||
public void doQuirk() {
|
||||
stateMachine.sendEvent("QUALIFIER_EVENT");
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,5 @@
|
||||
package click.kamil.examples.statemachine.extended.service;
|
||||
|
||||
public interface QuirkService {
|
||||
void doQuirk();
|
||||
}
|
||||
@@ -0,0 +1,10 @@
|
||||
package click.kamil.examples.statemachine.extended.web;
|
||||
|
||||
import org.springframework.web.bind.annotation.GetMapping;
|
||||
import org.springframework.web.bind.annotation.PathVariable;
|
||||
|
||||
public interface BaseController {
|
||||
|
||||
@GetMapping("/api/base/{id}")
|
||||
String processBaseEndpoint(@PathVariable String id);
|
||||
}
|
||||
@@ -0,0 +1,28 @@
|
||||
package click.kamil.examples.statemachine.extended.web;
|
||||
|
||||
import click.kamil.examples.statemachine.extended.service.PaymentService;
|
||||
import org.springframework.web.bind.annotation.PostMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
import org.springframework.web.bind.annotation.PathVariable;
|
||||
|
||||
@RestController
|
||||
public class PaymentController implements BaseController {
|
||||
|
||||
private final PaymentService paymentService;
|
||||
|
||||
public PaymentController(PaymentService paymentService) {
|
||||
this.paymentService = paymentService;
|
||||
}
|
||||
|
||||
@Override
|
||||
public String processBaseEndpoint(@PathVariable String id) {
|
||||
paymentService.processPayment(id);
|
||||
return "Started Base Payment: " + id;
|
||||
}
|
||||
|
||||
@PostMapping("/api/payment/{id}/capture")
|
||||
public String capturePaymentEndpoint(@PathVariable String id) {
|
||||
paymentService.capturePayment(id);
|
||||
return "Captured: " + id;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,45 @@
|
||||
package click.kamil.examples.statemachine.extended.web;
|
||||
|
||||
import click.kamil.examples.statemachine.extended.service.QuirkService;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.beans.factory.annotation.Qualifier;
|
||||
import org.springframework.web.bind.annotation.PostMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
@RestController
|
||||
public class QuirkController {
|
||||
|
||||
@Autowired
|
||||
private QuirkService quirkService; // Should resolve to PrimaryQuirkService
|
||||
|
||||
@Autowired
|
||||
@Qualifier("customName")
|
||||
private QuirkService someService; // Should resolve to NamedQuirkService
|
||||
|
||||
@Autowired
|
||||
@Qualifier("qualifierQuirkService")
|
||||
private QuirkService anotherService; // Should resolve to QualifierQuirkService
|
||||
|
||||
@Autowired
|
||||
private QuirkService fallbackQuirkService; // Should resolve to FallbackQuirkService
|
||||
|
||||
@PostMapping("/api/quirk/primary")
|
||||
public void testPrimary() {
|
||||
quirkService.doQuirk();
|
||||
}
|
||||
|
||||
@PostMapping("/api/quirk/named")
|
||||
public void testNamed() {
|
||||
someService.doQuirk();
|
||||
}
|
||||
|
||||
@PostMapping("/api/quirk/qualifier")
|
||||
public void testQualifier() {
|
||||
anotherService.doQuirk();
|
||||
}
|
||||
|
||||
@PostMapping("/api/quirk/fallback")
|
||||
public void testFallback() {
|
||||
fallbackQuirkService.doQuirk();
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user