Create a new Coordinated object and increment the number of parties by one.
Create a new Coordinated object and increment the number of parties by one. Use this method to pass on the coordination.
Java API: coordinated atomic method that accepts an Atomically.
Java API: coordinated atomic method that accepts an Atomically. Delimits the coordinated transaction. The transaction will wait for all other transactions in this coordination before committing. The timeout is specified by the transaction factory.
Java API: coordinated atomic method that accepts an Atomic.
Java API: coordinated atomic method that accepts an Atomic. Delimits the coordinated transaction. The transaction will wait for all other transactions in this coordination before committing. The timeout is specified by the transaction factory.
Delimits the coordinated transaction.
Delimits the coordinated transaction. The transaction will wait for all other transactions in this coordination before committing. The timeout is specified by the transaction factory.
Delimits the coordinated transaction.
Delimits the coordinated transaction. The transaction will wait for all other transactions in this coordination before committing. The timeout is specified by the transaction factory.
An empty coordinated atomic block.
An empty coordinated atomic block. Can be used to complete the number of parties involved and wait for all transactions to complete. The default timeout is used.
Java API: create a new Coordinated object and increment the number of parties by one.
Java API: create a new Coordinated object and increment the number of parties by one. Use this method to pass on the coordination.
Java API: get the message for this Coordinated.
Create a new Coordinated object but *do not* increment the number of parties by one.
Create a new Coordinated object but *do not* increment the number of parties by one. Only use this method if you know this is what you need.
Coordinatedis a message wrapper that adds aCountDownCommitBarrierfor explicitly coordinating transactions across actors or threads.Creating a
Coordinatedwill create a count down barrier with initially one member. For each member in the coordination set a transaction is expected to be created using the coordinated atomic method. The number of included parties must match the number of transactions, otherwise a successful transaction cannot be coordinated.To start a new coordinated transaction set that you will also participate in just create a
Coordinatedobject:To start a coordinated transaction that you won't participate in yourself you can create a
Coordinatedobject with a message and send it directly to an actor. The recipient of the message will be the first member of the coordination set:To receive a coordinated message in an actor simply match it in a case statement:
def receive = { case coordinated @ Coordinated(Message) => ... }To include another actor in the same coordinated transaction set that you've created or received, use the apply method on that object. This will increment the number of parties involved by one and create a new
Coordinatedobject to be sent.To enter the coordinated transaction use the atomic method of the coordinated object:
coordinated atomic { // do something in transaction ... }The coordinated transaction will wait for the other transactions before committing. If any of the coordinated transactions fail then they all fail.
akka.actor.Transactor for an actor that implements coordinated transactions