Merge pull request #12193 from IsuruMaduranga/transaction-counter

Integrate distributed transaction counter with APIM
wso2 · Dec 6, 2023 · e864195 · e864195
2 parents 7e0120c + 651f8c9
commit e864195
Show file tree

Hide file tree

Showing 3 changed files with 55 additions and 1 deletion.
diff --git a/...re.feature/src/main/resources/conf_templates/templates/repository/conf/api-manager.xml.j2 b/...re.feature/src/main/resources/conf_templates/templates/repository/conf/api-manager.xml.j2
@@ -185,6 +185,50 @@
             </Environment>
             {% endfor %}
         </Environments>
+        <TransactionCounter>
+            {% if integration.transaction_counter.enable is defined %}
+            <Enabled>{{integration.transaction_counter.enable}}</Enabled>
+            {% endif %}
+            {% if integration.transaction_counter.server_id is defined %}
+            <ServerID>{{integration.transaction_counter.server_id}}</ServerID>
+            {% endif %}
+            {% if integration.transaction_counter.store_impl is defined %}
+            <StoreClass>{{integration.transaction_counter.store_impl}}</StoreClass>
+            {% endif %}
+            {% if integration.transaction_counter.record_queue_size is defined %}
+            <QueueSize>{{integration.transaction_counter.record_queue_size}}</QueueSize>
+            {% endif %}
+            {% if integration.transaction_counter.producer_counting_thread_pool_size is defined %}
+            <ProducerThreadPoolSize>{{integration.transaction_counter.producer_counting_thread_pool_size}}</ProducerThreadPoolSize>
+            {% endif %}
+            {% if integration.transaction_counter.producer_scheduled_interval is defined %}
+            <ProducerScheduledInterval>{{integration.transaction_counter.producer_scheduled_interval}}</ProducerScheduledInterval>
+            {% endif %}
+            {% if integration.transaction_counter.max_transaction_count_per_record is defined %}
+            <MaxTransactionCount>{{integration.transaction_counter.max_transaction_count_per_record}}</MaxTransactionCount>
+            {% endif %}
+            {% if integration.transaction_counter.min_transaction_count_per_record is defined %}
+            <MinTransactionCount>{{integration.transaction_counter.min_transaction_count_per_record}}</MinTransactionCount>
+            {% endif %}
+            {% if integration.transaction_counter.publisher_scheduled_interval is defined %}
+            <PublisherScheduledInterval>{{integration.transaction_counter.publisher_scheduled_interval}}</PublisherScheduledInterval>
+            {% endif %}
+            {% if integration.transaction_counter.publisher_max_batch_size is defined %}
+            <MaxBatchSize>{{integration.transaction_counter.publisher_max_batch_size}}</MaxBatchSize>
+            {% endif %}
+            {% if integration.transaction_counter.publisher_max_retries is defined %}
+            <MaxRetryCount>{{integration.transaction_counter.publisher_max_retries}}</MaxRetryCount>
+            {% endif %}
+            {% if integration.transaction_counter.service_url is defined %}
+            <ServiceURL>{{integration.transaction_counter.service_url}}</ServiceURL>
+            {% endif %}
+            {% if integration.transaction_counter.service_username is defined %}
+            <ServiceUsername>{{integration.transaction_counter.service_username}}</ServiceUsername>
+            {% endif %}
+            {% if integration.transaction_counter.service_password is defined %}
+            <ServicePassword>{{integration.transaction_counter.service_password}}</ServicePassword>
+            {% endif %}
+        </TransactionCounter>
     </APIGateway>
 
     <TokenIssuers>

diff --git a/features/apimgt/org.wso2.carbon.apimgt.gateway.feature/pom.xml b/features/apimgt/org.wso2.carbon.apimgt.gateway.feature/pom.xml
@@ -266,7 +266,9 @@
                                 <importBundleDef>
                                     org.wso2.carbon.mediation:org.wso2.carbon.localentry.stub:${carbon.mediation.version}
                                 </importBundleDef>
-
+                                <bundleDef>
+                                    org.wso2.integration.transaction.counter:transaction-count-handler:${integration.transaction.counter.version}
+                                </bundleDef>
                                 <bundleDef>com.googlecode.json-simple:json-simple</bundleDef>
                                 <bundleDef>com.google.code.gson:gson:${google.code.gson.version}</bundleDef>
                                 <bundleDef>net.sf.ehcache.wso2:ehcache</bundleDef>

diff --git a/pom.xml b/pom.xml
@@ -1950,6 +1950,11 @@
                 <artifactId>batik-all</artifactId>
                 <version>${batik.version}</version>
             </dependency>
+            <dependency>
+                <groupId>org.wso2.integration.transaction.counter</groupId>
+                <artifactId>transaction-count-handler</artifactId>
+                <version>${integration.transaction.counter.version}</version>
+            </dependency>
         </dependencies>
     </dependencyManagement>
 
@@ -2074,6 +2079,9 @@
         <!-- databridge agent version range-->
         <databridge.agent.range>[5.1,6)</databridge.agent.range>
 
+        <!-- Transaction Counter -->
+        <integration.transaction.counter.version>1.0.0</integration.transaction.counter.version>
+
         <javax.xml.soap.imp.pkg.version>0.0.0</javax.xml.soap.imp.pkg.version>
         <javax.xml.stream.imp.pkg.version>[1.0.1, 1.1.0)</javax.xml.stream.imp.pkg.version>