Skip to content

Commit

Permalink
update version in readme & move pom version to next snapshot
Browse files Browse the repository at this point in the history
  • Loading branch information
SreeramGarlapati committed May 28, 2016
1 parent e18a480 commit 0d73ef8
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 6 deletions.
2 changes: 1 addition & 1 deletion java/ConsumingEvents.md
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ following dependency declaration inside of your Maven project file:
<dependency>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-eventhubs-clients</artifactId>
<version>0.7.0</version>
<version>0.7.1</version>
</dependency>
```

Expand Down
2 changes: 1 addition & 1 deletion java/PublishingEvents.md
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ following dependency declaration inside of your Maven project file:
<dependency>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-eventhubs-clients</artifactId>
<version>0.7.0</version>
<version>0.7.1</version>
</dependency>
```

Expand Down
2 changes: 1 addition & 1 deletion java/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
<properties>
<proton-j-version>0.12.2</proton-j-version>
<junit-version>4.10</junit-version>
<client-current-version>0.7.1</client-current-version>
<client-current-version>0.7.2-SNAPSHOT</client-current-version>
</properties>

<build>
Expand Down
8 changes: 5 additions & 3 deletions java/readme.md
Original file line number Diff line number Diff line change
Expand Up @@ -105,13 +105,15 @@ an offset, in the snippet below it's simply the start of the log.
partitionId,
PartitionReceiver.StartOfStream,
false).get();

receiver.setReceiveTimeout(Duration.ofSeconds(5));
```

Once the receiver is initialized, getting events is just a matter of calling the *receive()* method in a loop. Each call
to *receive()* will fetch an eneumerable batch of events to process.
to *receive()* will fetch an enumerable batch of events to process.

```Java
Iterable<EventData> receivedEvents = receiver.receive().get();
Iterable<EventData> receivedEvents = receiver.receive(maxEventsCount).get();
```

As you might imagine, there's quite a bit more to know about partitions, about distributing the workload of processing huge and
Expand All @@ -134,7 +136,7 @@ the required version of Apache Qpid Proton-J, and the crytography library BCPKIX
<dependency>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-eventhubs</artifactId>
<version>0.7.0</version>
<version>0.7.1</version>
</dependency>
```

Expand Down

0 comments on commit 0d73ef8

Please sign in to comment.