Skip to content

Commit

Permalink
Fix #252
Browse files Browse the repository at this point in the history
  • Loading branch information
mathieuancelin committed Jun 29, 2020
1 parent 21bd650 commit 3ccc7d8
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 1 deletion.
2 changes: 1 addition & 1 deletion otoroshi/app/gateway/http.scala
Original file line number Diff line number Diff line change
Expand Up @@ -598,7 +598,7 @@ class HttpHandler()(implicit env: Env) {
true
case _ => false
}

val theStream: Source[ByteString, _] = resp.bodyAsSource
.concat(snowMonkeyContext.trailingResponseBodyStream)
.alsoTo(Sink.onComplete {
Expand Down
2 changes: 2 additions & 0 deletions otoroshi/app/storage/drivers/lettuce/LettuceDataStore.scala
Original file line number Diff line number Diff line change
Expand Up @@ -119,6 +119,8 @@ class LettuceDataStores(configuration: Configuration,
new LettuceRedisStandaloneAndSentinels(redisActorSystem, redisClient)
}
case "cluster" => {
// docker run -p '7000-7050:7000-7050' -e "IP=0.0.0.0" grokzen/redis-cluster:latest
// -Dapp.redis.lettuce.connection=cluster -Dapp.redis.lettuce.uris.0=redis://localhost:7000/0 -Dapp.redis.lettuce.uris.1=redis://localhost:7001/0 -Dapp.redis.lettuce.uris.2=redis://localhost:7002/0
val redisClient = RedisClusterClient.create(resources, nodes)
clientRef.set(redisClient)
new LettuceRedisCluster(redisActorSystem, redisClient)
Expand Down

0 comments on commit 3ccc7d8

Please sign in to comment.