projects
/
demos
/
kafka
/
chat
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
WIP:haproxy
[demos/kafka/chat]
/
src
/
test
/
java
/
de
/
juplo
/
kafka
/
chat
/
backend
/
api
/
ChatBackendControllerTest.java
diff --git
a/src/test/java/de/juplo/kafka/chat/backend/api/ChatBackendControllerTest.java
b/src/test/java/de/juplo/kafka/chat/backend/api/ChatBackendControllerTest.java
index
1478e7c
..
01de390
100644
(file)
--- a/
src/test/java/de/juplo/kafka/chat/backend/api/ChatBackendControllerTest.java
+++ b/
src/test/java/de/juplo/kafka/chat/backend/api/ChatBackendControllerTest.java
@@
-259,8
+259,9
@@
public class ChatBackendControllerTest
{
// Given
UUID chatroomId = UUID.randomUUID();
{
// Given
UUID chatroomId = UUID.randomUUID();
+ String instanceId = "peter";
int shard = 666;
int shard = 666;
- when(chatHomeService.getChatRoomInfo(eq(chatroomId))).thenThrow(new ShardNotOwnedException(shard));
+ when(chatHomeService.getChatRoomInfo(eq(chatroomId))).thenThrow(new ShardNotOwnedException(
instanceId,
shard));
// When
WebTestClient.ResponseSpec responseSpec = client
// When
WebTestClient.ResponseSpec responseSpec = client
@@
-279,8
+280,9
@@
public class ChatBackendControllerTest
{
// Given
UUID chatroomId = UUID.randomUUID();
{
// Given
UUID chatroomId = UUID.randomUUID();
+ String instanceId = "peter";
int shard = 666;
int shard = 666;
- when(chatHomeService.getChatRoomData(eq(chatroomId))).thenThrow(new ShardNotOwnedException(shard));
+ when(chatHomeService.getChatRoomData(eq(chatroomId))).thenThrow(new ShardNotOwnedException(
instanceId,
shard));
// When
WebTestClient.ResponseSpec responseSpec = client
// When
WebTestClient.ResponseSpec responseSpec = client
@@
-301,8
+303,9
@@
public class ChatBackendControllerTest
UUID chatroomId = UUID.randomUUID();
String username = "foo";
Long messageId = 66l;
UUID chatroomId = UUID.randomUUID();
String username = "foo";
Long messageId = 66l;
+ String instanceId = "peter";
int shard = 666;
int shard = 666;
- when(chatHomeService.getChatRoomData(eq(chatroomId))).thenThrow(new ShardNotOwnedException(shard));
+ when(chatHomeService.getChatRoomData(eq(chatroomId))).thenThrow(new ShardNotOwnedException(
instanceId,
shard));
// When
WebTestClient.ResponseSpec responseSpec = client
// When
WebTestClient.ResponseSpec responseSpec = client
@@
-328,8
+331,9
@@
public class ChatBackendControllerTest
UUID chatroomId = UUID.randomUUID();
String username = "foo";
Long messageId = 66l;
UUID chatroomId = UUID.randomUUID();
String username = "foo";
Long messageId = 66l;
+ String instanceId = "peter";
int shard = 666;
int shard = 666;
- when(chatHomeService.getChatRoomData(eq(chatroomId))).thenThrow(new ShardNotOwnedException(shard));
+ when(chatHomeService.getChatRoomData(eq(chatroomId))).thenThrow(new ShardNotOwnedException(
instanceId,
shard));
// When
WebTestClient.ResponseSpec responseSpec = client
// When
WebTestClient.ResponseSpec responseSpec = client
@@
-352,8
+356,9
@@
public class ChatBackendControllerTest
{
// Given
UUID chatroomId = UUID.randomUUID();
{
// Given
UUID chatroomId = UUID.randomUUID();
+ String instanceId = "peter";
int shard = 666;
int shard = 666;
- when(chatHomeService.getChatRoomData(eq(chatroomId))).thenThrow(new ShardNotOwnedException(shard));
+ when(chatHomeService.getChatRoomData(eq(chatroomId))).thenThrow(new ShardNotOwnedException(
instanceId,
shard));
// When
WebTestClient.ResponseSpec responseSpec = client
// When
WebTestClient.ResponseSpec responseSpec = client