event source changes

CJSCommonPlatform · Mar 9, 2018 · f1be2a0 · f1be2a0
1 parent 6c116ad
commit f1be2a0
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 8 deletions.
diff --git a/...t-source/src/main/java/uk/gov/justice/services/eventsourcing/source/core/EventSource.java b/...t-source/src/main/java/uk/gov/justice/services/eventsourcing/source/core/EventSource.java
@@ -20,19 +20,19 @@ public interface EventSource {
 
 
     /**
-     * Get a eventStream by stream id.
+     * Get a streams Of eventStreams.
      *
-     * @param streamId - the stream id of the stream to be retrieved
      * @return the {@link EventStream}
      */
-    EventStream getEventStreamById(final UUID streamId);
+    EventStream getEventStreams();
+
 
     /**
      * Get a streams Of eventStreams.
      *
      * @return the {@link EventStream}
      */
-    Stream<EventStream> getEventStreams();
+    EventStream getEventStreamsFrom(final long sequenceNumber);
 
     /**
      * Clones the stream into a new stream id.

diff --git a/...t-stream/src/main/java/uk/gov/justice/services/eventsourcing/source/core/EventStream.java b/...t-stream/src/main/java/uk/gov/justice/services/eventsourcing/source/core/EventStream.java
@@ -32,19 +32,18 @@ public interface EventStream {
      *
      * @return the stream of events
      */
-    Stream<JsonEnvelope> readEventsStreams();
+    Stream<JsonEnvelope> readEventStreams();
+
 
     /**
-     * Get the stream of events from the given version.
+     * Get the stream of eventStreams from the given version.
      *
      * @param version the version of the stream
      * @return the stream of events
      */
     Stream<JsonEnvelope> readEventStreamsFrom(final long version);
 
 
-
-
     /**
      * Store a stream of events.
      *