Instance Constructors
-
new
LocalRouter
(virtual_host: VirtualHost)
Value Members
-
def
!=
(arg0: AnyRef): Boolean
-
def
!=
(arg0: Any): Boolean
-
def
##
(): Int
-
def
==
(arg0: AnyRef): Boolean
-
def
==
(arg0: Any): Boolean
-
def
_create_queue
(binding: Binding, id: Long = 1): Queue
-
def
_destroy_queue
(queue: Queue): Unit
-
def
_destroy_queue
(queue: Queue, security: SecurityContext): Option[String]
-
def
_destroy_queue
(id: Long, security: SecurityContext): Option[String]
-
var
_serviceFailure
: Exception
-
var
_service_state
: State
-
def
_start
(on_completed: Task): Unit
-
def
_stop
(on_completed: Task): Unit
-
def
apply_update
(on_completed: Task): Unit
-
def
asInstanceOf
[T0]
: T0
-
def
assert_executing
: Unit
-
-
def
auto_create_destinations
: Boolean
-
def
bind
(addresses: Array[_ <: org.apache.activemq.apollo.broker.BindAddress], consumer: DeliveryConsumer, security: SecurityContext): Option[String]
-
def
check_on_queues_destroyed_actions
: Unit
-
def
clone
(): AnyRef
-
def
connect
(addresses: Array[_ <: org.apache.activemq.apollo.broker.ConnectAddress], producer: BindableDeliveryProducer, security: SecurityContext): Option[String]
-
def
connection_regroup
: Unit
-
def
create
(addresses: Array[_ <: org.apache.activemq.apollo.broker.DestinationAddress], security: SecurityContext): Option[String]
-
def
create_configure_destinations
: Unit
-
def
delete
(addresses: Array[_ <: org.apache.activemq.apollo.broker.DestinationAddress], security: SecurityContext): Option[String]
-
def
destroy_queue
(id: Long, security: SecurityContext): Option[String] @scala.util.continuations.cpsParam[Unit,Unit]
-
def
disconnect
(addresses: Array[_ <: org.apache.activemq.apollo.broker.ConnectAddress], producer: BindableDeliveryProducer): Unit
-
def
dispatch_queue
: DispatchQueue
-
def
dsub_domain
: 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_queue
(id: Long): Option[Queue]
-
def
hashCode
(): Int
-
def
isInstanceOf
[T0]
: Boolean
-
-
val
local_dsub_domain
: DsubDomain
-
val
local_queue_domain
: QueueDomain
-
val
local_topic_domain
: TopicDomain
-
def
ne
(arg0: AnyRef): Boolean
-
def
notify
(): Unit
-
def
notifyAll
(): Unit
-
def
on_queue_destroy_end
: Unit
-
def
on_queue_destroy_start
: Unit
-
var
on_queues_destroyed_actions
: List[Runnable]
-
var
pending_queue_destroys
: Int
-
def
queue_domain
: LocalRouter.this.Domain[_ <: org.apache.activemq.apollo.broker.DomainDestination]
-
var
queues_by_store_id
: LinkedHashMap[Long, Queue]
-
def
remove_temp_destinations
(active_connections: Set[String]): Unit
-
val
router_listeners
: List[RouterListener]
-
def
schedule_connection_regroup
: Unit
-
def
serviceFailure
: Exception
-
def
service_state
: State
-
def
start
(on_completed: Task): Unit
-
def
stop
(on_completed: Task): Unit
-
def
synchronized
[T0]
(arg0: ⇒ T0): T0
-
def
temp_owner
(address: DestinationAddress): Option[(String, String)]
-
def
toString
(): String
-
def
topic_domain
: LocalRouter.this.Domain[_ <: org.apache.activemq.apollo.broker.DomainDestination]
-
def
unbind
(addresses: Array[_ <: org.apache.activemq.apollo.broker.BindAddress], 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.