@MessageEndpoint | |
class ReservationProcessor { | |
@Autowired | |
private ReservationRepository reservationRepository; | |
@ServiceActivator(inputChannel = INPUT) | |
public void acceptNewReservation(String rn) { | |
this.reservationRepository.save(new Reservation(rn)); | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment