org
.
apache
.
activemq
.
apollo
.
broker
Topic
class
Topic
extends
DomainDestination
with
SecuredResource
A logical messaging topic
Linear Supertypes
DomainDestination
,
SecuredResource
, AnyRef,
Any
Ordering
Alphabetic
By inheritance
Inherited
Hide All
Show all
Topic
DomainDestination
SecuredResource
AnyRef
Any
Visibility
Public
All
Instance Constructors
new
Topic
(
router:
LocalRouter
,
destination_dto:
TopicDestinationDTO
,
config_updater: () ⇒
TopicDTO
,
id: String
,
path:
Path
)
Type Members
case class
ProxyDeliveryConsumer
(
consumer: DeliveryConsumer
,
link: LinkDTO
)
extends DeliveryConsumer with Product with Serializable
case class
TopicDeliverySession
(
session: DeliverySession
)
extends DeliverySession with SessionSinkFilter[Delivery] with Product with Serializable
Value Members
def
!=
(
arg0: AnyRef
)
:
Boolean
Attributes
final
Definition Classes
AnyRef
def
!=
(
arg0:
Any
)
:
Boolean
Attributes
final
Definition Classes
Any
def
##
()
:
Int
Attributes
final
Definition Classes
AnyRef → Any
def
==
(
arg0: AnyRef
)
:
Boolean
Attributes
final
Definition Classes
AnyRef
def
==
(
arg0:
Any
)
:
Boolean
Attributes
final
Definition Classes
Any
def
add_counters
(
to:
Topic
,
from: (
Long
,
Long
,
Long
)
)
:
Unit
def
add_counters
(
to:
LinkDTO
,
from: (
Long
,
Long
,
Long
)
)
:
Unit
def
asInstanceOf
[
T0
]
: T0
Attributes
final
Definition Classes
Any
var
auto_delete_after
:
Int
def
bind
(
destination:
DestinationDTO
,
consumer:
DeliveryConsumer
)
:
Unit
Definition Classes
Topic
→
DomainDestination
def
bind_durable_subscription
(
destination:
DurableSubscriptionDestinationDTO
,
queue:
Queue
)
:
Unit
def
check_idle
:
Unit
def
clone
()
: AnyRef
Attributes
protected[
lang
]
Definition Classes
AnyRef
Annotations
@throws
()
var
config
:
TopicDTO
var
config_updater
: () ⇒
TopicDTO
def
connect
(
destination:
DestinationDTO
,
producer:
BindableDeliveryProducer
)
:
Unit
Definition Classes
Topic
→
DomainDestination
var
consumer_counter
:
Long
var
consumer_queues
:
HashMap
[
DeliveryConsumer
,
Queue
]
val
consumers
:
HashMap
[
DeliveryConsumer
,
ProxyDeliveryConsumer
]
val
created_at
:
Long
var
dequeue_item_counter
:
Long
var
dequeue_size_counter
:
Long
var
dequeue_ts
:
Long
val
destination_dto
:
TopicDestinationDTO
Definition Classes
Topic
→
DomainDestination
def
disconnect
(
producer:
BindableDeliveryProducer
)
:
Unit
Definition Classes
Topic
→
DomainDestination
def
disconnect_producers
:
Unit
def
dispatch_queue
:
DispatchQueue
var
durable_subscriptions
:
ListBuffer
[
Queue
]
var
enqueue_item_counter
:
Long
var
enqueue_size_counter
:
Long
var
enqueue_ts
:
Long
def
eq
(
arg0: AnyRef
)
:
Boolean
Attributes
final
Definition Classes
AnyRef
def
equals
(
arg0:
Any
)
:
Boolean
Definition Classes
AnyRef → Any
def
finalize
()
:
Unit
Attributes
protected[
lang
]
Definition Classes
AnyRef
Annotations
@throws
()
implicit def
from_link
(
from:
LinkDTO
)
: (
Long
,
Long
,
Long
)
Attributes
implicit
implicit def
from_session
(
from:
TopicDeliverySession
)
: (
Long
,
Long
,
Long
)
Attributes
implicit
def
getClass
()
: java.lang.Class[_]
Attributes
final
Definition Classes
AnyRef
def
hashCode
()
:
Int
Definition Classes
AnyRef → Any
val
id
: String
Definition Classes
Topic
→
DomainDestination
→
SecuredResource
var
idled_at
:
Long
def
isInstanceOf
[
T0
]
:
Boolean
Attributes
final
Definition Classes
Any
def
ne
(
arg0: AnyRef
)
:
Boolean
Attributes
final
Definition Classes
AnyRef
def
notify
()
:
Unit
Attributes
final
Definition Classes
AnyRef
def
notifyAll
()
:
Unit
Attributes
final
Definition Classes
AnyRef
def
now
:
Long
var
producer_counter
:
Long
val
producers
:
HashMap
[
BindableDeliveryProducer
,
LinkDTO
]
var
proxy_sessions
:
HashSet
[
TopicDeliverySession
]
def
refresh_config
:
Unit
val
resource_kind
: org.apache.activemq.apollo.broker.security.SecuredResource.TopicKind.type
Definition Classes
Topic
→
SecuredResource
val
router
:
LocalRouter
var
rules_cache
:
SecurityRules
Definition Classes
SecuredResource
def
slow_consumer_policy
:
String
def
status
:
TopicStatusDTO
def
synchronized
[
T0
]
(
arg0: ⇒ T0
)
: T0
Attributes
final
Definition Classes
AnyRef
def
toString
()
:
String
Definition Classes
Topic
→ AnyRef → Any
def
unbind
(
consumer:
DeliveryConsumer
,
persistent:
Boolean
)
:
Unit
Definition Classes
Topic
→
DomainDestination
def
unbind_durable_subscription
(
destination:
DurableSubscriptionDestinationDTO
,
queue:
Queue
)
:
Unit
def
update
(
on_completed:
Runnable
)
:
Unit
Definition Classes
Topic
→
DomainDestination
def
virtual_host
:
VirtualHost
Definition Classes
Topic
→
DomainDestination
def
wait
()
:
Unit
Attributes
final
Definition Classes
AnyRef
Annotations
@throws
()
def
wait
(
arg0:
Long
,
arg1:
Int
)
:
Unit
Attributes
final
Definition Classes
AnyRef
Annotations
@throws
()
def
wait
(
arg0:
Long
)
:
Unit
Attributes
final
Definition Classes
AnyRef
Annotations
@throws
()
Inherited from
DomainDestination
Inherited from
SecuredResource
Inherited from AnyRef
Inherited from
Any
A logical messaging topic