Skip to content

Commit

Permalink
Update javaclient version in the readme
Browse files Browse the repository at this point in the history
  • Loading branch information
SreeramGarlapati committed May 25, 2016
1 parent 3515564 commit 68d0a14
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 6 deletions.
10 changes: 6 additions & 4 deletions 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.6.9</version>
<version>0.7.0</version>
</dependency>
```

Expand Down Expand Up @@ -64,19 +64,21 @@ The receiver code then creates (at least) one *PartitionReceiver* that will rece
an offset, in the snippet below it's simply the start of the log.

```Java
String partitionId = "0"; // API to get PartitionIds will be released as part of V0.2
String partitionId = "0"; // API to get PartitionIds will be released soon
PartitionReceiver receiver = ehClient.createReceiver(
EventHubClient.DefaultConsumerGroupName,
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 iterable batch of events to process.

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

##Consumer Groups
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.6.9</version>
<version>0.7.0</version>
</dependency>
```

Expand Down
2 changes: 1 addition & 1 deletion java/readme.md
Original file line number Diff line number Diff line change
Expand Up @@ -134,7 +134,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.6.9</version>
<version>0.7.0</version>
</dependency>
```

Expand Down

0 comments on commit 68d0a14

Please sign in to comment.