Added data publishing capability from accelerators on APIM,IS to SI #879
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -559,4 +559,117 @@ | |
| {% endif %} | ||
| </Security> | ||
| </ExtensionsEndpoint> | ||
| <Event> | ||
| {% if financial_services.event.queue_size is defined %} | ||
| <QueueSize>{{financial_services.event.queue_size}}</QueueSize> | ||
| {% else %} | ||
| <QueueSize>32768</QueueSize> | ||
| {% endif %} | ||
| {% if financial_services.event.worker_thread_count is defined %} | ||
| <WorkerThreadCount>{{financial_services.event.worker_thread_count}}</WorkerThreadCount> | ||
| {% else %} | ||
| <WorkerThreadCount>10</WorkerThreadCount> | ||
| {% endif %} | ||
| <EventExecutors> | ||
| {% if financial_services.event.event_executors is defined %} | ||
| {% for executor in financial_services.event.event_executors %} | ||
| <Executor class="{{executor.name}}" priority="{{executor.priority}}"/> | ||
| {% endfor %} | ||
| {% else %} | ||
| {% if financial_services.event.event_executor is defined %} | ||
| <Executor class="{{financial_services.event.event_executor}}"/> | ||
| {% else %} | ||
| <Executor class="org.wso2.financial.services.accelerator.common.event.executor.DefaultOBEventExecutor"/> | ||
| {% endif %} | ||
| {% endif %} | ||
| </EventExecutors> | ||
| </Event> | ||
| <DataPublishing> | ||
| {% if financial_services.data_publishing.enable is defined %} | ||
| <Enabled>{{financial_services.data_publishing.enable}}</Enabled> | ||
| {% else %} | ||
| <Enabled>false</Enabled> | ||
| {% endif %} | ||
| <!-- Administrator username to login to the SI server for data publishing. --> | ||
| {% if financial_services.data_publishing.username is defined %} | ||
| <Username>{{financial_services.data_publishing.username}}</Username> | ||
| {% else %} | ||
| <Username>[email protected]@carbon.super</Username> | ||
| {% endif %} | ||
| <!-- Administrator password to login to the SI server for data publishing. --> | ||
| {% if financial_services.data_publishing.password is defined %} | ||
| <Password>{{financial_services.data_publishing.password}}</Password> | ||
| {% else %} | ||
| <Password>wso2123</Password> | ||
| {% endif %} | ||
| <!-- Server URL of the remote SI server used to collect statistics. Must | ||
| be specified in {protocol://hostname:port/} format. --> | ||
| {% if financial_services.data_publishing.server_url is defined %} | ||
| <ServerURL>{{financial_services.data_publishing.server_url}}</ServerURL> | ||
| {% else %} | ||
| <ServerURL>{tcp://ANALYTICS_HOSTNAME:7612}</ServerURL> | ||
| {% endif %} | ||
| {% if financial_services.data_publishing.auth_url is defined %} | ||
| <AuthURL>{{financial_services.data_publishing.auth_url}}</AuthURL> | ||
| {% endif %} | ||
| <!-- Allowed values: Thrift --> | ||
| {% if financial_services.data_publishing.protocol is defined %} | ||
| <Protocol>{{financial_services.data_publishing.protocol}}</Protocol> | ||
| {% else %} | ||
| <Protocol>Thrift</Protocol> | ||
| {% endif %} | ||
| {% if financial_services.data_publishing.pool_size is defined %} | ||
| <PoolSize>{{financial_services.data_publishing.pool_size}}</PoolSize> | ||
| {% else %} | ||
| <PoolSize>10</PoolSize> | ||
| {% endif %} | ||
| {% if financial_services.data_publishing.queue_size is defined %} | ||
| <QueueSize>{{financial_services.data_publishing.queue_size}}</QueueSize> | ||
| {% else %} | ||
| <QueueSize>32768</QueueSize> | ||
| {% endif %} | ||
| {% if financial_services.data_publishing.worker_thread_count is defined %} | ||
| <WorkerThreadCount>{{financial_services.data_publishing.worker_thread_count}}</WorkerThreadCount> | ||
| {% else %} | ||
| <WorkerThreadCount>10</WorkerThreadCount> | ||
| {% endif %} | ||
| {% if financial_services.data_publishing.pool_wait_time_Ms is defined %} | ||
| <PoolWaitTimeMs>{{financial_services.data_publishing.pool_wait_time_Ms}}</PoolWaitTimeMs> | ||
| {% else %} | ||
| <PoolWaitTimeMs>60000</PoolWaitTimeMs> | ||
| {% endif %} | ||
| {% if financial_services.data_publishing.financial_services_data_publisher is defined %} | ||
| <FinancialServicesDataPublisher>{{financial_services.data_publishing.financial_services_data_publisher}}</FinancialServicesDataPublisher> | ||
| {% else %} | ||
| <FinancialServicesDataPublisher>org.wso2.financial.services.accelerator.data.publisher.common.FinancialServicesThriftDataPublisher</FinancialServicesDataPublisher> | ||
| {% endif %} | ||
| {% if financial_services.data_publishing.protocol == "Thrift" or financial_services.data_publishing.protocol is not defined%} | ||
| <Thrift> | ||
| {% if financial_services.data_publishing.thrift.publishing_timeout is defined %} | ||
| <PublishingTimeout>{{financial_services.data_publishing.thrift.publishing_timeout}}</PublishingTimeout> | ||
| {% else %} | ||
| <PublishingTimeout>2000</PublishingTimeout> | ||
| {% endif %} | ||
| <Streams> | ||
| {% for stream in financial_services.data_publishing.thrift.stream %} | ||
| <{{stream.name}}> | ||
| {% for attribute in stream.attributes %} | ||
| {% if attribute.required is defined %} | ||
| {% set required = "{{attribute.required}}" %} | ||
| {% else %} | ||
| {% set required = "false" %} | ||
| {% endif %} | ||
| {% if attribute.type is defined %} | ||
| {% set type = "{{attribute.type}}" %} | ||
| {% else %} | ||
| {% set type = "string" %} | ||
| {% endif %} | ||
|
Comment on lines
+657
to
+666
There was a problem hiding this comment. Incorrect Jinja2 syntax in Using 🔎 Proposed fix {% if attribute.required is defined %}
- {% set required = "{{attribute.required}}" %}
+ {% set required = attribute.required %}
{% else %}
{% set required = "false" %}
{% endif %}
{% if attribute.type is defined %}
- {% set type = "{{attribute.type}}" %}
+ {% set type = attribute.type %}
{% else %}
{% set type = "string" %}
{% endif %}🤖 Prompt for AI Agents |
||
| <Attribute name="{{attribute.name}}" priority="{{attribute.priority}}" required="{{required}}" type="{{type}}"/> | ||
| {% endfor %} | ||
| </{{stream.name}}> | ||
| {% endfor %} | ||
| </Streams> | ||
| </Thrift> | ||
| {% endif %} | ||
|
|
||
| </Server> | ||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
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.
🧩 Analysis chain
🏁 Script executed:
Repository: wso2/financial-services-accelerator
Length of output: 1453
🏁 Script executed:
Repository: wso2/financial-services-accelerator
Length of output: 61
Update executor class name to match actual implementation.
The template references
DefaultOBEventExecutorat line 582, but this class does not exist in the codebase. The actual executor implementation isDefaultFSEventExecutor, which is the only executor class defined. Update line 582 to use the correct class name:This mismatch will cause runtime failures when the configuration is loaded.
🤖 Prompt for AI Agents