public final class ChangeShipmentState extends UpdateActionImpl<Order>
See also OrderUpdateCommand.
withOrder(client(), order -> {
final ShipmentState newState = ShipmentState.SHIPPED;
assertThat(order.getShipmentState()).isNotEqualTo(newState);
final Order updatedOrder = client().executeBlocking(OrderUpdateCommand.of(order, ChangeShipmentState.of(newState)));
assertThat(updatedOrder.getShipmentState()).isEqualTo(newState);
//you can observe a message
final Query<OrderShipmentStateChangedMessage> messageQuery = MessageQuery.of()
.withPredicates(m -> m.resource().is(order))
.forMessageType(OrderShipmentStateChangedMessage.MESSAGE_HINT);
assertEventually(() -> {
final Optional<OrderShipmentStateChangedMessage> orderShipmentStateChangedMessageOptional =
client().executeBlocking(messageQuery).head();
assertThat(orderShipmentStateChangedMessageOptional).isPresent();
final OrderShipmentStateChangedMessage orderShipmentStateChangedMessage = orderShipmentStateChangedMessageOptional.get();
assertThat(orderShipmentStateChangedMessage.getShipmentState()).isNotNull();
});
return updatedOrder;
});
See the test code.
| Modifier and Type | Method and Description |
|---|---|
ShipmentState |
getShipmentState() |
static ChangeShipmentState |
of(ShipmentState shipmentState) |
getActionpublic static ChangeShipmentState of(ShipmentState shipmentState)
public ShipmentState getShipmentState()