Merge pull request #94 from SreeramGarlapati/release_0.13.1

Release 0.13.1
Azure · Apr 7, 2017 · 36a8c40 · 36a8c40
2 parents be64ad9 + 2807eed
commit 36a8c40
Show file tree

Hide file tree

Showing 80 changed files with 6,684 additions and 7,343 deletions.
diff --git a/ConsumingEvents.md b/ConsumingEvents.md
@@ -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.13.0</version> 
+   		<version>0.13.1</version> 
    	</dependency>   
  ```
 

diff --git a/PublishingEvents.md b/PublishingEvents.md
@@ -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.13.0</version> 
+   		<version>0.13.1</version> 
    	</dependency>   
  ```
 

diff --git a/azure-eventhubs/src/main/java/com/microsoft/azure/eventhubs/EventData.java b/azure-eventhubs/src/main/java/com/microsoft/azure/eventhubs/EventData.java
diff --git a/azure-eventhubs/src/main/java/com/microsoft/azure/eventhubs/EventDataUtil.java b/azure-eventhubs/src/main/java/com/microsoft/azure/eventhubs/EventDataUtil.java
@@ -20,53 +20,53 @@
  * Internal utility class for EventData
  */
 final class EventDataUtil {
-    
-	@SuppressWarnings("serial")
-	static final Set<String> RESERVED_SYSTEM_PROPERTIES = Collections.unmodifiableSet(new HashSet<String>()
-			{{
-				add(AmqpConstants.OFFSET_ANNOTATION_NAME);
-				add(AmqpConstants.PARTITION_KEY_ANNOTATION_NAME);
-				add(AmqpConstants.SEQUENCE_NUMBER_ANNOTATION_NAME);
-				add(AmqpConstants.ENQUEUED_TIME_UTC_ANNOTATION_NAME);
-				add(AmqpConstants.PUBLISHER_ANNOTATION_NAME);
-			}});
-	
-	private EventDataUtil(){}
-
-	static LinkedList<EventData> toEventDataCollection(final Collection<Message> messages, final PassByRef<Message> lastMessageRef) {
-            
-		if (messages == null) {
-			return null;
-		}
-
-		LinkedList<EventData> events = new LinkedList<>();
-                for (Message message : messages) {
-                    
-			events.add(new EventData(message));
-                        
-                        if (lastMessageRef != null)
-                            lastMessageRef.set(message);
-                }
-
-		return events;
-	}
-
-	static Iterable<Message> toAmqpMessages(final Iterable<EventData> eventDatas, final String partitionKey) {
-            
-		final LinkedList<Message> messages = new LinkedList<>();
-		eventDatas.forEach(new Consumer<EventData>() {
-			@Override
-			public void accept(EventData eventData) {				
-				Message amqpMessage = partitionKey == null ? eventData.toAmqpMessage() : eventData.toAmqpMessage(partitionKey);
-				messages.add(amqpMessage);
-			}
-		});
-
-		return messages;
-	}
-
-	static Iterable<Message> toAmqpMessages(final Iterable<EventData> eventDatas) {
-            
-		return EventDataUtil.toAmqpMessages(eventDatas, null);
-	}
+
+    @SuppressWarnings("serial")
+    static final Set<String> RESERVED_SYSTEM_PROPERTIES = Collections.unmodifiableSet(new HashSet<String>() {{
+        add(AmqpConstants.OFFSET_ANNOTATION_NAME);
+        add(AmqpConstants.PARTITION_KEY_ANNOTATION_NAME);
+        add(AmqpConstants.SEQUENCE_NUMBER_ANNOTATION_NAME);
+        add(AmqpConstants.ENQUEUED_TIME_UTC_ANNOTATION_NAME);
+        add(AmqpConstants.PUBLISHER_ANNOTATION_NAME);
+    }});
+
+    private EventDataUtil() {
+    }
+
+    static LinkedList<EventData> toEventDataCollection(final Collection<Message> messages, final PassByRef<Message> lastMessageRef) {
+
+        if (messages == null) {
+            return null;
+        }
+
+        LinkedList<EventData> events = new LinkedList<>();
+        for (Message message : messages) {
+
+            events.add(new EventData(message));
+
+            if (lastMessageRef != null)
+                lastMessageRef.set(message);
+        }
+
+        return events;
+    }
+
+    static Iterable<Message> toAmqpMessages(final Iterable<EventData> eventDatas, final String partitionKey) {
+
+        final LinkedList<Message> messages = new LinkedList<>();
+        eventDatas.forEach(new Consumer<EventData>() {
+            @Override
+            public void accept(EventData eventData) {
+                Message amqpMessage = partitionKey == null ? eventData.toAmqpMessage() : eventData.toAmqpMessage(partitionKey);
+                messages.add(amqpMessage);
+            }
+        });
+
+        return messages;
+    }
+
+    static Iterable<Message> toAmqpMessages(final Iterable<EventData> eventDatas) {
+
+        return EventDataUtil.toAmqpMessages(eventDatas, null);
+    }
 }