Skip to content
This repository has been archived by the owner on Jun 1, 2021. It is now read-only.

Commit

Permalink
Support compilation in IntelliJ
Browse files Browse the repository at this point in the history
The IntelliJ compiler complained about double defined
EmbeddedCassandra types even though one was defined in it and one in
multi-jvm. To silent IntelliJ the EmbeddedCassandra in multi-jvm is
renamed to MultiNodeEmbeddedCassandra.
  • Loading branch information
volkerstampa committed Jun 30, 2017
1 parent e58f87b commit 18192fa
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ package com.rbmhtechnology.eventuate

import org.cassandraunit.utils.EmbeddedCassandraServerHelper

object EmbeddedCassandra {
object MultiNodeEmbeddedCassandra {
val DefaultCassandraDir =
"target/embedded-cassandra"

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,14 +31,14 @@ trait MultiNodeSupportCassandra extends BeforeAndAfterAll { this: MultiNodeSpec
val coordinator = RoleName("nodeA")

def cassandraDir: String =
EmbeddedCassandra.DefaultCassandraDir
MultiNodeEmbeddedCassandra.DefaultCassandraDir

def logProps(logId: String): Props =
CassandraEventLog.props(logId)

override def atStartup(): Unit = {
if (isNode(coordinator)) {
EmbeddedCassandra.start(cassandraDir)
MultiNodeEmbeddedCassandra.start(cassandraDir)
Cassandra(system)
}
enterBarrier("startup")
Expand All @@ -54,7 +54,7 @@ trait MultiNodeSupportCassandra extends BeforeAndAfterAll { this: MultiNodeSpec
// clean database and delete snapshot files
if (isNode(coordinator)) {
FileUtils.deleteDirectory(snapshotRootDir)
EmbeddedCassandra.clean()
MultiNodeEmbeddedCassandra.clean()
}
}
}

0 comments on commit 18192fa

Please sign in to comment.