[aries-journaled-events] branch master updated (7294f82 -> 816942f)

[cs...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

cschneider pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/aries-journaled-events.git.


    from 7294f82  ARIES-1880 - Use proper builder
     add 387df82  Message interface replaced with concrete class.
     new 816942f  Merge pull request #14 from akrainiouk/master

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../java/org/apache/aries/events/api/Message.java  | 23 +++++++++--
 .../org/apache/aries/events/api/Messaging.java     |  8 ----
 .../aries/events/memory/InMemoryMessaging.java     |  5 ---
 .../apache/aries/events/memory/MemoryMessage.java  | 44 ----------------------
 .../apache/aries/events/memory/MessagingTest.java  |  2 +-
 5 files changed, 21 insertions(+), 61 deletions(-)
 delete mode 100644 org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/MemoryMessage.java

[aries-journaled-events] 01/01: Merge pull request #14 from akrainiouk/master

[cs...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

cschneider pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/aries-journaled-events.git

commit 816942f86eed9679ec4055908f33a273652112d8
Merge: 7294f82 387df82
Author: Christian Schneider <ch...@die-schneider.net>
AuthorDate: Sun Jan 6 16:26:13 2019 +0100

    Merge pull request #14 from akrainiouk/master
    
    Message interface replaced with concrete class.

 .../java/org/apache/aries/events/api/Message.java  | 23 +++++++++--
 .../org/apache/aries/events/api/Messaging.java     |  8 ----
 .../aries/events/memory/InMemoryMessaging.java     |  5 ---
 .../apache/aries/events/memory/MemoryMessage.java  | 44 ----------------------
 .../apache/aries/events/memory/MessagingTest.java  |  2 +-
 5 files changed, 21 insertions(+), 61 deletions(-)

diff --cc org.apache.aries.events.api/src/main/java/org/apache/aries/events/api/Messaging.java
index 700aaaf,bdef185..5d1841c
--- a/org.apache.aries.events.api/src/main/java/org/apache/aries/events/api/Messaging.java
+++ b/org.apache.aries.events.api/src/main/java/org/apache/aries/events/api/Messaging.java
@@@ -35,22 -31,17 +35,14 @@@ public interface Messaging 
      void send(String topic, Message message);
  
      /**
 -     * Subscribe to a topic. The callback is called for each message received.
 -     * 
 -     * @param topic to consume from. TODO Do we allow wild cards? 
 -     * @param position in the topic to start consuming from 
 -     * @param seek where to start from when position is not valid or null
 -     * @param callback will be called for each message received
 -     * @return Returned subscription must be closed by the caller to unsubscribe
 +     * Subscribe to a topic.
 +     * The returned subscription must be closed by the caller to unsubscribe.
 +     *
 +     * @param request to subscribe
       */
 -    Subscription subscribe(String topic, Position position, Seek seek, Consumer<Received> callback);
 +    Subscription subscribe(SubscribeRequestBuilder request);
  
      /**
-      * Create a message with payload and metadata
-      * @param payload
-      * @param props
-      * @return
-      */
-     Message newMessage(byte[] payload, Map<String, String> props);
- 
-     /**
       * Deserialize the position from the string
       * 
       * @param position