New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
CAMEL-10178: Google PubSub Component #1267
Conversation
* PubSub Endpoint Definition | ||
*/ | ||
@UriEndpoint(scheme = "google-pubsub", title = "Google Pubsub", | ||
syntax = "google-pubsub:projectId:destinationName?[options]", label = "messaging") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The syntax should be without [options]. Those are implied.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thank you. Done.
@UriParam(name = "loggerId", description = "Logger ID to use when a match to the parent route required") | ||
private String loggerId; | ||
|
||
@UriParam(name = "concurrentConsumers", description = "The number of parallel streams consuming from the subscription") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
You need to set defaultValue in the @UriParam
to 1 so its the same as the field value
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Done for both params.
@UriParam(name = "connectionFactory", description = "ConnectionFactory to obtain connection to PubSub Service. If non provided the default one will be used") | ||
private GooglePubsubConnectionFactory connectionFactory; | ||
|
||
@UriParam(defaultValue = "AUTO", enums = "AUTO, NONE", |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
There should not be space in the enums
attribute, eg AUTO,NONE
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Done.
@davsclaus Once again - thank you. Anything else? |
Seems good. I think @oscerd and others have helped you review recently. So I will let them merge the PR. |
import org.slf4j.Logger; | ||
import org.slf4j.LoggerFactory; | ||
|
||
/** |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Ah yeah javadoc on endpoint become the component description AFAIR in the generated docs. So please updated this. eg its used for the description summary at https://github.com/apache/camel/tree/master/components#components
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Gladly. What would the component to demonstrate a good example of such doco?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thank you. Done.
Thanks the PR has been merged. I had to fix a little thing here: Can you close the PR? Many thanks! |
ENTESB-12630 - Upgrade Infinispan to version 9.4.16.Final-redhat-00003
Google PubSub component with producer and consumer endpoints, unit and integration tests.