+public class EventBusComponent extends DefaultComponent {
+ public EventBusComponent() {
+ super();
+ }
+ public EventBusComponent(CamelContext context) {
+ super(context);
+ }
+
+ @Override
+ protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
+ Endpoint endpoint = new EventBusEndPoint(uri, this);
+ setProperties(endpoint, parameters);
+ return endpoint;
+ }