valitydev/wb-list-manager
14
0
Fork 0
mirror of https://github.com/valitydev/wb-list-manager.git synced 2024-11-06 01:35:17 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

refactoring test

Browse Source
This commit is contained in:
ggmaleva 2021-09-29 11:24:17 +03:00
parent 7987ecac0b
commit 6d3ef0d162
No known key found for this signature in database
GPG Key ID: 0E412B78565B108F
2 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/test/java/com/rbkmoney/wb/list/manager/WbListManagerApplicationTest.java
View File

@ -6,7 +6,6 @@ import com.rbkmoney.testcontainers.annotations.kafka.KafkaTestcontainer;
import com.rbkmoney.wb.list.manager.extension.RiakContainerExtension;
import com.rbkmoney.wb.list.manager.utils.ChangeCommandWrapper;
import com.rbkmoney.woody.thrift.impl.http.THClientBuilder;
import lombok.extern.slf4j.Slf4j;
import org.apache.thrift.TBase;
import org.apache.thrift.TException;
import org.junit.jupiter.api.BeforeEach;
@ -31,7 +30,6 @@ import static org.junit.jupiter.api.Assertions.*;
import static org.springframework.boot.test.context.SpringBootTest.WebEnvironment.RANDOM_PORT;
import static org.testcontainers.shaded.com.trilead.ssh2.ChannelCondition.TIMEOUT;
@Slf4j
@ExtendWith({RiakContainerExtension.class})
@SpringBootTest(webEnvironment = RANDOM_PORT)
@KafkaSpringBootTest
@ -104,8 +102,7 @@ public class WbListManagerApplicationTest {
}
@Test
// TODO refactoring
void kafkaRowTest() throws Exception {
void kafkaRowTest() throws Exception { // TODO refactoring
Row row = createRowOld();
ChangeCommand changeCommand = createCommand(row);
row.setShopId(null);

2
src/test/java/com/rbkmoney/wb/list/manager/ConsumerConfig.java → src/test/java/com/rbkmoney/wb/list/manager/config/ConsumerConfig.java
View File

@ -1,4 +1,4 @@
package com.rbkmoney.wb.list.manager;
package com.rbkmoney.wb.list.manager.config;
import com.rbkmoney.damsel.wb_list.Event;
import com.rbkmoney.testcontainers.annotations.kafka.config.KafkaConsumer;