move AeronSource, AeronSink to remote
This commit is contained in:
parent
d9188d242c
commit
f5b88f7620
5 changed files with 7 additions and 5 deletions
|
|
@ -17,6 +17,8 @@ import java.util.concurrent.CountDownLatch
|
|||
import java.util.concurrent.CyclicBarrier
|
||||
import java.util.concurrent.atomic.AtomicLongArray
|
||||
import akka.stream.ThrottleMode
|
||||
import akka.remote.artery.AeronSink
|
||||
import akka.remote.artery.AeronSource
|
||||
|
||||
object AeronStreams {
|
||||
|
||||
|
|
|
|||
|
|
@ -1,4 +1,4 @@
|
|||
package akka.aeron
|
||||
package akka.remote.artery
|
||||
|
||||
import java.nio.ByteBuffer
|
||||
import java.util.concurrent.TimeUnit
|
||||
|
|
@ -1,4 +1,4 @@
|
|||
package akka.aeron
|
||||
package akka.remote.artery
|
||||
|
||||
import java.nio.ByteBuffer
|
||||
import java.util.concurrent.TimeUnit
|
||||
|
|
@ -107,7 +107,7 @@ object AkkaBuild extends Build {
|
|||
dependencies = Seq(
|
||||
actor,
|
||||
http, stream, streamTests,
|
||||
persistence, distributedData,
|
||||
remote, persistence, distributedData,
|
||||
testkit
|
||||
).map(_ % "compile;compile->test;provided->provided")
|
||||
).disablePlugins(ValidatePullRequest)
|
||||
|
|
|
|||
|
|
@ -129,7 +129,7 @@ object Dependencies {
|
|||
|
||||
val actorTests = l ++= Seq(Test.junit, Test.scalatest.value, Test.commonsCodec, Test.commonsMath, Test.mockito, Test.scalacheck.value, Test.junitIntf)
|
||||
|
||||
val remote = l ++= Seq(netty, uncommonsMath, Test.junit, Test.scalatest.value)
|
||||
val remote = l ++= Seq(netty, uncommonsMath, aeronDriver, aeronClient, Test.junit, Test.scalatest.value)
|
||||
|
||||
val remoteTests = l ++= Seq(Test.junit, Test.scalatest.value, Test.scalaXml)
|
||||
|
||||
|
|
@ -165,7 +165,7 @@ object Dependencies {
|
|||
|
||||
val contrib = l ++= Seq(Test.junitIntf, Test.commonsIo)
|
||||
|
||||
val benchJmh = l ++= Seq(Provided.levelDB, Provided.levelDBNative, aeronDriver, aeronClient, hdrHistogram)
|
||||
val benchJmh = l ++= Seq(Provided.levelDB, Provided.levelDBNative, hdrHistogram)
|
||||
|
||||
// akka stream & http
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue