-
Notifications
You must be signed in to change notification settings - Fork 35
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
javadsl for CassandraProjection #84
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks good.
@@ -49,6 +49,7 @@ import akka.stream.alpakka.cassandra.scaladsl.CassandraSession | |||
Instant.now(clock)) | |||
} | |||
|
|||
// FIXME maybe we need to make this public for user's tests |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Is this something we could do on initialization or lazily (or try to do) if the keyspace and table DNE?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
it should not be automatic, but we probably need to expose it for test
akka-projection-cassandra/src/main/scala/akka/projection/cassandra/javadsl/Handler.scala
Show resolved
Hide resolved
e1cb0d5
to
b9ebe36
Compare
I have added CassandraProjectionTest with javadsl.ProjectionTestKit b9ebe36 so this is ready for final review. |
* CassandraProjectionTest with javadsl.ProjectionTestKit
e76e1c2
to
8a0df5b
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
Couldn't write any tests because we need javadsl of the testkit first, but I have prepared for the junit testing. #83
References #21