trait
ExtractionBusService extends AnyRef
Abstract Value Members
-
abstract
def
cancelPendingSubmission(id: UUID, queueName: String, msg_id: UUID): Unit
-
abstract
def
close(): Unit
-
abstract
def
connect(): Boolean
-
abstract
def
fileAddedToDataset(file: File, dataset: Dataset, host: String, requestAPIKey: Option[String]): Unit
-
abstract
def
fileCreated(file: TempFile, host: String, requestAPIKey: Option[String]): Unit
-
abstract
def
fileCreated(file: File, dataset: Option[Dataset], host: String, requestAPIKey: Option[String]): Unit
-
abstract
def
fileRemovedFromDataset(file: File, dataset: Dataset, host: String, requestAPIKey: Option[String]): Unit
-
abstract
def
fileSetAddedToDataset(dataset: Dataset, filelist: List[File], host: String, requestAPIKey: Option[String]): Unit
-
abstract
def
getBindings: Future[Response]
-
abstract
def
getChannelsList: Future[Response]
-
abstract
def
getExchanges: Future[Response]
-
abstract
def
getQueueBindings(qname: String): Future[Response]
-
abstract
def
getQueueDetails(qname: String): Future[Response]
-
abstract
def
getQueuesNamesForAnExchange(exchange: String): Future[Response]
-
abstract
def
metadataAddedToResource(metadataId: UUID, resourceRef: ResourceRef, extraInfo: Map[String, Any], host: String, requestAPIKey: Option[String], user: Option[User]): Unit
-
abstract
def
metadataRemovedFromResource(metadataId: UUID, resourceRef: ResourceRef, host: String, requestAPIKey: Option[String], user: Option[User]): Unit
-
abstract
def
multimediaQuery(tempFileId: UUID, contentType: String, length: String, host: String, requestAPIKey: Option[String]): Unit
-
abstract
def
onStart(): Unit
-
abstract
def
onStop(): Unit
-
abstract
def
resubmitPendingRequests(cancellationQueueConsumer: QueueingConsumer, channel: Channel, cancellationSearchTimeout: Long): Unit
-
abstract
def
submitDatasetManually(host: String, queue: String, extraInfo: Map[String, Any], datasetId: UUID, newFlags: String, requestAPIKey: Option[String], user: Option[User]): Boolean
-
abstract
def
submitFileManually(originalId: UUID, file: File, host: String, queue: String, extraInfo: Map[String, Any], datasetId: UUID, newFlags: String, requestAPIKey: Option[String], user: Option[User]): Boolean
-
abstract
def
submitSectionPreviewManually(preview: Preview, sectionId: UUID, host: String, requestAPIKey: Option[String]): Unit
Concrete 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
-
final
def
asInstanceOf[T0]: T0
-
def
clone(): AnyRef
-
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
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toString(): String
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
Inherited from AnyRef
Inherited from Any