发件箱Quarkus扩展

<依赖> < groupId > io.debez开云体育官方注册网址ium < / groupId > < artifactId > debezium-quarkus-outbox < / artifactId > <版本> tripwire。最后< /版本> < /依赖>

公共类OrderCreatedEvent实现ExportedEvent <字符串,JsonNode >{私有静态最终字符串类型=“秩序”;私有静态最终字符串EVENT_TYPE =“OrderCreated”;私人最终长orderId;私人最终JsonNode JsonNode;私人最后即时时间戳;公共OrderCreatedEvent(即时createdAt订单顺序){。orderId = order.getId ();这一点。时间戳= createdAt;这一点。jsonNode = convertToJson(秩序); } @Override public String getAggregateId() { return String.valueOf(orderId); } @Override public String getAggregateType() { return TYPE; } @Override public JsonNode getPayload() { return jsonNode; } @Override public String getType() { return EVENT_TYPE; } @Override public Instant getTimestamp() { return timestamp; } @Override public Map getAdditionalFieldValues() { // no additional fields return Collections.emptyMap(); } }

@ApplicationScoped公开课OrderService {@ inject OrderRepository OrderRepository;@ inject事件< ExportedEvent < ?,? > >事件;@ transactional公共秩序addOrder(订单顺序){= orderRepository.save顺序(顺序);事件。火(新OrderCreatedEvent (Instant.now(),顺序));返回订单;}}

<依赖> < groupId > io.debez开云体育官方注册网址ium < / groupId > < artifactId > debezium-quarkus-outbox-reactive < / artifactId > <版本> tripwire。最后< /版本> < /依赖>

@ApplicationScoped公开课OrderService {@ inject DebeziumOut开云体育官方注册网址boxHandler DebeziumOutboxHandler;@ inject OrderRepository OrderRepository;@ inject事件< ExportedEvent < ?,? > >事件;@ReactiveTransactional公立大学<订单> addOrder(订单订单){返回orderRepository.persistAndFlush(秩序)打电话给(debeziumOutboxHandler。开云体育官方注册网址persistToOutbox(新OrderCreatedEvent (Instant.now(),顺序)));}}

<字段>:< field-java-type > [: < field-column-definition > [: < field-jpa-attribute-converter >]]

quarkus.开云体育官方注册网址debezium-outbox.additional-fields = customer_name:字符串:varchar (100): example.UpperCase

公共类OrderCreatedEvent实现ExportedEvent <字符串,JsonNode > {…@Override公共地图<字符串、对象> getAdditionalFieldValues(){返回集合。singletonMap (“customer_name”、“Acme商品”);}}