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

PD-257019 Stabilization emodb queue service changes #831

Merged
merged 59 commits into from
Oct 22, 2024
Merged

PD-257019 Stabilization emodb queue service changes #831

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
59 commits
Select commit Hold shift + click to select a range
7086b8e
PD-249429: integrated emodb with datastorage-media-service for gettin…
vikram-vikram-bv Jul 23, 2024
e31f482
PD-249429: refactored code.
vikram-vikram-bv Jul 24, 2024
4f8ba8d
PD-249428: DELETE blob with blob id.
vikram-vikram-bv Jul 24, 2024
db4a7d6
PD-249428: Implemented upload blob from byte array.
vikram-vikram-bv Jul 25, 2024
5bb2723
PD-249428: Implemented upload blob from byte array.
vikram-vikram-bv Aug 6, 2024
8f4348e
PD-249428: Fixed failing ITs.
vikram-vikram-bv Sep 10, 2024
69c0a26
PD-249428: Fixed failing ITs.
vikram-vikram-bv Sep 10, 2024
380471a
PD-249428: Changed the snapshot version.
vikram-vikram-bv Sep 11, 2024
2d7ff0b
PD-249428: Refactored code.
vikram-vikram-bv Oct 3, 2024
b824029
PD-249428: changed the version to 172.
vikram-vikram-bv Oct 3, 2024
43b223d
PD-249428: commented tests.
vikram-vikram-bv Oct 3, 2024
aa998d5
branch admin -prepare release emodb-6.5.172
Oct 3, 2024
45b0c57
PD-249428: changed snapshot versions.
vikram-vikram-bv Oct 3, 2024
0bc3539
PD-249428: changed snapshot versions.
vikram-vikram-bv Oct 3, 2024
7c8e6b1
branch admin -prepare release emodb-6.5.173
Oct 3, 2024
dc34565
branch admin -prepare for next development iteration
Oct 3, 2024
62eb393
changed the BASE_URL
vikram-vikram-bv Oct 4, 2024
451c879
PD-256742: fixed all bugs.
vikram-vikram-bv Oct 7, 2024
1518c12
PD-256742: changed snapshot version.
vikram-vikram-bv Oct 7, 2024
c74167f
PD-256742: changed snapshot version.
vikram-vikram-bv Oct 8, 2024
785982c
branch admin -prepare release emodb-6.5.176
Oct 8, 2024
10d0f7a
branch admin -prepare for next development iteration
Oct 8, 2024
94f25ac
for testing
nabajyotiDash-hub Jul 16, 2024
b49b2b6
feat: integrate kafka to emodb
rishuyadavbv Sep 28, 2024
60549b0
feat: include logic for separation of queue and dedupq
rishuyadavbv Sep 29, 2024
34e56cd
feat: include guava dependency injection for emodb
rishuyadavbv Oct 1, 2024
539c0be
fix: seperation of producer and admin service and proper injection
rishuyadavbv Oct 1, 2024
2acd542
fix: fix DI wiring issue
rishuyadavbv Oct 1, 2024
8e160ad
feat: integrate triggering step function execution on creation of new…
rishuyadavbv Oct 7, 2024
21569aa
feat: merge changes for stepfunction
rishuyadavbv Oct 7, 2024
5bb37c0
branch admin -prepare release emodb-6.5.175
Oct 7, 2024
b2825a0
branch admin -prepare for next development iteration
Oct 7, 2024
b58712b
feat: add parameter store
rishuyadavbv Oct 7, 2024
8397020
fix:add aws core dependency
rishuyadavbv Oct 8, 2024
7d229ce
fix:remove credentialProvider
rishuyadavbv Oct 8, 2024
c0560d3
fix: changes for ci deployment
rishuyadavbv Oct 9, 2024
8a4fd37
fix: pom changes for blob
rishuyadavbv Oct 9, 2024
38807d4
chore: update tags to 177 for deployment
rishuyadavbv Oct 9, 2024
1291c70
branch admin -prepare release emodb-6.5.177
Oct 9, 2024
4c28f80
branch admin -prepare for next development iteration
Oct 9, 2024
6378ece
chore: update msk servers
rishuyadavbv Oct 9, 2024
e2b238a
fix: include msk server url
rishuyadavbv Oct 15, 2024
6dff7fe
chore: snapshot update to 181
rishuyadavbv Oct 15, 2024
fe9d822
branch admin -prepare release emodb-6.5.181
Oct 15, 2024
0ede16d
branch admin -prepare for next development iteration
Oct 15, 2024
d6bebfd
feat: include working parameter store and stepfn changes
rishuyadavbv Oct 15, 2024
322486b
branch admin -prepare release emodb-6.5.182
Oct 15, 2024
89dbd38
branch admin -prepare for next development iteration
Oct 15, 2024
fb7c3f7
feat: fetch kafka configs from ssm and dependency injection for stepfn
rishuyadavbv Oct 15, 2024
baf3696
branch admin -prepare release emodb-6.5.183
Oct 15, 2024
d0d4d31
branch admin -prepare for next development iteration
Oct 15, 2024
5ec6daa
feat: feature flag implementation for queue migrations
rishuyadavbv Oct 17, 2024
4d4b75c
fix: fix param for allowedQueues
rishuyadavbv Oct 17, 2024
d0f482b
branch admin -prepare release emodb-6.5.184
Oct 17, 2024
8a5cc45
branch admin -prepare for next development iteration
Oct 17, 2024
8385622
fix: remove blob changes
rishuyadavbv Oct 18, 2024
6a7ebff
chore: add comments and fix start.sh
rishuyadavbv Oct 18, 2024
ca1ad1d
fix: changed logic for feature flag
rishuyadavbv Oct 18, 2024
bb10a0f
fix: fixed exception handling and code refactoring
rishuyadavbv Oct 19, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Empty file added abc.txt
View file
Open in desktop
Empty file.
2 changes: 1 addition & 1 deletion auth/auth-client/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion auth/auth-core/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion auth/auth-store/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion auth/auth-util/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
<parent>
<artifactId>emodb</artifactId>
<groupId>com.bazaarvoice.emodb</groupId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
Expand Down
2 changes: 1 addition & 1 deletion blob-api/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion blob-clients/blob-client-common/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion blob-clients/blob-client-jersey2/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion blob-clients/blob-client/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion blob/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion blob/src/main/java/com/bazaarvoice/emodb/blob/core/DefaultBlobStore.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -474,4 +474,4 @@ private static void checkLegalBlobId(String blobId) {
"Blob IDs must be ASCII strings between 1 and 255 characters in length. " +
"Whitespace, ISO control characters and certain punctuation characters that aren't generally allowed in file names are excluded.");
}
}
}
2 changes: 1 addition & 1 deletion cachemgr/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion common/api/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion common/astyanax/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion common/client-jax-rs-2/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion common/client-jersey2/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion common/client/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion common/dropwizard/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion common/jersey-client/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion common/json/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion common/stash/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion common/uuid/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion common/zookeeper/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion databus-api/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion databus-client-common/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion databus-client-jersey2/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion databus-client/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion databus/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion datacenter/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion event/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion job-api/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion job/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion kafka/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion megabus/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
13 changes: 12 additions & 1 deletion parent/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@

