Skip to content

Commit f4e484f

Browse files
committed
fix event stream sender bug
1 parent 8d9c3dc commit f4e484f

File tree

1 file changed

+2
-2
lines changed
  • spring-cloud-gray-server-plugins/spring-cloud-gray-server-plugin-event-stream/src/main/java/cn/springcloud/gray/server/event/stream

1 file changed

+2
-2
lines changed

spring-cloud-gray-server-plugins/spring-cloud-gray-server-plugin-event-stream/src/main/java/cn/springcloud/gray/server/event/stream/GrayEventStreamSender.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,10 +24,10 @@ public GrayEventStreamSender(StreamOutput sender) {
2424

2525
@Override
2626
public void send(GrayEvent grayEvent) {
27-
executorService.schedule(() -> send(grayEvent), 100, TimeUnit.MILLISECONDS);
27+
executorService.schedule(() -> sendMsg(grayEvent), 100, TimeUnit.MILLISECONDS);
2828
}
2929

30-
public boolean send(Object obj) {
30+
public boolean sendMsg(Object obj) {
3131
return sender.output().send(MessageBuilder.withPayload(obj).build());
3232
}
3333
}

0 commit comments

Comments
 (0)