Added tests for monostate pattern
This commit is contained in:
parent
6fe01e73b2
commit
531158c836
@ -14,5 +14,10 @@
|
|||||||
<artifactId>junit</artifactId>
|
<artifactId>junit</artifactId>
|
||||||
<scope>test</scope>
|
<scope>test</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.mockito</groupId>
|
||||||
|
<artifactId>mockito-core</artifactId>
|
||||||
|
<scope>test</scope>
|
||||||
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
</project>
|
</project>
|
||||||
|
@ -28,8 +28,8 @@ public class App {
|
|||||||
public static void main(String[] args) {
|
public static void main(String[] args) {
|
||||||
LoadBalancer loadBalancer1 = new LoadBalancer();
|
LoadBalancer loadBalancer1 = new LoadBalancer();
|
||||||
LoadBalancer loadBalancer2 = new LoadBalancer();
|
LoadBalancer loadBalancer2 = new LoadBalancer();
|
||||||
loadBalancer1.serverequest(new Request("Hello"));
|
loadBalancer1.serverRequest(new Request("Hello"));
|
||||||
loadBalancer2.serverequest(new Request("Hello World"));
|
loadBalancer2.serverRequest(new Request("Hello World"));
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@ -39,7 +39,7 @@ public class LoadBalancer {
|
|||||||
return lastServedId;
|
return lastServedId;
|
||||||
}
|
}
|
||||||
|
|
||||||
public void serverequest(Request request) {
|
public void serverRequest(Request request) {
|
||||||
if (lastServedId >= servers.size()) {
|
if (lastServedId >= servers.size()) {
|
||||||
lastServedId = 0;
|
lastServedId = 0;
|
||||||
}
|
}
|
||||||
|
@ -25,7 +25,7 @@ public class Server {
|
|||||||
return port;
|
return port;
|
||||||
}
|
}
|
||||||
|
|
||||||
public final void serve(Request request) {
|
public void serve(Request request) {
|
||||||
System.out.println("Server ID " + id + " associated to host : " + getHost() + " and Port "
|
System.out.println("Server ID " + id + " associated to host : " + getHost() + " and Port "
|
||||||
+ getPort() + " Processed request with value " + request.value);
|
+ getPort() + " Processed request with value " + request.value);
|
||||||
}
|
}
|
||||||
|
@ -5,17 +5,6 @@ import org.junit.Test;
|
|||||||
|
|
||||||
public class AppTest {
|
public class AppTest {
|
||||||
|
|
||||||
@Test
|
|
||||||
public void testSameStateAmonstAllInstances() {
|
|
||||||
LoadBalancer balancer = new LoadBalancer();
|
|
||||||
LoadBalancer balancer2 = new LoadBalancer();
|
|
||||||
balancer.addServer(new Server("localhost", 8085, 6));
|
|
||||||
// Both should have the same number of servers.
|
|
||||||
Assert.assertTrue(balancer.getNoOfServers() == balancer2.getNoOfServers());
|
|
||||||
// Both Should have the same LastServedId
|
|
||||||
Assert.assertTrue(balancer.getLastServedId() == balancer2.getLastServedId());
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void testMain() {
|
public void testMain() {
|
||||||
String[] args = {};
|
String[] args = {};
|
||||||
|
@ -0,0 +1,49 @@
|
|||||||
|
package com.iluwatar.monostate;
|
||||||
|
|
||||||
|
import org.junit.Assert;
|
||||||
|
import org.junit.Test;
|
||||||
|
|
||||||
|
import static org.mockito.Mockito.mock;
|
||||||
|
import static org.mockito.Mockito.times;
|
||||||
|
import static org.mockito.Mockito.verify;
|
||||||
|
import static org.mockito.Mockito.verifyNoMoreInteractions;
|
||||||
|
import static org.mockito.Mockito.verifyZeroInteractions;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Date: 12/21/15 - 12:26 PM
|
||||||
|
*
|
||||||
|
* @author Jeroen Meulemeester
|
||||||
|
*/
|
||||||
|
public class LoadBalancerTest {
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testSameStateAmongstAllInstances() {
|
||||||
|
final LoadBalancer firstBalancer = new LoadBalancer();
|
||||||
|
final LoadBalancer secondBalancer = new LoadBalancer();
|
||||||
|
firstBalancer.addServer(new Server("localhost", 8085, 6));
|
||||||
|
// Both should have the same number of servers.
|
||||||
|
Assert.assertTrue(firstBalancer.getNoOfServers() == secondBalancer.getNoOfServers());
|
||||||
|
// Both Should have the same LastServedId
|
||||||
|
Assert.assertTrue(firstBalancer.getLastServedId() == secondBalancer.getLastServedId());
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testServe() {
|
||||||
|
final Server server = mock(Server.class);
|
||||||
|
|
||||||
|
final LoadBalancer loadBalancer = new LoadBalancer();
|
||||||
|
loadBalancer.addServer(server);
|
||||||
|
|
||||||
|
verifyZeroInteractions(server);
|
||||||
|
|
||||||
|
final Request request = new Request("test");
|
||||||
|
for (int i = 0; i < loadBalancer.getNoOfServers() * 2; i++) {
|
||||||
|
loadBalancer.serverRequest(request);
|
||||||
|
}
|
||||||
|
|
||||||
|
verify(server, times(2)).serve(request);
|
||||||
|
verifyNoMoreInteractions(server);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
Loading…
x
Reference in New Issue
Block a user