Fix samples POM.xml

Update version to 0.6.0

java/azure-eventhubs-samples/pom.xml

@@ -0,0 +1,27 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+
+	<parent>
+		<groupId>com.microsoft.azure</groupId>
+		<artifactId>azure-eventhubs-clients</artifactId>
+		<version>0.6.0-SNAPSHOT</version>
+  	</parent>
+  
+  	<modelVersion>4.0.0</modelVersion>
+
+	<artifactId>azure-eventhubs-samples</artifactId>
+	<name>azure-eventhubs-samples</name>
+	    
+	<dependencies>
+	 	<dependency>
+			<groupId>com.microsoft.azure</groupId>
+			<artifactId>azure-eventhubs</artifactId>
+		    <version>${project.parent.version}</version>
+	</dependency>
+	 	<dependency>
+	  		<groupId>com.google.code.gson</groupId>
+	  		<artifactId>gson</artifactId>
+	  		<version>2.3.1</version>
+	   </dependency>
+	</dependencies>
+
+</project>

java/azure-eventhubs-samples/src/main/java/com/microsoft/azure/eventhubs/samples/SendReceiveAsync.java

@@ -0,0 +1,155 @@
+package com.microsoft.azure.eventhubs.samples;
+
+import java.io.*;
+import java.nio.charset.Charset;
+import java.time.Instant;
+import java.time.temporal.*;
+import java.util.*;
+import java.util.concurrent.*;
+import java.util.function.*;
+
+import com.google.gson.*;
+import com.microsoft.azure.eventhubs.*;
+import com.microsoft.azure.servicebus.*;
+
+public class SendReceiveAsync
+{
+	public static void main(String[] args) 
+			throws ServiceBusException, ExecutionException, InterruptedException, IOException
+	{
+		String username = "RootManageSharedAccessKey";
+		String password = "LHbmplGdVC7Lo7A1RAXXDgeHSM9WHIRvZmIt7m1y5w0=";
+		String namespaceName = "firstehub-ns";
+		
+		ConnectionStringBuilder connStr = new ConnectionStringBuilder(namespaceName, "gojavago", username, password);
+		// ConnectionStringBuilder connStr = new ConnectionStringBuilder("----namespaceName-----", "----EventHubName-----", "-----sayKeyName-----", "---SasKey----");
+		
+		final Gson gson = new GsonBuilder().create();
+		
+		final String partitionId = "0";
+		CompletableFuture<EventHubClient> ehClientCreateTask = EventHubClient.createFromConnectionString(connStr.toString());
+		
+		Function<EventHubSender, CompletableFuture<Void>> sendBatch = new Function<EventHubSender, CompletableFuture<Void>>()
+		{
+			@Override
+			public CompletableFuture<Void> apply(EventHubSender sender)
+			{
+				LinkedList<EventData> events = new LinkedList<EventData>();
+				for (int count = 1; count < 11; count++)
+				{
+					PayloadEvent payload = new PayloadEvent(count);
+					byte[] payloadBytes = gson.toJson(payload).getBytes(Charset.defaultCharset());
+					EventData sendEvent = new EventData(payloadBytes);
+					Map<String, String> applicationProperties = new HashMap<String, String>();
+					applicationProperties.put("from", "javaClient");
+					sendEvent.setProperties(applicationProperties);
+					events.add(sendEvent);
+				}
+
+				System.out.println(String.format("Sent Batch... Size: %s", events.size()));
+				try
+				{
+					return sender.send(events);
+				}
+				catch(ServiceBusException exception)
+				{
+					exception.printStackTrace();
+					throw new CompletionException(exception);
+				}
+			}	
+		};
+		
+		Function<PartitionReceiver, CompletableFuture<Iterable<EventData>>> receiveBatch = new Function<PartitionReceiver, CompletableFuture<Iterable<EventData>>>()
+		{
+			@Override
+			public CompletableFuture<Iterable<EventData>> apply(PartitionReceiver receiver)
+			{
+				try
+				{
+					return receiver.receive();
+				}
+				catch (ServiceBusException e)
+				{
+					throw new CompletionException(e);
+				}
+			}
+		};
+		
+		Consumer<Iterable<EventData>> printEvents = new Consumer<Iterable<EventData>>()
+		{
+			@Override
+			public void accept(Iterable<EventData> receivedEvents)
+			{
+				int batchSize = 0;
+				if (receivedEvents != null)
+				{
+					for(EventData receivedEvent: receivedEvents)
+					{
+						System.out.print(String.format("Offset: %s, SeqNo: %s, EnqueueTime: %s", 
+								receivedEvent.getSystemProperties().getOffset(), 
+								receivedEvent.getSystemProperties().getSequenceNumber(), 
+								receivedEvent.getSystemProperties().getEnqueuedTime()));
+						System.out.println(String.format("| Message Payload: %s", new String(receivedEvent.getBody(), Charset.defaultCharset())));
+						batchSize++;
+					}
+				}
+				
+				System.out.println(String.format("ReceivedBatch Size: %s", batchSize));					
+			}
+		};
+		
+		Function<EventHubClient, CompletableFuture<EventHubSender>> senderCreate = new Function<EventHubClient, CompletableFuture<EventHubSender>>()
+		{
+			@Override
+			public CompletableFuture<EventHubSender> apply(EventHubClient ehClient)
+			{
+				try {
+					return ehClient.createPartitionSender(partitionId);
+				} catch (ServiceBusException e) {
+					e.printStackTrace();
+					throw new CompletionException(null);
+				}
+			}
+		};		
+
+		CompletableFuture<PartitionReceiver> createReceiverTask = ehClientCreateTask
+				.thenComposeAsync(new Function<EventHubClient, CompletableFuture<PartitionReceiver>>()
+				{
+					@Override
+					public CompletableFuture<PartitionReceiver> apply(EventHubClient ehClient)
+					{
+						try {
+							return ehClient.createReceiver(EventHubClient.DefaultConsumerGroupName, 
+									partitionId, Instant.now().minus(1, ChronoUnit.MINUTES));
+						} catch (ServiceBusException e) {
+							e.printStackTrace();
+							throw new CompletionException(e);
+						}
+					}
+				});
+		
+		
+		// start sending & receiving...
+		CompletableFuture<EventHubSender> senderCreateTask = ehClientCreateTask.thenComposeAsync(senderCreate);
+		
+	}
+
+	/**
+	 * actual application-payload, ex: a telemetry event
+	 */
+	static final class PayloadEvent
+	{
+		PayloadEvent(final int seed)
+		{
+			this.id = "telemetryEvent1-critical-eventid-2345" + seed;
+			this.strProperty = "I am a mock telemetry event from JavaClient.";
+			this.longProperty = seed * new Random().nextInt(seed);
+			this.intProperty = seed * new Random().nextInt(seed);
+		}
+		
+		public String id;
+		public String strProperty;
+		public long longProperty;
+		public int intProperty;
+	}
+}

