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

PD-257019 Changes for emodb stabilization, kafka integration and stepfunction firing #844

Merged
merged 44 commits into from
Oct 28, 2024
Merged

PD-257019 Changes for emodb stabilization, kafka integration and stepfunction firing #844

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
44 commits
Select commit Hold shift + click to select a range
a835c18
PD-257019 Stabilization emodb queue service changes (#831)
rishuyadavbv Oct 22, 2024
240e58f
update pom version
nabajyotiDash-hub Oct 22, 2024
81cc72c
branch admin -prepare release emodb-6.5.192
Oct 22, 2024
27c7f51
branch admin -prepare for next development iteration
Oct 22, 2024
6da9069
modify producer properties (#834)
nabajyotiDash-hub Oct 23, 2024
30a9361
PD-257019 Add universe fetching and bug fixes (#835)
rishuyadavbv Oct 23, 2024
fa24d95
branch admin -prepare release emodb-6.5.193
Oct 23, 2024
f7cff82
branch admin -prepare for next development iteration
Oct 23, 2024
821cf22
uncached_size for dedupq (#837)
nabajyotiDash-hub Oct 23, 2024
1a3f655
PD-257019 Producer send and logging changes (#838)
rishuyadavbv Oct 23, 2024
3ef1bfb
branch admin -prepare release emodb-6.5.194
Oct 24, 2024
c72756a
branch admin -prepare for next development iteration
Oct 24, 2024
c37ac6a
branch admin -prepare release emodb-6.5.195
Oct 24, 2024
5a4da1d
branch admin -prepare for next development iteration
Oct 24, 2024
a673f0f
branch admin -prepare release emodb-6.5.196
Oct 24, 2024
64656fc
branch admin -prepare for next development iteration
Oct 24, 2024
34ce3dc
chore: snapshot updates
rishuyadavbv Oct 24, 2024
c151823
branch admin -prepare release emodb-6.5.194
Oct 24, 2024
8f6e757
branch admin -prepare for next development iteration
Oct 24, 2024
29bbe6e
[PD-258160] added dd metrics for queue name and queue size (#836)
anurag0510 Oct 24, 2024
403538a
branch admin -prepare release emodb-6.5.195
Oct 24, 2024
5fe4c1a
alter pom version for bvengineering deployment
nabajyotiDash-hub Oct 24, 2024
fc87b05
branch admin -prepare release emodb-6.5.196
Oct 24, 2024
e8972d8
update pom to 6.5.197-SNAPSHOT
nabajyotiDash-hub Oct 24, 2024
5a20d93
branch admin -prepare release emodb-6.5.197
Oct 24, 2024
474ca29
branch admin -prepare for next development iteration
Oct 24, 2024
f5e93e7
branch admin -prepare release emodb-6.5.198
Oct 24, 2024
c9d6dd4
branch admin -prepare for next development iteration
Oct 24, 2024
6951831
add cache
nabajyotiDash-hub Oct 24, 2024
a7f5d86
add allowedQueues cache
nabajyotiDash-hub Oct 24, 2024
cc54853
feat: producer future logic and caching changes
rishuyadavbv Oct 25, 2024
a90e902
chore: clear out unused code
rishuyadavbv Oct 26, 2024
63deae2
PD-257019 Producer send and logging changes (#838)
rishuyadavbv Oct 23, 2024
15ce863
fix: fix the config changes
rishuyadavbv Oct 26, 2024
93f5a76
Merge branch 'master' into PD-257019-producer-async-fixes
rishuyadavbv Oct 26, 2024
b4383ae
Revert "Merge branch 'master' into PD-257019-producer-async-fixes"
rishuyadavbv Oct 26, 2024
428d42d
chore: snapshot updates for deployement
rishuyadavbv Oct 26, 2024
0f1369a
chore: clear up testing logs
rishuyadavbv Oct 26, 2024
beaca42
fix: remove default servers
rishuyadavbv Oct 26, 2024
8ab6ada
branch admin -prepare release emodb-6.5.202
Oct 26, 2024
948d4cd
branch admin -prepare for next development iteration
Oct 26, 2024
10bdb07
chore: caching logs refactoring
rishuyadavbv Oct 26, 2024
87f64a9
branch admin -prepare release emodb-6.5.203
Oct 26, 2024
74c580b
branch admin -prepare for next development iteration
Oct 26, 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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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.204-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