update the testcases after the kafka 11 changes

Issue-ID: DMAAP-526
Change-Id: I477a8ee05fb3cdd76af726b6ca0d1a69aa9eef93
Signed-off-by: sunil unnava <su622b@att.com>

1 files changed, 5 insertions, 4 deletions

diff --git a/src/test/java/com/att/nsa/cambria/beans/DMaaPCambriaLimiterTest.java b/src/test/java/com/att/nsa/cambria/beans/DMaaPCambriaLimiterTest.java
index 10f2613..8c3568f 100644
--- a/src/test/java/com/att/nsa/cambria/beans/DMaaPCambriaLimiterTest.java
+++ b/src/test/java/com/att/nsa/cambria/beans/DMaaPCambriaLimiterTest.java
@@ -26,7 +26,8 @@ import org.junit.After;
 import org.junit.Before;

 import org.junit.Test;

 

-import com.att.nsa.cambria.CambriaApiException;

+import com.att.dmf.mr.CambriaApiException;

+import com.att.dmf.mr.beans.DMaaPCambriaLimiter;

 

 public class DMaaPCambriaLimiterTest {

 

@@ -53,9 +54,9 @@ public class DMaaPCambriaLimiterTest {
 	@Test

 	public void testOnCall() {

 		

-		DMaaPCambriaLimiter limiter = new DMaaPCambriaLimiter(1, 3);

+		DMaaPCambriaLimiter limiter = new DMaaPCambriaLimiter(1,2, 3);

 		try {

-			limiter.onCall("testTopic", "ConsumerGroup1", "client2");

+			limiter.onCall("testTopic", "ConsumerGroup1", "client2","remoteHost");

 		} catch (CambriaApiException e) {

 			// TODO Auto-generated catch block

 			e.printStackTrace();

@@ -69,7 +70,7 @@ public class DMaaPCambriaLimiterTest {
 	@Test

 	public void testOnSend() {

 		

-		DMaaPCambriaLimiter limiter = new DMaaPCambriaLimiter(3, 3);

+		DMaaPCambriaLimiter limiter = new DMaaPCambriaLimiter(3,3, 3);

 		limiter.onSend("testTopic", "consumerGroup1", "client1", 100);

 		

 		String trueValue = "True";