This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/servicecomb-pack.git
commit 849eb380ee87949d5b65700c91997e0fefa18f2e Author: CMonkey <[email protected]> AuthorDate: Fri Aug 16 16:58:41 2019 +0800 SCB-1442 check KafkaMessagePublisher msg type --- .../pack/alpha/fsm/channel/kafka/KafkaMessagePublisher.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/alpha/alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaMessagePublisher.java b/alpha/alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaMessagePublisher.java index b6a9051..ba96b56 100644 --- a/alpha/alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaMessagePublisher.java +++ b/alpha/alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaMessagePublisher.java @@ -48,11 +48,11 @@ public class KafkaMessagePublisher implements MessagePublisher { BaseEvent event = (BaseEvent) data; kafkaTemplate.send(topic, event.getGlobalTxId(), event).get(); }else{ - kafkaTemplate.send(topic, data).get(); + throw new UnsupportedOperationException("data must be BaseEvent type"); } - } catch (InterruptedException | ExecutionException e) { + } catch (InterruptedException | ExecutionException | UnsupportedOperationException e) { logger.error("publish Exception = [{}]", e.getMessage(), e); throw new RuntimeException(e); } } -} \ No newline at end of file +}
