| | |
|---|
| | | @ServiceActivator(inputChannel = ChannelName.INBOUND_EVENTS_FLIGHT_TASK_PROGRESS, outputChannel = ChannelName.OUTBOUND_EVENTS) |
|---|
| | | public CommonTopicReceiver handleProgress(CommonTopicReceiver receiver, MessageHeaders headers) { |
|---|
| | | log.info("上报航线任务进度: {}", receiver.toString()); |
|---|
| | | EventsReceiver<WaylineTaskProgressReceiver> eventsReceiver = mapper.convertValue(receiver.getData(), |
|---|
| | | EventsReceiver<WaylineTaskProgressReceiver> eventsReceiver = mapper.convertValue(receiver.getData(), |
|---|
| | | new TypeReference<EventsReceiver<WaylineTaskProgressReceiver>>(){}); |
|---|
| | | eventsReceiver.setBid(receiver.getBid()); |
|---|
| | | eventsReceiver.setSn(receiver.getGateway()); |
|---|
