Skip to content

Commit

Permalink
Remove comments
Browse files Browse the repository at this point in the history
  • Loading branch information
jonnyz32 committed Oct 16, 2024
1 parent ae60c39 commit 9b6ab1b
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -79,8 +79,7 @@ public synchronized Map<String, ManzanRoute> getRoutes(CamelContext context) {
case "google-pubsub":
final String projectId = getRequiredString(name, "projectId");
final String topicName = getRequiredString(name, "topicName");
final String serviceAccountKey = getRequiredString(name, "serviceAccountKey");
ret.put(name, new GooglePubSubDestination(context, name, projectId, topicName, serviceAccountKey, format, getUriAndHeaderParameters(name, sectionObj, "projectId", "topicName", "serviceAccountKey")));
ret.put(name, new GooglePubSubDestination(context, name, projectId, topicName, format, componentOptions, getUriAndHeaderParameters(name, sectionObj, "projectId", "topicName")));
break;
case "file":
final String file = getRequiredString(name, "file");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,10 +12,9 @@
import com.github.theprez.manzan.routes.ManzanGenericCamelRoute;

public class GooglePubSubDestination extends ManzanGenericCamelRoute {
public GooglePubSubDestination(CamelContext context, final String _name, final String _projectId, final String _topicName, final String _serviceAccountKey, final String _format, final Map<String, String> _uriParams) {
super(_name, "google-pubsub", _projectId + ":" + _topicName, _format, _uriParams, null);
GooglePubsubComponent pubsub = context.getComponent("google-pubsub", GooglePubsubComponent.class);
pubsub.setServiceAccountKey(_serviceAccountKey);
public GooglePubSubDestination(final CamelContext _context, final String _name, final String _projectId, final String _topicName, final String _format, final Map<String, String> _componentOptions, final Map<String, String> _uriParams) {
super(_context, _name, "google-pubsub", _projectId + ":" + _topicName, _format, _uriParams, null, _componentOptions);
GooglePubsubComponent pubsub = _context.getComponent("google-pubsub", GooglePubsubComponent.class);
pubsub.init();
pubsub.start();
}
Expand Down

0 comments on commit 9b6ab1b

Please sign in to comment.