fix syntax errors

jd-opensource · Aug 11, 2020 · 9dd3b16 · 9dd3b16
1 parent 1352994
commit 9dd3b16
Show file tree

Hide file tree

Showing 32 changed files with 85 additions and 85 deletions.
diff --git a/...ore/src/main/java/org/joyqueue/client/internal/consumer/support/DefaultMessagePoller.java b/...ore/src/main/java/org/joyqueue/client/internal/consumer/support/DefaultMessagePoller.java
@@ -353,7 +353,7 @@ public JoyQueueCode commitIndex(String topic, short partition, long index) {
         TopicMetadata topicMetadata = messagePollerInner.getAndCheckTopicMetadata(topic);
 
         PartitionMetadata partitionMetadata = topicMetadata.getPartition(partition);
-        Preconditions.checkArgument(partitionMetadata != null, "partition is not exist");
+        Preconditions.checkArgument(partitionMetadata != null, "partition dose not exist");
 
         return consumerIndexManager.commitIndex(topic, config.getAppFullName(), partition, index, config.getTimeout());
     }
@@ -426,4 +426,4 @@ protected void checkState() {
             throw new ConsumerException("consumer is not started", JoyQueueCode.CN_SERVICE_NOT_AVAILABLE.getCode());
         }
     }
-}
+}
diff --git a/...-core/src/main/java/org/joyqueue/client/internal/consumer/support/MessagePollerInner.java b/...-core/src/main/java/org/joyqueue/client/internal/consumer/support/MessagePollerInner.java
@@ -331,15 +331,15 @@ public BrokerAssignments buildAllBrokerAssignments(TopicMetadata topicMetadata)
     public TopicMetadata getAndCheckTopicMetadata(String topic) {
         TopicMetadata topicMetadata = clusterManager.fetchTopicMetadata(getTopicFullName(topic), config.getAppFullName());
         if (topicMetadata == null) {
-            throw new ConsumerException(String.format("topic %s is not exist", topic), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
+            throw new ConsumerException(String.format("topic %s dose not exist", topic), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
         }
         if (topicMetadata.getConsumerPolicy() == null) {
-            throw new ConsumerException(String.format("topic %s consumer %s is not exist", topic, config.getAppFullName()), JoyQueueCode.FW_CONSUMER_NOT_EXISTS.getCode());
+            throw new ConsumerException(String.format("topic %s consumer %s dose not exist", topic, config.getAppFullName()), JoyQueueCode.FW_CONSUMER_NOT_EXISTS.getCode());
         }
         return topicMetadata;
     }
 
     public String getTopicFullName(String topic) {
         return NameServerHelper.getTopicFullName(topic, nameServerConfig);
     }
-}
+}
diff --git a/...e/src/main/java/org/joyqueue/client/internal/consumer/support/PartitionMessagePoller.java b/...e/src/main/java/org/joyqueue/client/internal/consumer/support/PartitionMessagePoller.java
@@ -344,7 +344,7 @@ public JoyQueueCode commitIndex(String topic, short partition, long index) {
         TopicMetadata topicMetadata = messagePollerInner.getAndCheckTopicMetadata(topic);
 
         PartitionMetadata partitionMetadata = topicMetadata.getPartition(partition);
-        Preconditions.checkArgument(partitionMetadata != null, "partition is not exist");
+        Preconditions.checkArgument(partitionMetadata != null, "partition dose not exist");
 
         return consumerIndexManager.commitIndex(topic, config.getAppFullName(), partition, index, config.getTimeout());
     }
@@ -426,4 +426,4 @@ protected void checkState() {
             throw new ConsumerException("consumer is not started", JoyQueueCode.CN_SERVICE_NOT_AVAILABLE.getCode());
         }
     }
