EndpointFactory endpointFactory = muleContext.getEndpointFactory();
EndpointBuilder endpointBuilder = endpointFactory.getEndpointBuilder(subscription);
endpointBuilder.setExchangePattern(MessageExchangePattern.fromSyncFlag(!asynchronous));
InboundEndpoint endpoint = endpointFactory.getInboundEndpoint(endpointBuilder);
messageRouter.addSource(endpoint);
}
}
DefaultJavaComponent component = new DefaultJavaComponent(new SingletonObjectFactory(this));
component.setMuleContext(muleContext);
service.setComponent(component);