Skip to content
This repository was archived by the owner on Feb 10, 2025. It is now read-only.

Commit 032af2b

Browse files
rishuyadavbvvikram-vikram-bvjenkinsnabajyotiDash-hubanurag0510
authored
PD-257019 Changes for emodb stabilization, kafka integration and stepfunction firing (#844)
* PD-257019 Stabilization emodb queue service changes (#831) * PD-249429: integrated emodb with datastorage-media-service for getting the metadata from s3. * PD-249429: refactored code. * PD-249428: DELETE blob with blob id. * PD-249428: Implemented upload blob from byte array. * PD-249428: Implemented upload blob from byte array. * PD-249428: Fixed failing ITs. * PD-249428: Fixed failing ITs. * PD-249428: Changed the snapshot version. * PD-249428: Refactored code. * PD-249428: changed the version to 172. * PD-249428: commented tests. * branch admin -prepare release emodb-6.5.172 * PD-249428: changed snapshot versions. * PD-249428: changed snapshot versions. * branch admin -prepare release emodb-6.5.173 * branch admin -prepare for next development iteration * changed the BASE_URL * PD-256742: fixed all bugs. * PD-256742: changed snapshot version. * PD-256742: changed snapshot version. * branch admin -prepare release emodb-6.5.176 * branch admin -prepare for next development iteration * for testing * feat: integrate kafka to emodb * Create kafka producer and admin service * Overload the sendAll method to reroute messages to kafka * Make the required changes in Clients like jersey2 * feat: include logic for separation of queue and dedupq * feat: include guava dependency injection for emodb * fix: seperation of producer and admin service and proper injection * fix: fix DI wiring issue * feat: integrate triggering step function execution on creation of new topic * feat: merge changes for stepfunction * branch admin -prepare release emodb-6.5.175 * branch admin -prepare for next development iteration * feat: add parameter store * fix:add aws core dependency * fix:remove credentialProvider * fix: changes for ci deployment * fix: pom changes for blob * chore: update tags to 177 for deployment * branch admin -prepare release emodb-6.5.177 * branch admin -prepare for next development iteration * chore: update msk servers * fix: include msk server url * chore: snapshot update to 181 * branch admin -prepare release emodb-6.5.181 * branch admin -prepare for next development iteration * feat: include working parameter store and stepfn changes * add proper exception handling in parameter store and stepfn * make abstractqueue service code modular and organized * branch admin -prepare release emodb-6.5.182 * branch admin -prepare for next development iteration * feat: fetch kafka configs from ssm and dependency injection for stepfn * fetch aws configs from ssm parameter store * introduce dependency injection for stepfunction service * branch admin -prepare release emodb-6.5.183 * branch admin -prepare for next development iteration * feat: feature flag implementation for queue migrations * include the proper naming for each stepfn execution * include all required contracts for stepfn * include the feature flag logic, fetch params from parameter store and based on the allowed queues migrate * fix: fix param for allowedQueues * branch admin -prepare release emodb-6.5.184 * branch admin -prepare for next development iteration * fix: remove blob changes * chore: add comments and fix start.sh * fix: changed logic for feature flag * add changed logic for feature flag implementation * wrap the payload for stepfn around a executionInput parameter * fix: fixed exception handling and code refactoring * throw back exceptions after logging * include create topic and checktopic in one function * add comments for better description --------- Co-authored-by: vikram-vikram_bveng <[email protected]> Co-authored-by: jenkins <[email protected]> Co-authored-by: nabajyotiDash-hub <[email protected]> * update pom version * branch admin -prepare release emodb-6.5.192 * branch admin -prepare for next development iteration * modify producer properties (#834) * PD-257019 Add universe fetching and bug fixes (#835) * feat: add universe fetching and bug fixes * fix: remove debug logs * branch admin -prepare release emodb-6.5.193 * branch admin -prepare for next development iteration * uncached_size for dedupq (#837) * PD-257019 Producer send and logging changes (#838) * fix: fix send logic and exception handling changes * added exception handling * changed producer send logic to be synchronous * removed redundant logs * uncached_size for dedupq (#837) * chore: rename queuetype as per convention * chore: fix naming issue --------- Co-authored-by: nabajyotiDash-hub <[email protected]> * branch admin -prepare release emodb-6.5.194 * branch admin -prepare for next development iteration * branch admin -prepare release emodb-6.5.195 * branch admin -prepare for next development iteration * branch admin -prepare release emodb-6.5.196 * branch admin -prepare for next development iteration * chore: snapshot updates * branch admin -prepare release emodb-6.5.194 * branch admin -prepare for next development iteration * [PD-258160] added dd metrics for queue name and queue size (#836) * branch admin -prepare release emodb-6.5.195 * alter pom version for bvengineering deployment * branch admin -prepare release emodb-6.5.196 * update pom to 6.5.197-SNAPSHOT * branch admin -prepare release emodb-6.5.197 * branch admin -prepare for next development iteration * branch admin -prepare release emodb-6.5.198 * branch admin -prepare for next development iteration * add cache * add allowedQueues cache * feat: producer future logic and caching changes * chore: clear out unused code * PD-257019 Producer send and logging changes (#838) * fix: fix send logic and exception handling changes * added exception handling * changed producer send logic to be synchronous * removed redundant logs * uncached_size for dedupq (#837) * chore: rename queuetype as per convention * chore: fix naming issue --------- Co-authored-by: nabajyotiDash-hub <[email protected]> * fix: fix the config changes * Revert "Merge branch 'master' into PD-257019-producer-async-fixes" This reverts commit 93f5a76, reversing changes made to 15ce863. * chore: snapshot updates for deployement * chore: clear up testing logs * fix: remove default servers * branch admin -prepare release emodb-6.5.202 * branch admin -prepare for next development iteration * chore: caching logs refactoring * branch admin -prepare release emodb-6.5.203 * branch admin -prepare for next development iteration --------- Co-authored-by: vikram-vikram_bveng <[email protected]> Co-authored-by: jenkins <[email protected]> Co-authored-by: nabajyotiDash-hub <[email protected]> Co-authored-by: nabajyotiDash-hub <[email protected]> Co-authored-by: Anurag Dubey <[email protected]>
1 parent 3538bbf commit 032af2b

File tree

84 files changed

+1051
-122
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

84 files changed

+1051
-122
lines changed

‎abc.txt

Whitespace-only changes.

‎auth/auth-client/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../../parent/pom.xml</relativePath>
1111
</parent>
1212

‎auth/auth-core/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../../parent/pom.xml</relativePath>
1111
</parent>
1212

‎auth/auth-store/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../../parent/pom.xml</relativePath>
1111
</parent>
1212

‎auth/auth-util/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
<parent>
44
<artifactId>emodb</artifactId>
55
<groupId>com.bazaarvoice.emodb</groupId>
6-
<version>6.5.171-SNAPSHOT</version>
6+
<version>6.5.204-SNAPSHOT</version>
77
<relativePath>../../pom.xml</relativePath>
88
</parent>
99
<modelVersion>4.0.0</modelVersion>

‎blob-api/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../parent/pom.xml</relativePath>
1111
</parent>
1212

‎blob-clients/blob-client-common/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../../parent/pom.xml</relativePath>
1111
</parent>
1212

‎blob-clients/blob-client-jersey2/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../../parent/pom.xml</relativePath>
1111
</parent>
1212

‎blob-clients/blob-client/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../../parent/pom.xml</relativePath>
1111
</parent>
1212

‎blob/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../parent/pom.xml</relativePath>
1111
</parent>
1212

‎blob/src/main/java/com/bazaarvoice/emodb/blob/core/DefaultBlobStore.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -474,4 +474,4 @@ private static void checkLegalBlobId(String blobId) {
474474
"Blob IDs must be ASCII strings between 1 and 255 characters in length. " +
475475
"Whitespace, ISO control characters and certain punctuation characters that aren't generally allowed in file names are excluded.");
476476
}
477-
}
477+
}