<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<packaging>pom</packaging>

<name>EmoDB Parent</name>
Expand Down Expand Up @@ -635,11 +635,22 @@
<artifactId>aws-java-sdk-sns</artifactId>
<version>${aws-sdk.version}</version>
</dependency>
<dependency>
<groupId>com.amazonaws</groupId>
<artifactId>aws-java-sdk-stepfunctions</artifactId>
<version>${aws-sdk.version}</version>
</dependency>
<dependency>
<groupId>com.amazonaws</groupId>
<artifactId>aws-java-sdk-sqs</artifactId>
<version>${aws-sdk.version}</version>
</dependency>

<dependency>
<groupId>com.amazonaws</groupId>
<artifactId>aws-java-sdk-ssm</artifactId>
<version>${aws-sdk.version}</version>
</dependency>
<dependency>
<groupId>com.amazonaws</groupId>
<artifactId>aws-java-sdk-sts</artifactId>
Expand Down
2 changes: 1 addition & 1 deletion plugins/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion quality/integration/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion quality/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion queue-api/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>com.bazaarvoice.emodb</groupId>
<artifactId>emodb-parent</artifactId>
<version>6.5.171-SNAPSHOT</version>
<version>6.5.185-SNAPSHOT</version>
<relativePath>../parent/pom.xml</relativePath>
</parent>

Expand Down
2 changes: 2 additions & 0 deletions queue-api/src/main/java/com/bazaarvoice/emodb/queue/api/AuthDedupQueueService.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -64,4 +64,6 @@ public interface AuthDedupQueueService {

/** Delete all messages in the queue, for debugging/testing. */
void purge(@Credential String apiKey, String queue);

void sendAll(String apiKey, String queue, Collection<?> messages, boolean isFlush);
}
3 changes: 3 additions & 0 deletions queue-api/src/main/java/com/bazaarvoice/emodb/queue/api/AuthQueueService.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@ public interface AuthQueueService {
void sendAll(@Credential String apiKey, String queue, Collection<?> messages);

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

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

/** Delete all messages in the queue, for debugging/testing. */
void purge(@Credential String apiKey, String queue);


}
Loading