---
adding java doc for tests
This commit is contained in:
psemenkov 2022-09-20 18:26:49 +03:00
parent cc01789369
commit 0bb08e59c4
2 changed files with 56 additions and 9 deletions

View file

@ -44,9 +44,9 @@ import java.util.HashMap;
HazelcastInstanceTestConfiguration.class})
public class MoneyMarketSecurityServiceTest {
static final ObjectMapper objectMapper = new ObjectMapper();
private MockConsumer<String, Object> kafkaMockQueue;
private final int TIMEOUT = 1000;
boolean isUsed;
private MockConsumer<String, Object> kafkaMockQueue;
@Autowired
@Qualifier("hazelcastServiceTest")
private HazelcastService hazelcastService;
@ -54,8 +54,6 @@ public class MoneyMarketSecurityServiceTest {
@Qualifier("hazelcastInstance")
private HazelcastInstance hz;
boolean isUsed;
private void setIsUsed(boolean isUsed) {
this.isUsed = isUsed;
}
@ -91,6 +89,18 @@ public class MoneyMarketSecurityServiceTest {
keyRateService.afterPropertiesSet();
}
/**
* {@link MoneyMarketSecurityService#newMoneyMarket(BaseRequest)}<br>
* Тест проверяет генерацию сущности {@link MoneyMarketSecurity} в Hazelcast при передаче из Apache Kafka.<br>
* Входной запрос {@link MoneyMarketSecurityNewRequest}:<br>
* {@link MoneyMarketSecurityNewRequest#lotSize} - 1.0<br>
* {@link MoneyMarketSecurityNewRequest#startDate} - текущее колличество секунд с 1970-01-01T00:00:00Z.<br>
* {@link MoneyMarketSecurityNewRequest#endDate} - текущее колличество секунд с 1970-01-01T00:00:00Z.<br>
* {@link MoneyMarketSecurityNewRequest#nominalValue} - 1.0<br>
* {@link MoneyMarketSecurityNewRequest#nominalCurrencyId} - 1L<br>
* {@link MoneyMarketSecurityNewRequest#instrumentType} - "sdgaga"<br>
* {@link MoneyMarketSecurityNewRequest#fullName} - "estat"<br>
*/
@Test
public void testNewMoneyMarketSecurity() throws InterruptedException {
final String TOPIC = Consts.DESTINATION_MONEY_MARKET_SECURITY_NEW;
@ -154,6 +164,12 @@ public class MoneyMarketSecurityServiceTest {
iMap.removeEntryListener(listenerID);
}
/**
* {@link MoneyMarketSecurityService#deleteMoneyMarket(BaseRequest)}<br>
* Тест проверяет удаление сущности {@link MoneyMarketSecurity} в Hazelcast при передаче из Apache Kafka.<br>
* Входной запрос {@link CommonDeleteRequest}:<br>
* {@link CommonDeleteRequest#id} - Идентификатор записи<br>
*/
@Test
public void testDeleteKeyRate() throws InterruptedException {
final String TOPIC = Consts.DESTINATION_MONEY_MARKET_SECURITY_DELETE;
@ -215,7 +231,16 @@ public class MoneyMarketSecurityServiceTest {
iMap.removeEntryListener(listenerID);
}
/**
* {@link MoneyMarketSecurityService#updateMoneyMarket(BaseRequest)}
* Тест проверяет обновление сущности {@link MoneyMarketSecurity} в Hazelcast при передаче из Apache Kafka.<br>
* Входной запрос {@link MoneyMarketSecurityUpdateRequest}:<br>
* {@link MoneyMarketSecurityUpdateRequest#fullName} - sfgsdfg<br>
* {@link MoneyMarketSecurityUpdateRequest#instrumentType} - qwerqwe<br>
* {@link MoneyMarketSecurityUpdateRequest#nominalCurrencyId} - 2L<br>
* {@link MoneyMarketSecurityUpdateRequest#nominalValue} - 2.0<br>
* {@link MoneyMarketSecurityUpdateRequest#endDate} - текущее колличество секунд с 1970-01-01T00:00:00Z + (24 * 3600)<br>
*/
@Test
public void testUpdateKeyRate() throws InterruptedException {
final String TOPIC = Consts.DESTINATION_MONEY_MARKET_SECURITY_UPDATE;

View file

@ -41,9 +41,9 @@ import java.util.HashMap;
HazelcastInstanceTestConfiguration.class})
public class KeyRateServiceTest {
static final ObjectMapper objectMapper = new ObjectMapper();
private MockConsumer<String, Object> kafkaMockQueue;
private final int TIMEOUT = 1000;
boolean isUsed;
private MockConsumer<String, Object> kafkaMockQueue;
@Autowired
@Qualifier("hazelcastServiceTest")
private HazelcastService hazelcastService;
@ -51,8 +51,6 @@ public class KeyRateServiceTest {
@Qualifier("hazelcastInstance")
private HazelcastInstance hz;
boolean isUsed;
private void setIsUsed(boolean isUsed) {
this.isUsed = isUsed;
}
@ -88,6 +86,15 @@ public class KeyRateServiceTest {
keyRateService.afterPropertiesSet();
}
/**
* {@link KeyRateService#newKeyRate(BaseRequest)}
* Тест проверяет генерацию сущности {@link KeyRate} в Hazelcast при передаче из Apache Kafka.<br>
* Входной запрос {@link KeyRateNewRequest}:<br>
* {@link KeyRateNewRequest#keyRate} - 0.5<br>
* {@link KeyRateNewRequest#document} - "Test"<br>
* {@link KeyRateNewRequest#startDate} - текущее колличество секунд с 1970-01-01T00:00:00Z.<br>
* {@link KeyRateNewRequest#endDate} - текущее колличество секунд с 1970-01-01T00:00:00Z.<br>
*/
@Test
public void testNewKeyRate() throws InterruptedException {
final String TOPIC = Consts.DESTINATION_KEY_RATE_NEW;
@ -150,6 +157,12 @@ public class KeyRateServiceTest {
iMap.removeEntryListener(listenerID);
}
/**
* {@link KeyRateService#deleteKeyRate(BaseRequest)}<br>
* Тест проверяет удаление сущности {@link KeyRate} в Hazelcast при передаче из Apache Kafka.<br>
* Входной запрос {@link CommonDeleteRequest}:<br>
* {@link CommonDeleteRequest#id} - Идентификатор записи<br>
*/
@Test
public void testDeleteKeyRate() throws InterruptedException {
final String TOPIC = Consts.DESTINATION_KEY_RATE_DELETE;
@ -209,6 +222,15 @@ public class KeyRateServiceTest {
iMap.removeEntryListener(listenerID);
}
/**
* {@link KeyRateService#updateKeyRate(BaseRequest)}
* Тест проверяет генерацию сущности {@link KeyRate} в Hazelcast при передаче из Apache Kafka.<br>
* Входной запрос {@link KeyRateUpdateRequest}:<br>
* {@link KeyRateUpdateRequest#keyRate} - 5<br>
* {@link KeyRateUpdateRequest#document} - "Update"<br>
* {@link KeyRateUpdateRequest#startDate} - текущее колличество секунд с 1970-01-01T00:00:00Z + (24 * 3600)<br>
* {@link KeyRateUpdateRequest#endDate} - текущее колличество секунд с 1970-01-01T00:00:00Z + (24 * 3600)<br>
*/
@Test
public void testUpdateKeyRate() throws InterruptedException {
final String TOPIC = Consts.DESTINATION_KEY_RATE_UPDATE;