Sessions support (#25)

* Chaning directory structure to align maven standard directory structure. Also changes to pom.xml files to align Maven standard build process like running tests. * Removing an unwanted file that was accidentally checked in. * Implemented Peek and PeekBatch functionality. Added some tests. * Implementation of ReceiveBySequenceNumber and Complete,Abandon,Defer,DeadLetter of messages received by sequence numbers. * WIP Sessions support * Full implementation of AcceptSession, receive features on sessions, renew lock, getState and set state. * Implementation of browse sessions. * Adding tests for topic-subscription cases
mssfang · Mar 14, 2017 · 9af284c · 9af284c
1 parent e7ef1df
commit 9af284c
Show file tree

Hide file tree

Showing 29 changed files with 2,043 additions and 902 deletions.
diff --git a/...ervicebus-samples/src/main/java/com/microsoft/azure/servicebus/samples/ReceiveSample.java b/...ervicebus-samples/src/main/java/com/microsoft/azure/servicebus/samples/ReceiveSample.java
@@ -34,7 +34,7 @@ private static void receiveMessages() throws InterruptedException, ServiceBusExc
 		while (true) {
 			IBrokeredMessage receivedMessage = receiver.receive(Duration.ofMinutes(1));
 			System.out.println(new String(receivedMessage.getContent()));
-			receiver.complete(receivedMessage);
+			receiver.complete(receivedMessage.getLockToken());
 		}
 	}
 

diff --git a/azure-servicebus/resources/access.properties.template b/azure-servicebus/resources/access.properties.template
@@ -1,4 +1,23 @@
-namespacename=yournamespace
-entitypath=yourentitypath
-sharedaccesskeyname=yoursharedaccesskey
-sharedaccesskey=yoursharedaccesskey
+# non-partitioned queue with no sessions
+queue.namespacename=yournamespace
+queue.entitypath=yourentitypath
+queue.sharedaccesskeyname=yoursharedaccesskey
+queue.sharedaccesskey=yoursharedaccesskey
+# non-partitioned queue with sessions
+queue.sessionful.namespacename=yournamespace
+queue.sessionful.entitypath=yourentitypath
+queue.sessionful.sharedaccesskeyname=yoursharedaccesskey
+queue.sessionful.sharedaccesskey=yoursharedaccesskey
+# non-partitioned topic/subscription with no sessions
+topic.namespacename=yournamespace
+topic.entitypath=yourentitypath
+subscription.entitypath=yoursubscriptionpath
+topic.sharedaccesskeyname=yoursharedaccesskey
+topic.sharedaccesskey=yoursharedaccesskey
+# non-partitioned topic/subscription with sessions
+topic.sessionful.namespacename=yournamespace
+topic.sessionful.entitypath=yourentitypath
+subscription.sessionful.entitypath=yoursubscriptionpath
+topic.sessionful.sharedaccesskeyname=yoursharedaccesskey
+topic.sessionful.sharedaccesskey=yoursharedaccesskey
+
diff --git a/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/BrokeredMessageBrowser.java b/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/BrokeredMessageBrowser.java