valitydev/hooker
14
0
Fork 0
mirror of https://github.com/valitydev/hooker.git synced 2024-11-06 08:15:17 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Disable updateAvailability (#147)

Browse Source 
* Disable updateAvailability

* Bump parent pom

* Bump kafka common lib
This commit is contained in:
Inal Arsanukaev 2021-06-28 11:35:12 +03:00 committed by GitHub
parent 28ef87522f
commit 26ced432e7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pom.xml
View File

@ -13,7 +13,7 @@
<parent>
<groupId>com.rbkmoney</groupId>
<artifactId>service-parent-pom</artifactId>
<version>1.2.2</version>
<version>1.2.7</version>
</parent>
<properties>
@ -103,6 +103,7 @@
<dependency>
<groupId>com.rbkmoney</groupId>
<artifactId>kafka-common-lib</artifactId>
<version>0.1.8</version>
</dependency>
<dependency>
<groupId>com.rbkmoney</groupId>

2
src/main/java/com/rbkmoney/hooker/configuration/KafkaConfig.java
View File

@ -104,7 +104,6 @@ public class KafkaConfig {
new ConcurrentKafkaListenerContainerFactory<>();
factory.setConsumerFactory(consumerFactory);
factory.setBatchListener(true);
factory.getContainerProperties().setAckOnError(false);
factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.MANUAL);
factory.setBatchErrorHandler(kafkaErrorHandler());
factory.setConcurrency(invoicingConcurrency);
@ -120,7 +119,6 @@ public class KafkaConfig {
new ConcurrentKafkaListenerContainerFactory<>();
factory.setConsumerFactory(consumerFactory);
factory.setBatchListener(false);
factory.getContainerProperties().setAckOnError(false);
factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.MANUAL);
factory.setErrorHandler(new SeekToCurrentErrorHandler());
factory.setConcurrency(customerConcurrency);

6
src/main/java/com/rbkmoney/hooker/service/MessageProcessor.java
View File

@ -111,8 +111,8 @@ public class MessageProcessor<M extends Message, Q extends Queue> implements Run
}
private void updateAvailability(Queue queue) {
double rate = faultDetector.getRate(queue.getHook().getId());
hookDao.updateAvailability(queue.getHook().getId(), rate);
log.info("Hook {} availability has been updated to {}", queue.getHook().getId(), rate);
//double rate = faultDetector.getRate(queue.getHook().getId());
//hookDao.updateAvailability(queue.getHook().getId(), rate);
//log.info("Hook {} availability has been updated to {}", queue.getHook().getId(), rate);
}
}