Хм... щас попробую

или akka.actor.Status.Failure если был эксепшен

для pipeTo что надо импортировать?

akka.pattern.pipe

а так же import context.dispatcher

ему нужен ExecutionContext вроде

а какой выигрыш от использования Akka тут вообще?

Эм... case DeleteStash(stash_id: String) => { import akka.pattern.pipe import context.dispatcher log.info(s"Убиваем записи во вкладке stash id: $stash_id") PoeCurrencies.deleteWhereStash(stash_id) pipeTo sender } pipeTo - он не видит

def deleteWhereStash(stash_id: String): Future[Boolean] = { db.run(table.filter(_.stashId === stash_id).delete).map(_ => true) }

Это поменял, но чего я этим добился - не понял. Мне даже не надо знать этот результат. Мне просто надо быть увереным что сначала я сделаю delete, а токльо затем пойдут insert'ы

то что ты вызвал run и он выполнился еще не значит что delete выполнился

тебе же возвращается Future

Верно, потому и думал делать через ?, т.е. вроде как ответ должен вернуться. Т.е. я его должен дождаться прежде чем дальше ижти

А, всё, видимо сообразил

но pipeTo всё равно не работает

Это поменял, но чего я этим добился - не понял. Мне даже не надо знать этот результат. Мне просто надо быть увереным что сначала я сделаю delete, а токльо затем пойдут insert'ы

deleteWhereStash должна возвращать футуру. Сейчас там всегда возвращается true.

Я уже поправил )

Покажи, как поправил :)

def deleteWhereStash(stash_id: String): Future[Boolean] = { db.run(table.filter(_.stashId === stash_id).delete).map(_ => true) }

А, вижу

Теперь уровень выше case DeleteStash(stash_id: String) => { import akka.pattern.pipe import context.dispatcher log.info(s"Убиваем записи во вкладке stash id: $stash_id") PoeCurrencies.deleteWhereStash(stash_id) pipeTo sender }

pipeTo - он не видит

Импорт не произошел

)

Я тут тоже накосячил, да?..

вроде ок выглядит все

Пайту таймаут нужен

разве?

угу, заработало когда import akka.pattern.pipe import context.dispatcher вынес в самый верх

Вроде бы да. implicit val timeout = Timeout(5 seconds)

Таймаут там нужен, что бы в случае чего сгенерить ошибку

не не нужен http://doc.akka.io/api/akka/2.0/akka/pattern/package.html

аску нужен да

import akka.pattern.ask implicit val timeout = Timeout(5 seconds) val future = dbActor ? DeleteStash(stash.id) // enabled by the “ask” import val result = Await.result(future, timeout.duration).asInstanceOf[Boolean]

Верно.

Но я то делаю так?

Или можно так же по другому как то?

(dbActor ? DeleteStash(stash.id)).mapTo[Boolean]

для начала

Так? import akka.pattern.ask implicit val timeout = Timeout(5 seconds) val future = (dbActor ? DeleteStash(stash.id)).mapTo[Boolean] val result = Await.result(future, timeout.duration) println(s"stash clear results: $result ${stash.accountName} ${stash.id}")

Таймаут можно прибить. Сорри.

т.е. без await щас делать?

но мне в любом случае future развернуть же надо?

Await надо менять на flatMap.

да там не нужен flatMap

здесь по идее просто map можно

там onComplete достаточно

чтобы потом себе же послать сообщение

хм...

Если там дальше еще один аск, то почему бы нет?

там нет асков еще

а где?

дальше идет просто отправка инсертов, я их отсылаю и забываю про них

val f1: Future[Int] = Future.sucessful(0) val f2: Future[Int] = Future.sucessful(1) val f3 = f1.flatMap(x => f2.map(y => x + y)) f3 pipeTo sender()

Имхо это все проще сделать на чистых Future, ты запаришься очень скоро так работать с Аккой и профита особого не видно

ну профит там есть, там не толкьо эта задача висит

Ну ок )

От акки вообще никакого профита в стейтлес приложениях.

просто косяк произошел видимо только здесь

стейтлес?

Что значит стейтлесс? )

угу)

Просто у всех разное понимание )

