-
Notifications
You must be signed in to change notification settings - Fork 0
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
updated to use gateway framework 2.0 #11
Conversation
@@ -0,0 +1,16 @@ | |||
<component name="ProjectRunConfigurationManager"> |
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.
Should this be committed?
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.
I think its fine. Makes it easier to run in IDE.
* | ||
* @author DiffusionData Ltd | ||
*/ | ||
public final class SimpleJSONToCsvStringConvertor | ||
implements OutboundPayloadConvertor<String, JSON> { | ||
public final class SimpleJSONToCsvStringConverter |
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.
"JSON" or "Json"? The class name uses "Csv" for "CSV". I prefer Json mixed-case ;-)
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.
All caps types JSON/INT64 etcs is used across framework and else where to specify Diffusion topic types.
@@ -0,0 +1,16 @@ | |||
<component name="ProjectRunConfigurationManager"> |
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.
Should this be committed?
@@ -96,7 +97,7 @@ public SourceServiceProperties getSourceServiceProperties() throws InvalidConfig | |||
return | |||
newSourceServicePropertiesBuilder() | |||
.updateMode(UpdateMode.STREAMING) | |||
.payloadConvertorName("$CSV_to_JSON") | |||
.payloadConverter("$CSV_to_JSON") |
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.
This one seems to still have the dollar prefix, but the JSON_TO_CSV doesn't.
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.
all framework provided converters have dollar prefixes and customs one created in application do not.
dad98fe
to
871e609
Compare
871e609
to
5aab011
Compare
5aab011
to
e312289
Compare
No description provided.