Skip to content

Commit

Permalink
Spring support
Browse files Browse the repository at this point in the history
  • Loading branch information
jiachun.fjc committed Jun 12, 2016
1 parent c33fe3d commit c0a783d
Showing 1 changed file with 24 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -54,6 +54,8 @@ public class JupiterSpringProviderBean implements InitializingBean, ApplicationC
private int connCount;
private Executor executor;
private FlowController<JRequest> flowController;
private JServer.ProviderInitializer<?> providerInitializer;
private Executor providerInitializerExecutor;

@Override
public void afterPropertiesSet() throws Exception {
Expand Down Expand Up @@ -145,13 +147,34 @@ public void setFlowController(FlowController<JRequest> flowController) {
this.flowController = flowController;
}

public JServer.ProviderInitializer<?> getProviderInitializer() {
return providerInitializer;
}

public void setProviderInitializer(JServer.ProviderInitializer<?> providerInitializer) {
this.providerInitializer = providerInitializer;
}

public Executor getProviderInitializerExecutor() {
return providerInitializerExecutor;
}

public void setProviderInitializerExecutor(Executor providerInitializerExecutor) {
this.providerInitializerExecutor = providerInitializerExecutor;
}

private final class JupiterApplicationListener implements ApplicationListener {

@Override
public void onApplicationEvent(ApplicationEvent event) {
if (event instanceof ContextRefreshedEvent) {
// 发布服务
acceptor.getAcceptor().publish(serviceWrapper);
if (providerInitializer == null) {
acceptor.getAcceptor().publish(serviceWrapper);
} else {
acceptor.getAcceptor().publishWithInitializer(
serviceWrapper, providerInitializer, providerInitializerExecutor);
}

logger.info("#publish service: {}.", serviceWrapper);
}
Expand Down

0 comments on commit c0a783d

Please sign in to comment.