You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/12/20 01:18:19 UTC
[pulsar] branch master updated: Avoid raw use of parameterized class 'MessagePassingQueue' (#13386)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 1a70ae5 Avoid raw use of parameterized class 'MessagePassingQueue' (#13386)
1a70ae5 is described below
commit 1a70ae50651a738cfccf7b2e78c0e4ec55868f76
Author: JiangHaiting <ji...@apache.org>
AuthorDate: Mon Dec 20 09:17:04 2021 +0800
Avoid raw use of parameterized class 'MessagePassingQueue' (#13386)
---
.../pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java
index 058d62b..5d78282 100644
--- a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java
+++ b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java
@@ -143,7 +143,7 @@ public abstract class AbstractBatchedMetadataStore extends AbstractMetadataStore
return op.getFuture();
}
- private void enqueue(MessagePassingQueue queue, MetadataOp op) {
+ private void enqueue(MessagePassingQueue<MetadataOp> queue, MetadataOp op) {
if (enabled) {
if (!queue.offer(op)) {
// Execute individually if we're failing to enqueue