services
PendingRequestCancellationActor
class
PendingRequestCancellationActor extends Actor
Instance Constructors
-
new
PendingRequestCancellationActor(exchange: String, connection: Option[Connection], cancellationDownloadQueueName: String, cancellationSearchTimeout: Long)
Type Members
-
type
Receive = PartialFunction[Any, Unit]
Value Members
-
final
def
!=(arg0: AnyRef): Boolean
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: AnyRef): Boolean
-
final
def
==(arg0: Any): Boolean
-
val
CancellationSearchNumLimits: Integer
-
final
def
asInstanceOf[T0]: T0
-
def
clone(): AnyRef
-
val
configuration: Configuration
-
implicit
val
context: ActorContext
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
finalize(): Unit
-
final
def
getClass(): Class[_]
-
def
hashCode(): Int
-
final
def
isInstanceOf[T0]: Boolean
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
postRestart(reason: Throwable): Unit
-
def
postStop(): Unit
-
def
preRestart(reason: Throwable, message: Option[Any]): Unit
-
def
preStart(): Unit
-
def
receive: PartialFunction[Any, Unit]
-
implicit final
val
self: ActorRef
-
final
def
sender: ActorRef
-
def
supervisorStrategy: SupervisorStrategy
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toString(): String
-
def
unhandled(message: Any): Unit
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
Inherited from Actor
Inherited from AnyRef
Inherited from Any
First, it will connect to the target rabbitmq queue to download each pending submission request and search the cancellation submission by comparing the message id of each pending submission request. This search will terminate when any of the following condition stands:
each downloaded submission(except the cancellation submission) will be forwarded to a named rabbitmq queue.
Second, when the searching is terminated, it will remove and resubmit each submission from the named rabbitmq queue to the extractor queue(s) based on the routing key of each submission.