diff options
author | Tor Brede Vekterli <vekterli@oath.com> | 2018-01-26 16:39:19 +0100 |
---|---|---|
committer | Geir Storli <geirst@yahoo-inc.com> | 2018-02-01 13:30:41 +0000 |
commit | 1283af0464c83ae836ae87ecc8db907e94b5e827 (patch) | |
tree | 2f928515aa3028c6c8e0e08a28bb3e2db04e13fa /documentapi | |
parent | b532e8ecd3d3d804980b762437d3700dc15d4e8f (diff) |
Add GetBucketList test for Java
Diffstat (limited to 'documentapi')
-rw-r--r-- | documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/Messages60TestCase.java | 22 |
1 files changed, 22 insertions, 0 deletions
diff --git a/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/Messages60TestCase.java b/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/Messages60TestCase.java index 2335f4556fe..6e7990f8f3c 100644 --- a/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/Messages60TestCase.java +++ b/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/Messages60TestCase.java @@ -6,6 +6,7 @@ import com.yahoo.document.BucketId; import com.yahoo.document.select.OrderingSpecification; import com.yahoo.documentapi.messagebus.protocol.CreateVisitorMessage; import com.yahoo.documentapi.messagebus.protocol.DocumentProtocol; +import com.yahoo.documentapi.messagebus.protocol.GetBucketListMessage; import com.yahoo.documentapi.messagebus.protocol.StatBucketMessage; import com.yahoo.text.Utf8; @@ -34,6 +35,7 @@ public class Messages60TestCase extends Messages52TestCase { out.put(DocumentProtocol.MESSAGE_CREATEVISITOR, new Messages60TestCase.testCreateVisitorMessage()); out.put(DocumentProtocol.MESSAGE_STATBUCKET, new Messages60TestCase.testStatBucketMessage()); + out.put(DocumentProtocol.MESSAGE_GETBUCKETLIST, new Messages60TestCase.testGetBucketListMessage()); } public class testCreateVisitorMessage implements RunnableTest { @@ -100,6 +102,26 @@ public class Messages60TestCase extends Messages52TestCase { } } + public class testGetBucketListMessage implements RunnableTest { + + private static final String BUCKET_SPACE = "beartato"; + + @Override + public void run() { + GetBucketListMessage msg = new GetBucketListMessage(new BucketId(16, 123)); + msg.setLoadType(loadTypes.getNameMap().get("foo")); + msg.setBucketSpace(BUCKET_SPACE); + assertEquals(BASE_MESSAGE_LENGTH + 12 + serializedLength(BUCKET_SPACE), serialize("GetBucketListMessage", msg)); + + for (Language lang : LANGUAGES) { + msg = (GetBucketListMessage)deserialize("GetBucketListMessage", DocumentProtocol.MESSAGE_GETBUCKETLIST, lang); + assertEquals(new BucketId(16, 123), msg.getBucketId()); + assertEquals("foo", msg.getLoadType().getName()); + assertEquals(BUCKET_SPACE, msg.getBucketSpace()); + } + } + } + // TODO want to test that non-default bucket space fails to encode with old version } |