‎cachemgr/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../parent/pom.xml</relativePath>
1111
</parent>
1212

‎common/api/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../../parent/pom.xml</relativePath>
1111
</parent>
1212

‎common/astyanax/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../../parent/pom.xml</relativePath>
1111
</parent>
1212

‎common/client-jax-rs-2/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../../parent/pom.xml</relativePath>
1111
</parent>
1212

‎common/client-jersey2/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
<parent>
66
<groupId>com.bazaarvoice.emodb</groupId>
77
<artifactId>emodb-parent</artifactId>
8-
<version>6.5.171-SNAPSHOT</version>
8+
<version>6.5.204-SNAPSHOT</version>
99
<relativePath>../../parent/pom.xml</relativePath>
1010
</parent>
1111

‎common/client/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../../parent/pom.xml</relativePath>
1111
</parent>
1212

‎common/dropwizard/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../../parent/pom.xml</relativePath>
1111
</parent>
1212

‎common/jersey-client/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
<parent>
66
<groupId>com.bazaarvoice.emodb</groupId>
77
<artifactId>emodb-parent</artifactId>
8-
<version>6.5.171-SNAPSHOT</version>
8+
<version>6.5.204-SNAPSHOT</version>
99
<relativePath>../../parent/pom.xml</relativePath>
1010
</parent>
1111

‎common/json/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../../parent/pom.xml</relativePath>
1111
</parent>
1212

‎common/stash/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../../parent/pom.xml</relativePath>
1111
</parent>
1212

