Instance Constructors
-
new
LocalRouter
(virtual_host: VirtualHost)
Type Members
-
trait
Domain
[D <: DomainDestination]
extends AnyRef
-
class
QueueDomain
extends Domain[Queue]
-
class
TopicDomain
extends Domain[Topic]
Value Members
-
def
!=
(arg0: AnyRef): Boolean
-
def
!=
(arg0: Any): Boolean
-
def
##
(): Int
-
def
==
(arg0: AnyRef): Boolean
-
def
==
(arg0: Any): Boolean
-
def
_create_queue
(binding: QueueBinding, id: Long = 1): Queue
-
def
_destroy_queue
(queue: Queue): Unit
-
def
_destroy_queue
(queue: Queue, security: SecurityContext): Option[String]
-
def
_destroy_queue
(dto: DestinationDTO, security: SecurityContext): Option[String]
-
def
_destroy_queue
(id: String, security: SecurityContext): Option[String]
-
def
_get_or_create_destination
(dto: DestinationDTO, security: SecurityContext): Result[DomainDestination, String]
-
var
_serviceFailure
: Exception
-
var
_service_state
: State
-
def
_start
(on_completed: Runnable): Unit
-
def
_stop
(on_completed: Runnable): Unit
-
def
apply_update
(on_completed: Runnable): Unit
-
def
asInstanceOf
[T0]
: T0
-
def
assert_executing
: Unit
-
def
auto_create_destinations
: Boolean
-
def
bind
(destination: Array[DestinationDTO], consumer: DeliveryConsumer, security: SecurityContext): Option[String] @scala.util.continuations.cpsParam[Unit,Unit]
-
def
clone
(): AnyRef
-
def
connect
(destinations: Array[DestinationDTO], producer: BindableDeliveryProducer, security: SecurityContext): Option[String] @scala.util.continuations.cpsParam[Unit,Unit]
-
def
connection_regroup
: Unit
-
def
create_configure_destinations
: Unit
-
def
destroy_queue
(dto: DestinationDTO, security: SecurityContext): Option[String] @scala.util.continuations.cpsParam[Unit,Unit]
-
def
destroy_queue
(id: String, security: SecurityContext): Option[String] @scala.util.continuations.cpsParam[Unit,Unit]
-
def
disconnect
(destinations: Array[DestinationDTO], producer: BindableDeliveryProducer): Unit
-
def
dispatch_queue
: DispatchQueue
-
def
domain
(destination: DestinationDTO): LocalRouter.this.Domain[_ <: org.apache.activemq.apollo.broker.DomainDestination]
-
def
eq
(arg0: AnyRef): Boolean
-
def
equals
(arg0: Any): Boolean
-
def
finalize
(): Unit
-
def
getClass
(): java.lang.Class[_]
-
def
get_or_create_destination
(id: DestinationDTO, security: SecurityContext): org.apache.activemq.apollo.util.Result[org.apache.activemq.apollo.broker.DomainDestination,String] @scala.util.continuations.cpsParam[Unit,Unit]
-
def
get_queue
(id: String): Option[org.apache.activemq.apollo.broker.Queue] @scala.util.continuations.cpsParam[Unit,Unit]
-
def
get_queue
(dto: DestinationDTO): Option[org.apache.activemq.apollo.broker.Queue] @scala.util.continuations.cpsParam[Unit,Unit]
-
def
hashCode
(): Int
-
def
isInstanceOf
[T0]
: Boolean
-
def
ne
(arg0: AnyRef): Boolean
-
def
notify
(): Unit
-
def
notifyAll
(): Unit
-
-
var
queues_by_binding
: HashMap[QueueBinding, Queue]
-
var
queues_by_id
: HashMap[String, Queue]
-
def
schedule_connection_regroup
: Unit
-
def
serviceFailure
: Exception
-
def
service_state
: State
-
def
start
(on_completed: Runnable): Unit
-
def
start
(): Unit
-
def
stop
(on_completed: Runnable): Unit
-
def
stop
(): Unit
-
def
synchronized
[T0]
(arg0: ⇒ T0): T0
-
def
toString
(): String
-
-
def
unbind
(destinations: Array[DestinationDTO], consumer: DeliveryConsumer, persistent: Boolean, security: SecurityContext): Unit
-
-
def
wait
(): Unit
-
def
wait
(arg0: Long, arg1: Int): Unit
-
def
wait
(arg0: Long): Unit
Inherited from BaseService
Inherited from Dispatched
Inherited from Service
Inherited from AnyRef
Inherited from Any
Provides a non-blocking concurrent producer to consumer routing implementation.
DeliveryProducers create a route object for each destination they will be producing to. Once the route is connected to the router, the producer can use the route.targets list without synchronization to get the current set of consumers that are bound to the destination.