Package csw.command.client.messages

Class SupervisorLockMessage.Lock

java.lang.Object

csw.command.client.messages.SupervisorLockMessage.Lock

All Implemented Interfaces:

CommandSerializationMarker.RemoteMsg, ComponentMessage, SupervisorLockMessage, SupervisorMessage, SupervisorRunningMessage, CommandSerializable, Serializable, scala.Equals, scala.Product

Enclosing interface:

SupervisorLockMessage

public static class SupervisorLockMessage.Lock
extends Object
implements SupervisorLockMessage, scala.Product, Serializable

Represents message to lock a component

param: source represents the prefix of component that is acquiring lock param: replyTo represents the actor that will receive the command response param: leaseDuration represents the lease duration of lock acquired

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface csw.command.client.messages.SupervisorLockMessage

SupervisorLockMessage.Lock, SupervisorLockMessage.Lock$, SupervisorLockMessage.Unlock, SupervisorLockMessage.Unlock$

Constructor Summary

Constructors

Constructor	Description
Lock(Prefix source, akka.actor.typed.ActorRef<LockingResponse> replyTo, scala.concurrent.duration.FiniteDuration leaseDuration)

Method Summary

Modifier and Type	Method	Description
scala.concurrent.duration.FiniteDuration	leaseDuration()
akka.actor.typed.ActorRef<LockingResponse>	replyTo()
Prefix	source()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Constructor Details

Lock

public Lock(Prefix source,
 akka.actor.typed.ActorRef<LockingResponse> replyTo,
 scala.concurrent.duration.FiniteDuration leaseDuration)

Method Details

source

public Prefix source()

replyTo

public akka.actor.typed.ActorRef<LockingResponse> replyTo()

leaseDuration

public scala.concurrent.duration.FiniteDuration leaseDuration()