java/azure-eventhubs/pom.xml

@@ -3,7 +3,7 @@
   <parent>
 	<groupId>com.microsoft.azure</groupId>
 	<artifactId>azure-eventhubs-clients</artifactId>
-	<version>0.0.1-SNAPSHOT</version>
+	<version>0.6.0-SNAPSHOT</version>
   </parent>
 
   <modelVersion>4.0.0</modelVersion>

java/pom.xml

@@ -6,7 +6,7 @@
 	
 	<groupId>com.microsoft.azure</groupId>
 	<artifactId>azure-eventhubs-clients</artifactId>
-	<version>0.0.1-SNAPSHOT</version>
+	<version>0.6.0-SNAPSHOT</version>
 	<packaging>pom</packaging>
 	
 	<url>https://github.com/Azure/azure-event-hubs</url>
@@ -62,6 +62,7 @@
 	
 	 <modules> 
 	    <module>azure-eventhubs</module>
+	    <module>azure-eventhubs-samples</module>
 	 </modules>
 
 </project>

java/readme.md

@@ -122,7 +122,7 @@ the required version of Apache Qpid Proton-J, and the crytography library BCPKIX
 ```XML
     <dependency> 
    		<groupId>com.microsoft.azure</groupId> 
-   		<artifactId>azure-eventhubs-clients</artifactId> 
+   		<artifactId>azure-eventhubs</artifactId> 
    		<version>0.6.0</version> 
    	</dependency>   
  ```

samples/java/pom.xml

@@ -1,41 +0,0 @@
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-
-  <modelVersion>4.0.0</modelVersion>
-
-  <artifactId>azure-eventhubs-samples</artifactId>
-  <name>azure-eventhubs-samples</name>
-  <groupId>com.microsoft.azure</groupId>
-  <version>0.0.1-SNAPSHOT</version>
-    
-  <properties>
-    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-  </properties>
-
-  <dependencies>
-  	  	<dependency>
-  		<groupId>org.bouncycastle</groupId>
-  		<artifactId>bcpkix-jdk15on</artifactId>
-  		<version>1.47</version>
-  	</dependency>
-  	<dependency>
-      		<groupId>com.google.code.gson</groupId>
-      		<artifactId>gson</artifactId>
-      		<version>2.3.1</version>
-    	</dependency>
-    <dependency>
-  		<groupId>com.microsoft.azure</groupId>
-  		<artifactId>azure-eventhubs</artifactId>
-  		<version>0.0.1-SNAPSHOT</version>
-  		<scope>system</scope>
-  		<systemPath>\\thinker\public\javaClient\azure-eventhubs-0.0.1-SNAPSHOT.jar</systemPath>
-  	</dependency>
-  	<dependency>
-  		<groupId>org.apache.qpid</groupId>
-  		<artifactId>proton-j</artifactId>
-  		<scope>system</scope>
-        <version>0.12.0-SNAPSHOT</version>
-  		<systemPath>\\thinker\public\protonj\proton-j-0.12.0-SNAPSHOT.jar</systemPath>
-  	</dependency>
-  </dependencies>
-
-</project>