Дословно "без состояния". Пришел запрос, обработали отправили ответ. Все хранится где-нибудь еще. На пример в бд. Или в кэше.

(dbActor ? DeleteStash(stash.id)).onComplete { case Success(_) => println(s"stash clear results: $result ${stash.accountName} ${stash.id}") stash.stashType match { case "CurrencyStash" => if (stash.items.isDefined) { self ! CurrenciesParse(stash.accountName, stash.lastCharacterName, stash.id, curTimeFormat.format(today), stash.items.get) } else { self ! ItemsNotFound } case "PremiumStash" => if (stash.items.isDefined) { self ! ItemsParse(stash.accountName, stash.lastCharacterName, stash.id, curTimeFormat.format(today), stash.items.get) } else { self ! ItemsNotFound } case "NormalStash" => if (stash.items.isDefined) { self ! ItemsParse(stash.accountName, stash.lastCharacterName, stash.id, curTimeFormat.format(today), stash.items.get) } else { self ! ItemsNotFound } case r => log.warning(s"Неизвестный тип вкладки: $r") } case Failure(e) => // handle exception }

там хранится в БД всё, но дальше в планах иметь состояния стешей в самой акке, т.е. при запуске - она это дело должна взять из базы и сформировать стеши, а потом просто вносить изменения

ERROR: S client not available

Ну Акка отлично для таких штук подходит

Только зачем оборачивать доступ к базе в актор? Какой плюс от этого?

почему бы не заинжектит простой интерфейс

вот, значит я по идее выбрал верно

думал над этим, учитывая что сам слик тоже через акторы работает - видимо зря я еще одну прослойку добавил

но удалять уже буду когда начну переходить на хранение состояний

там хранится в БД всё, но дальше в планах иметь состояния стешей в самой акке, т.е. при запуске - она это дело должна взять из базы и сформировать стеши, а потом просто вносить изменения

А потом горизонтально масшабировать надо будет через акка-кластер. То еще веселье

(dbActor ? DeleteStash(stash.id)).onComplete { case Success(_) => case Failure(e) => } это же надо? import akka.actor.Status.{Failure, Success}

а по кластеру - там не настолько много всего будет, может пара десятков тысяч записей, вряд ли больше

да так

тогда я не понимаю чего он опять возмущается

говорит что хочет Try[Any]

ты mapTo забыл

Нет. Там другой пакет

аа

ну да нет )

scala.util._

верно, спасибо, щас буду пробовать тогда

Кстати может глупый вопрос, но... как проще всего переделать ActorLogging что бы в случае log.error он писал в файл?

(dbActor ? DeleteStash(stash.id)).mapTo[Boolean].onComplete { case Success(_) => { if (stash.public) { stash.stashType match { case "CurrencyStash" => if (stash.items.isDefined) { self ! CurrenciesParse(stash.accountName, stash.lastCharacterName, stash.id, curTimeFormat.format(today), stash.items.get) } else { self ! ItemsNotFound } case "PremiumStash" => if (stash.items.isDefined) { self ! ItemsParse(stash.accountName, stash.lastCharacterName, stash.id, curTimeFormat.format(today), stash.items.get) } else { self ! ItemsNotFound } case "NormalStash" => if (stash.items.isDefined) { self ! ItemsParse(stash.accountName, stash.lastCharacterName, stash.id, curTimeFormat.format(today), stash.items.get) } else { self ! ItemsNotFound } case r => log.warning(s"Неизвестный тип вкладки: $r") } } } case Failure(e) => log.error("Стеш не очистился") } В итоге получилось так, щас буду пробовать

подключить и настроить logback

читай документацию к Акке она хорошая

лучше сделай stashType не строкой sealed trait c разными case object

тогда не надо будет на уровне актора обрабатывать всякую хрень

ты ее отловишь на уровне парсинга

лучше сделай stashType не строкой sealed trait c разными case object

Эм... не понял что имелось в виду

и тогда вся эта хрень с onComplete превратится в map().pipeTo(self)

sealed trait StashType object StashType { case object NormalStash extends StashType … }

блин

форматирование не работает

У тебя сейчас там строки

из за этого актор работает с потениально невалидным вводом