-}
+}
diff --git a/...ore/src/main/java/org/joyqueue/client/internal/consumer/support/TopicMessageConsumer.java b/...ore/src/main/java/org/joyqueue/client/internal/consumer/support/TopicMessageConsumer.java
@@ -126,10 +126,10 @@ protected MessagePoller createMessagePoller(String topic) {
         TopicMetadata topicMetadata = clusterManager.fetchTopicMetadata(topicName.getFullName(), config.getAppFullName());
 
         if (topicMetadata == null) {
-            throw new ConsumerException(String.format("topic %s is not exist", topic), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
+            throw new ConsumerException(String.format("topic %s dose not exist", topic), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
         }
         if (topicMetadata.getConsumerPolicy() == null) {
-            throw new ConsumerException(String.format("topic %s consumer %s is not exist", topic, config.getAppFullName()), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
+            throw new ConsumerException(String.format("topic %s consumer %s dose not exist", topic, config.getAppFullName()), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
         }
 
         if (config.getThread() == ConsumerConfig.NONE_THREAD) {
@@ -177,4 +177,4 @@ public synchronized void removeListener(BaseMessageListener messageListener) {
     public MessagePoller getMessagePoller() {
         return messagePoller;
     }
-}
+}
diff --git a/...re/src/main/java/org/joyqueue/client/internal/producer/checker/ProduceMessageChecker.java b/...re/src/main/java/org/joyqueue/client/internal/producer/checker/ProduceMessageChecker.java
@@ -43,7 +43,7 @@ public static void checkMessage(ProduceMessage produceMessage, ProducerConfig co
             throwCheckException("message body is not empty");
         }
         if (produceMessage.getPartition() != ProduceMessage.NONE_PARTITION && produceMessage.getPartition() < 0) {
-            throwCheckException("message body is not exist");
+            throwCheckException("message body dose not exist");
         }
         if (StringUtils.isNotBlank(produceMessage.getBody()) && produceMessage.getBody().length() > config.getBodyLengthLimit()) {
             throwCheckException(String.format("body is too long, it must less than %s characters", config.getBodyLengthLimit()));
@@ -92,4 +92,4 @@ public static void checkMessages(List<ProduceMessage> produceMessages, ProducerC
     protected static void throwCheckException(String message) {
         throw new ProducerException(message, JoyQueueCode.CN_PARAM_ERROR.getCode());
     }
-}
+}
diff --git a/...rc/main/java/org/joyqueue/client/internal/producer/feedback/DefaultTxFeedbackManager.java b/...rc/main/java/org/joyqueue/client/internal/producer/feedback/DefaultTxFeedbackManager.java
@@ -118,7 +118,7 @@ public synchronized void removeTransactionCallback(String topic) {
 
         TxFeedbackScheduler txFeedbackScheduler = txCallback.get(topicFullName);
         if (txFeedbackScheduler == null) {
-            throw new IllegalArgumentException(String.format("%s feedback is not exist", topic));
+            throw new IllegalArgumentException(String.format("%s feedback dose not exist", topic));
         }
 
         if (txFeedbackScheduler.isStarted()) {
@@ -130,10 +130,10 @@ public synchronized void removeTransactionCallback(String topic) {
     protected TopicMetadata checkTopicMetadata(String topic) {
         TopicMetadata topicMetadata = clusterManager.fetchTopicMetadata(getTopicFullName(topic), config.getApp());
         if (topicMetadata == null) {
-            throw new ProducerException(String.format("topic %s is not exist", topic), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
+            throw new ProducerException(String.format("topic %s dose not exist", topic), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
         }
         if (topicMetadata.getProducerPolicy() == null) {
-            throw new ProducerException(String.format("topic %s producer %s is not exist", topic, config.getApp()), JoyQueueCode.FW_PRODUCER_NOT_EXISTS.getCode());
+            throw new ProducerException(String.format("topic %s producer %s dose not exist", topic, config.getApp()), JoyQueueCode.FW_PRODUCER_NOT_EXISTS.getCode());
         }
         return topicMetadata;
     }
@@ -147,4 +147,4 @@ protected void checkState() {
             throw new UnsupportedOperationException("txFeedbackManager is not started");
         }
     }
-}
+}
diff --git a/...ore/src/main/java/org/joyqueue/client/internal/producer/support/MessageProducerInner.java b/...ore/src/main/java/org/joyqueue/client/internal/producer/support/MessageProducerInner.java
@@ -301,10 +301,10 @@ protected List<SendResult> handleSendBatchResultData(String topic, String app, S
     public TopicMetadata getAndCheckTopicMetadata(String topic) {
         TopicMetadata topicMetadata = clusterManager.fetchTopicMetadata(getTopicFullName(topic), config.getApp());
         if (topicMetadata == null) {
-            throw new ProducerException(String.format("topic %s is not exist", topic), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
+            throw new ProducerException(String.format("topic %s dose not exist", topic), JoyQueueCode.FW_TOPIC_NOT_EXIST.getCode());
         }
         if (topicMetadata.getProducerPolicy() == null) {
-            throw new ProducerException(String.format("topic %s producer %s is not exist", topic, nameServerConfig.getApp()), JoyQueueCode.FW_PRODUCER_NOT_EXISTS.getCode());
+            throw new ProducerException(String.format("topic %s producer %s dose not exist", topic, nameServerConfig.getApp()), JoyQueueCode.FW_PRODUCER_NOT_EXISTS.getCode());
         }
         return topicMetadata;
     }
@@ -392,4 +392,4 @@ public PartitionMetadata dispatchPartitions(List<ProduceMessage> messages, Topic
     public boolean isFailover(List<ProduceMessage> messages) {
         return (messages.get(0).getPartition() == ProduceMessage.NONE_PARTITION);
     }
-}
+}
diff --git a/...nt-core/src/main/java/org/joyqueue/client/internal/support/DefaultMessageAccessPoint.java b/...nt-core/src/main/java/org/joyqueue/client/internal/support/DefaultMessageAccessPoint.java
@@ -172,7 +172,7 @@ public synchronized void removeTransactionCallback(String topic) {
         Preconditions.checkArgument(StringUtils.isNotBlank(topic), "topic can not be null");
         TxFeedbackManager txFeedbackManager = txFeedbackManagerMap.get(topic);
         if (txFeedbackManager == null) {
-            throw new IllegalArgumentException(String.format("%s feedback is not exist", topic));
+            throw new IllegalArgumentException(String.format("%s feedback dose not exist", topic));
         }
         txFeedbackManager.removeTransactionCallback(topic);
     }
@@ -242,4 +242,4 @@ protected TxFeedbackManager getTxFeedbackManager(TxFeedbackConfig config) {
         }
         return txFeedbackManager;
     }
-}
+}
diff --git a/...ue-data/joyqueue-data-service/src/main/java/org/joyqueue/api/Impl/OpenAPIServiceImpl.java b/...ue-data/joyqueue-data-service/src/main/java/org/joyqueue/api/Impl/OpenAPIServiceImpl.java
@@ -342,7 +342,7 @@ public Topic createTopic(Topic topic, List<Broker> select, Identity operator) th
     public void removeTopic(String namespace, String topicCode) throws Exception {
         Topic topic = topicService.findByCode(namespace, topicCode);
         if (topic == null) {
-            throw new BusinessException("topic is not exist");
+            throw new BusinessException("topic dose not exist");
         }
         topicService.delete(topic);
     }

diff --git a/...server/joyqueue-broker-core/src/main/java/org/joyqueue/broker/cluster/ClusterManager.java b/...server/joyqueue-broker-core/src/main/java/org/joyqueue/broker/cluster/ClusterManager.java
@@ -1096,7 +1096,7 @@ protected Consumer buildConsumeCache(Consumer consumer) {
 
         protected Consumer getConsumerByTopicAndApp(TopicName topic, String app) {
             if (!consumerCache.containsKey(topic.getFullName())) {
-                logger.warn("topic {} is not exist on this broker", topic.getFullName());
+                logger.warn("topic {} dose not exist on this broker", topic.getFullName());
                 return null;
             }
             CacheConsumer consumer = consumerCache.get(topic.getFullName()).get(app);
@@ -1110,7 +1110,7 @@ protected Consumer getConsumerByTopicAndApp(TopicName topic, String app) {
 
         protected Producer getProducerByTopicAndApp(TopicName topic, String app) {
             if (!producerCache.containsKey(topic.getFullName())) {
-                logger.warn("topic {} is not exist on this broker", topic.getFullName());
+                logger.warn("topic {} dose not exist on this broker", topic.getFullName());
                 return null;
             }
             CacheProducer producer = producerCache.get(topic.getFullName()).get(app);
@@ -1512,4 +1512,4 @@ protected void doStop() {
         }
         logger.info("clusterManager is stopped");
     }
-}
+}
diff --git a/...rotocol/src/main/java/org/joyqueue/broker/protocol/handler/AddConsumerRequestHandler.java b/...rotocol/src/main/java/org/joyqueue/broker/protocol/handler/AddConsumerRequestHandler.java
@@ -63,7 +63,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(addConsumerRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}", transport);
+            logger.warn("connection dose not exist, transport: {}", transport);
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -110,4 +110,4 @@ protected String generateConsumerId(Connection connection, String topic, String
     public int type() {
         return JoyQueueCommandType.ADD_CONSUMER_REQUEST.getCode();
     }
-}
+}
diff --git a/...rotocol/src/main/java/org/joyqueue/broker/protocol/handler/AddProducerRequestHandler.java b/...rotocol/src/main/java/org/joyqueue/broker/protocol/handler/AddProducerRequestHandler.java
@@ -63,7 +63,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(addProducerRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, addProducerRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, addProducerRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -110,4 +110,4 @@ protected String generateProducerId(Connection connection, String topic, String
     public int type() {
         return JoyQueueCommandType.ADD_PRODUCER_REQUEST.getCode();
     }
-}
+}
diff --git a/...-protocol/src/main/java/org/joyqueue/broker/protocol/handler/CommitAckRequestHandler.java b/...-protocol/src/main/java/org/joyqueue/broker/protocol/handler/CommitAckRequestHandler.java
@@ -86,7 +86,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(commitAckRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, commitAckRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, commitAckRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -249,4 +249,4 @@ private RetryMessageModel generateRetryMessage(Consumer consumer, BrokerMessage
     public int type() {
         return JoyQueueCommandType.COMMIT_ACK_REQUEST.getCode();
     }
-}
+}
diff --git a/...rotocol/src/main/java/org/joyqueue/broker/protocol/handler/CommitIndexRequestHandler.java b/...rotocol/src/main/java/org/joyqueue/broker/protocol/handler/CommitIndexRequestHandler.java
@@ -51,7 +51,7 @@ public Command handle(Transport transport, Command command) {
         String app = commitIndexRequest.getApp();
 
         if (connection == null || !connection.isAuthorized(app)) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, app);
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, app);
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -99,4 +99,4 @@ public Command handle(Transport transport, Command command) {
     public int type() {
         return JoyQueueCommandType.COMMIT_ACK_INDEX_REQUEST.getCode();
     }
-}
+}
diff --git a/.../main/java/org/joyqueue/broker/protocol/handler/FetchAssignedPartitionRequestHandler.java b/.../main/java/org/joyqueue/broker/protocol/handler/FetchAssignedPartitionRequestHandler.java
@@ -81,7 +81,7 @@ public Command handle(Transport transport, Command command) {
         String connectionId = ((InetSocketAddress) transport.remoteAddress()).getHostString();
 
         if (connection == null || !connection.isAuthorized(fetchAssignedPartitionRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, fetchAssignedPartitionRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, fetchAssignedPartitionRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -146,4 +146,4 @@ protected List<PartitionGroup> getTopicRegionPartitionGroup(TopicConfig topicCon
     public int type() {
         return JoyQueueCommandType.FETCH_ASSIGNED_PARTITION_REQUEST.getCode();
     }
-}
+}
diff --git a/...otocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchClusterRequestHandler.java b/...otocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchClusterRequestHandler.java
@@ -79,7 +79,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(fetchClusterRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, fetchClusterRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, fetchClusterRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -198,4 +198,4 @@ protected TopicPartition convertTopicPartition(PartitionGroup partitionGroup, sh
     public int type() {
         return JoyQueueCommandType.FETCH_CLUSTER_REQUEST.getCode();
     }
-}
+}
diff --git a/...protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchIndexRequestHandler.java b/...protocol/src/main/java/org/joyqueue/broker/protocol/handler/FetchIndexRequestHandler.java
@@ -62,7 +62,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(fetchIndexRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, fetchIndexRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, fetchIndexRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -103,4 +103,4 @@ protected FetchIndexData fetchIndex(Connection connection, Consumer consumer, sh
     public int type() {
         return JoyQueueCommandType.FETCH_INDEX_REQUEST.getCode();
     }
-}
+}
diff --git a/...c/main/java/org/joyqueue/broker/protocol/handler/FetchPartitionMessageRequestHandler.java b/...c/main/java/org/joyqueue/broker/protocol/handler/FetchPartitionMessageRequestHandler.java
@@ -74,7 +74,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(fetchPartitionMessageRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, fetchPartitionMessageRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, fetchPartitionMessageRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -157,4 +157,4 @@ protected FetchPartitionMessageAckData fetchMessage(Transport transport, Consume
     public int type() {
         return JoyQueueCommandType.FETCH_PARTITION_MESSAGE_REQUEST.getCode();
     }
-}
+}
diff --git a/...rc/main/java/org/joyqueue/broker/protocol/handler/FetchProduceFeedbackRequestHandler.java b/...rc/main/java/org/joyqueue/broker/protocol/handler/FetchProduceFeedbackRequestHandler.java
@@ -70,7 +70,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(fetchProduceFeedbackRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}", transport, fetchProduceFeedbackRequest.getApp());
+            logger.warn("connection dose not exist, transport: {}, app: {}", transport, fetchProduceFeedbackRequest.getApp());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -117,4 +117,4 @@ protected List<FetchProduceFeedbackAckData> buildFeedbackAckData(List<Transactio
     public int type() {
         return JoyQueueCommandType.FETCH_PRODUCE_FEEDBACK_REQUEST.getCode();
     }
-}
+}
diff --git a/...l/src/main/java/org/joyqueue/broker/protocol/handler/FetchTopicMessageRequestHandler.java b/...l/src/main/java/org/joyqueue/broker/protocol/handler/FetchTopicMessageRequestHandler.java
@@ -82,7 +82,7 @@ public Command handle(Transport transport, Command command) {
         Connection connection = SessionHelper.getConnection(transport);
 
         if (connection == null || !connection.isAuthorized(fetchTopicMessageRequest.getApp())) {
-            logger.warn("connection is not exists, transport: {}, app: {}, topics: {}", transport, fetchTopicMessageRequest.getApp(), fetchTopicMessageRequest.getTopics().keySet());
+            logger.warn("connection dose not exist, transport: {}, app: {}, topics: {}", transport, fetchTopicMessageRequest.getApp(), fetchTopicMessageRequest.getTopics().keySet());
             return BooleanAck.build(JoyQueueCode.FW_CONNECTION_NOT_EXISTS.getCode());
         }
 
@@ -108,7 +108,7 @@ public Command handle(Transport transport, Command command) {
             Consumer consumer = (StringUtils.isBlank(consumerId) ? null : sessionManager.getConsumerById(consumerId));
 
             if (consumer == null) {
-                logger.warn("connection is not exists, transport: {}, app: {}, topics: {}", transport, fetchTopicMessageRequest.getApp(), fetchTopicMessageRequest.getTopics().keySet());
+                logger.warn("connection dose not exist, transport: {}, app: {}, topics: {}", transport, fetchTopicMessageRequest.getApp(), fetchTopicMessageRequest.getTopics().keySet());
                 result.put(topic, new FetchTopicMessageAckData(CheckResultConverter.convertFetchCode(command.getHeader().getVersion(), JoyQueueCode.FW_CONSUMER_NOT_EXISTS)));
                 continue;
             }
@@ -157,4 +157,4 @@ protected FetchTopicMessageAckData fetchMessage(Transport transport, Consumer co
     public int type() {
         return JoyQueueCommandType.FETCH_TOPIC_MESSAGE_REQUEST.getCode();
     }
-}
+}