‎common/uuid/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../../parent/pom.xml</relativePath>
1111
</parent>
1212

‎common/zookeeper/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../../parent/pom.xml</relativePath>
1111
</parent>
1212

‎databus-api/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../parent/pom.xml</relativePath>
1111
</parent>
1212

‎databus-client-common/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../parent/pom.xml</relativePath>
1111
</parent>
1212

‎databus-client-jersey2/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../parent/pom.xml</relativePath>
1111
</parent>
1212

‎databus-client/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../parent/pom.xml</relativePath>
1111
</parent>
1212

‎databus/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../parent/pom.xml</relativePath>
1111
</parent>
1212

‎datacenter/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../parent/pom.xml</relativePath>
1111
</parent>
1212

‎event/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../parent/pom.xml</relativePath>
1111
</parent>
1212

‎job-api/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../parent/pom.xml</relativePath>
1111
</parent>
1212

‎job/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../parent/pom.xml</relativePath>
1111
</parent>
1212

‎kafka/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../parent/pom.xml</relativePath>
1111
</parent>
1212

‎megabus/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../parent/pom.xml</relativePath>
1111
</parent>
1212

‎parent/pom.xml

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111

1212
<groupId>com.bazaarvoice.emodb</groupId>
1313
<artifactId>emodb-parent</artifactId>
14-
<version>6.5.171-SNAPSHOT</version>
14+
<version>6.5.204-SNAPSHOT</version>
1515
<packaging>pom</packaging>
1616

1717
<name>EmoDB Parent</name>
@@ -635,11 +635,22 @@
635635
<artifactId>aws-java-sdk-sns</artifactId>
636636
<version>${aws-sdk.version}</version>
637637
</dependency>
638+
<dependency>
639+
<groupId>com.amazonaws</groupId>
640+
<artifactId>aws-java-sdk-stepfunctions</artifactId>
641+
<version>${aws-sdk.version}</version>
642+
</dependency>
638643
<dependency>
639644
<groupId>com.amazonaws</groupId>
640645
<artifactId>aws-java-sdk-sqs</artifactId>
641646
<version>${aws-sdk.version}</version>
642647
</dependency>
648+
649+
<dependency>
650+
<groupId>com.amazonaws</groupId>
651+
<artifactId>aws-java-sdk-ssm</artifactId>
652+
<version>${aws-sdk.version}</version>
653+
</dependency>
643654
<dependency>
644655
<groupId>com.amazonaws</groupId>
645656
<artifactId>aws-java-sdk-sts</artifactId>

‎plugins/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
<parent>
55
<groupId>com.bazaarvoice.emodb</groupId>
66
<artifactId>emodb-parent</artifactId>
7-
<version>6.5.171-SNAPSHOT</version>
7+
<version>6.5.204-SNAPSHOT</version>
88
<relativePath>../parent/pom.xml</relativePath>
99
</parent>
1010

‎pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>parent/pom.xml</relativePath>
1111
</parent>
1212

‎quality/integration/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../../parent/pom.xml</relativePath>
1111
</parent>
1212

‎quality/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../parent/pom.xml</relativePath>
1111
</parent>
1212

‎queue-api/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<parent>
77
<groupId>com.bazaarvoice.emodb</groupId>
88
<artifactId>emodb-parent</artifactId>
9-
<version>6.5.171-SNAPSHOT</version>
9+
<version>6.5.204-SNAPSHOT</version>
1010
<relativePath>../parent/pom.xml</relativePath>
1111
</parent>
1212

‎queue-api/src/main/java/com/bazaarvoice/emodb/queue/api/AuthDedupQueueService.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -64,4 +64,6 @@ public interface AuthDedupQueueService {
6464

6565
/** Delete all messages in the queue, for debugging/testing. */
6666
void purge(@Credential String apiKey, String queue);
67+
68+
void sendAll(String apiKey, String queue, Collection<?> messages, boolean isFlush);
6769
}

‎queue-api/src/main/java/com/bazaarvoice/emodb/queue/api/AuthQueueService.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@ public interface AuthQueueService {
1818
void sendAll(@Credential String apiKey, String queue, Collection<?> messages);
1919

2020
void sendAll(@Credential String apiKey, Map<String, ? extends Collection<?>> messagesByQueue);
21+
void sendAll(@Credential String apiKey, String queue, Collection<?> messages, boolean isFlush);
2122

2223
/**
2324
* Counts pending messages for the specified queue. The count will include messages that are currently claimed
@@ -64,4 +65,6 @@ public interface AuthQueueService {
6465

6566
/** Delete all messages in the queue, for debugging/testing. */
6667
void purge(@Credential String apiKey, String queue);
68+
69+
6770
}

0 commit comments

Comments
 (0)