code.model.flows.processors.queues.QueueCollection

Aliases

Parameters

subClasses

superClasses

code.model.flows.processors.queues.WithSubscriptions
java.lang.Object
scala.lang.Any

Js Constructors

ApplyMethods

Methods

$bang$eq(x$1:scala.lang.Any:Any, ):java.lang.Boolean:Boolean
$eq$eq(x$1:scala.lang.Any:Any, ):java.lang.Boolean:Boolean
$hash$hash():java.lang.Int:Int
$init$():scala.Unit:Unit
ackMessage(queueName:java.lang.String:String, message:scala.util.Either[code.model.flows.processors.queues.QueueMessagejava.lang.Exception], payload:scala.Option[code.data.Payload[code.data.Datum]], ):scala.util.Either[code.model.flows.processors.queues.QueueMessageResponsejava.lang.Exception]
ackMessage$default$3():scala.Option[code.data.Payload[code.data.Datum]]
ackMessages(queueName:java.lang.String:String, messages:scala.collection.immutable.Stream[scala.util.Either[code.model.flows.processors.queues.QueueMessagejava.lang.Exception]], payload:scala.Option[code.data.Payload[code.data.Datum]], ):scala.collection.immutable.Stream[scala.util.Either[code.model.flows.processors.queues.QueueMessageResponsejava.lang.Exception]]
ackMessages$default$3():scala.Option[code.data.Payload[code.data.Datum]]
addSubscription(s:scala.Tuple2, ):scala.Function1[null:Nullscala.Unit:Unit]
asInstanceOf():null:Null
deleteQueueMessages(queueName:java.lang.String:String, payload:scala.Option[code.data.Payload[code.data.Datum]], maxChunkSize:java.lang.Int:Int, ):scala.Unit:Unit
deleteQueueMessages$default$2():scala.Option[code.data.Payload[code.data.Datum]]
deleteQueueMessages$default$3():java.lang.Int:Int
describe():java.lang.String:String
enqueueMessage(queueName:java.lang.String:String, message:scala.util.Either[code.model.flows.processors.queues.QueueMessagejava.lang.Exception], payload:scala.Option[code.data.Payload[code.data.Datum]], batch:scala.Option[java.lang.String:String], prioritizeMessageBatchId:java.lang.Boolean:Boolean, retryFailedEnqueues:java.lang.Int:Int, ultimatelyKillFlowWhenFailingToEnqueue:java.lang.Boolean:Boolean, ):scala.util.Either[code.model.flows.processors.queues.QueueMessageResponsejava.lang.Exception]
enqueueMessage$default$3():scala.Option[code.data.Payload[code.data.Datum]]
enqueueMessage$default$4():scala.Option[java.lang.String:String]
enqueueMessage$default$5():java.lang.Boolean:Boolean
enqueueMessage$default$6():java.lang.Int:Int
enqueueMessage$default$7():java.lang.Boolean:Boolean
enqueueMessages(queueName:java.lang.String:String, messages:scala.collection.Iterator[scala.util.Either[code.model.flows.processors.queues.QueueMessagejava.lang.Exception]], payload:scala.Option[code.data.Payload[code.data.Datum]], batch:scala.Option[java.lang.String:String], prioritizeMessageBatchId:java.lang.Boolean:Boolean, retryFailedEnqueues:java.lang.Int:Int, ultimatelyKillFlowWhenFailingToEnqueue:java.lang.Boolean:Boolean, ):scala.collection.Iterator[scala.util.Either[code.model.flows.processors.queues.QueueMessageResponsejava.lang.Exception]]
enqueueMessages$default$3():scala.Option[code.data.Payload[code.data.Datum]]
enqueueMessages$default$4():scala.Option[java.lang.String:String]
enqueueMessages$default$5():java.lang.Boolean:Boolean
enqueueMessages$default$6():java.lang.Int:Int
enqueueMessages$default$7():java.lang.Boolean:Boolean
eq(x$1:java.lang.Object:Object, ):java.lang.Boolean:Boolean
equals(x$1:scala.lang.Any:Any, ):java.lang.Boolean:Boolean
getClass():java.lang.Class[scala.lang.Any:Any]
getQueue(name:java.lang.String:String, ):code.model.flows.processors.queues.Queue
getQueueLength(payload:scala.Option[code.data.Payload[code.data.Datum]], ):scala.collection.immutable.Map[java.lang.Long:Longjava.lang.String:String]
getQueueLength$default$1():scala.Option[code.data.Payload[code.data.Datum]]
getQueues():scala.collection.immutable.List[java.lang.String:String]
hashCode():java.lang.Int:Int
isInMaintenanceMode():java.lang.Boolean:Boolean
isInstanceOf():java.lang.Boolean:Boolean
merge(oldQueue:java.lang.String:String, newQueue:java.lang.String:String, payload:scala.Option[code.data.Payload[code.data.Datum]], ):code.model.flows.processors.queues.Queue
merge$default$3():scala.Option[code.data.Payload[code.data.Datum]]
nackMessage(queueName:java.lang.String:String, message:scala.util.Either[code.model.flows.processors.queues.QueueMessagejava.lang.Exception], payload:scala.Option[code.data.Payload[code.data.Datum]], ):scala.util.Either[code.model.flows.processors.queues.QueueMessageResponsejava.lang.Exception]
nackMessage$default$3():scala.Option[code.data.Payload[code.data.Datum]]
nackMessages(queueName:java.lang.String:String, messages:scala.collection.immutable.Stream[scala.util.Either[code.model.flows.processors.queues.QueueMessagejava.lang.Exception]], payload:scala.Option[code.data.Payload[code.data.Datum]], ):scala.collection.immutable.Stream[scala.util.Either[code.model.flows.processors.queues.QueueMessageResponsejava.lang.Exception]]
nackMessages$default$3():scala.Option[code.data.Payload[code.data.Datum]]
ne(x$1:java.lang.Object:Object, ):java.lang.Boolean:Boolean
notify():scala.Unit:Unit
notifyAll():scala.Unit:Unit
purgeQueue(queueName:java.lang.String:String, payload:scala.Option[code.data.Payload[code.data.Datum]], ):scala.Unit:Unit
purgeQueue$default$2():scala.Option[code.data.Payload[code.data.Datum]]
purgeQueues(payload:scala.Option[code.data.Payload[code.data.Datum]], ):scala.Unit:Unit
purgeQueues$default$1():scala.Option[code.data.Payload[code.data.Datum]]
rejectMessage(queueName:java.lang.String:String, message:scala.util.Either[code.model.flows.processors.queues.QueueMessagejava.lang.Exception], payload:scala.Option[code.data.Payload[code.data.Datum]], ):scala.util.Either[code.model.flows.processors.queues.QueueMessageResponsejava.lang.Exception]
rejectMessage$default$3():scala.Option[code.data.Payload[code.data.Datum]]
rejectMessages(queueName:java.lang.String:String, messages:scala.collection.immutable.Stream[scala.util.Either[code.model.flows.processors.queues.QueueMessagejava.lang.Exception]], payload:scala.Option[code.data.Payload[code.data.Datum]], ):scala.collection.immutable.Stream[scala.util.Either[code.model.flows.processors.queues.QueueMessageResponsejava.lang.Exception]]
rejectMessages$default$3():scala.Option[code.data.Payload[code.data.Datum]]
removeSubscription(sn:java.lang.String:String, ):scala.Function1[null:Nullscala.Unit:Unit]
sendMessageToSubscriber(sn:java.lang.String:String, m:null:Null, ):scala.Unit:Unit
sendMessageToSubscribers(m:null:Null, ):scala.Unit:Unit
shutdown():scala.Unit:Unit
startup():scala.Unit:Unit
synchronized(x$1:null:Null, ):null:Null
toString():java.lang.String:String
wait():scala.Unit:Unit
wait(x$1:java.lang.Long:Long, ):scala.Unit:Unit
wait(x$1:java.lang.Long:Long, x$2:java.lang.Int:Int, ):scala.Unit:Unit