This commit is contained in:
@@ -20,7 +20,7 @@ public class EateryServiceTest {
|
||||
|
||||
@Test
|
||||
@ActivateRequestContext
|
||||
void testConsumeManagerSignup() {
|
||||
void testConsumeManagerSignup() throws InterruptedException {
|
||||
// 1. Chuẩn bị dữ liệu giả lập
|
||||
ManagerCreate input = new ManagerCreate();
|
||||
input.id = UUID.randomUUID(); // Giả sử manager ID là 99
|
||||
@@ -29,6 +29,8 @@ public class EateryServiceTest {
|
||||
// 2. Đẩy tin nhắn vào channel "manager-in" bằng InMemoryConnector
|
||||
connector.source("manager-in").send(input);
|
||||
|
||||
Thread.sleep(1000);
|
||||
|
||||
// 3. Kiểm tra kết quả trong Database
|
||||
// Lưu ý: Vì xử lý Kafka là bất đồng bộ, đôi khi cần đợi vài miligiây
|
||||
// nhưng với InMemoryConnector thì thường là tức thì.
|
||||
|
||||
Reference in New Issue
Block a user