Результаты поиска по запросу "akka"
который, по-видимому, остается открытым.
бую следующее: class ClientActor (stockActor: ActorSelection, paymentsActor: ActorSelection) extends PersistentActor with AtLeastOnceDelivery with akka.actor.ActorLogging with RequiresMessageQueue[akka.custom.CustomMailbox]{ //actor ...
Akka Logging вне Актер
У меня есть актер Акка, который звонит
член, вам нужно изменить свое заявление на
орая проблема формата, когда я пытаюсь процитировать код, поэтому вот изображение :( описание изображения здесь [https://i.stack.imgur.com/4GAYi.jpg] import akka.actor.{Actor, ActorSystem, Props} case class Number(n: Int) case class String(s: ...
были предоставлены для таких случаев, когда мы знаем и полагаемся на конечную точку HTTP.
я есть топология akka-streams, где я делаю вызов POST, используя akka-http. Я получаю следующее сообщение об ошибке при отправке запроса на незащищенный сервер (с самозаверяющими сертификатами). Это внутренний сервер, так что я в порядке с точки ...
Я не установил для master значение local [n], но получил то же исключение.
от вопрос уже есть ответ здесь: Почему не удается присоединиться к «java.util.concurrent.TimeoutException: время ожидания фьючерса истекло после [300 ...
Затем вы можете использовать unmarshaller, передавая его в директиву параметров:
отаю над REST-сервисом, используя Akka HTTP (в Scala). Я хотел бы, чтобы параметр, который передается в запрос http get, был преобразован в тип ZonedDateTime. Код работает нормально, если я пытаюсь использовать String или Int, но не работает с ...
Поэтому я бы сказал, что это максимальное количество элементов, которые можно обрабатывать без регулирования. Обработанный "в то же время" никогда не будет точным определением в потоке :)
def throttle(elements: Int, per: FiniteDuration, maximumBurst: Int, mode: ThrottleMode): Repr[Out]лиmaximumBurst означает количество элементов, которые могут быть обработаны одновременно?
Пример создания конфигурации программно (это в Scala, но вы можете адаптировать ее для Java):
ли изменить или создать файл конфигурации из исходного кода. Я создаю клиент-серверную архитектуру с удаленным доступом. Что я хочу выполнить, так это возмож...
только если вы хотите манипулировать сообщениями.
аюсь создать простой прокси для соединений Websocket, используя потоки Play и akka. Транспортный поток выглядит так:
Большое спасибо, пока!
ожусь в ситуации, когда я хочу, чтобы остановить / отменить работу Flink из кода. Это мой интеграционный тест, в котором я отправляю задание на мою работу Fl...