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
Topic
DomainDestination
SecuredResource
AnyRef
Any
Hide All
Show all
Learn more about member selection
Visibility
Public
All
Instance Constructors
new
Topic
(
router:
LocalRouter
,
address:
DestinationAddress
,
config_updater: () ⇒
TopicDTO
)
Type Members
case class
ProxyConsumerSession
(
proxy:
ProxyDeliveryConsumer
,
session:
DeliverySession
)
extends
Sink
[
Delivery
] with
DeliverySession
with
SessionSinkFilter
[
Delivery
] with
Product
with
Serializable
case class
ProxyDeliveryConsumer
(
consumer:
DeliveryConsumer
,
link:
LinkDTO
,
registered:
DeliveryConsumer
)
extends
DeliveryConsumerFilter
with
Product
with
Serializable
case class
ProxyProducerSession
(
producer:
DeliveryProducer
)
extends
Sink
[
Delivery
] with
DeliverySession
with
Product
with
Serializable
Value Members
final
def
!=
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
final
def
!=
(
arg0:
Any
)
:
Boolean
Definition Classes
Any
final
def
##
()
:
Int
Definition Classes
AnyRef → Any
final
def
==
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
final
def
==
(
arg0:
Any
)
:
Boolean
Definition Classes
Any
def
add_dequeue_counters
(
to:
DestMetricsDTO
,
from: (
Long
,
Long
,
Long
)
)
:
Unit
def
add_enqueue_counters
(
to:
DestMetricsDTO
,
from: (
Long
,
Long
,
Long
)
)
:
Unit
def
add_link_counters
(
to:
LinkDTO
,
from: (
Long
,
Long
,
Long
)
)
:
Unit
val
address
:
DestinationAddress
Definition Classes
Topic
→
DomainDestination
final
def
asInstanceOf
[
T0
]
:
T0
Definition Classes
Any
var
auto_delete_after
:
Int
def
bind
(
address:
BindAddress
,
consumer:
DeliveryConsumer
,
on_bind: () ⇒
Unit
)
:
Unit
Definition Classes
Topic
→
DomainDestination
def
bind_durable_subscription
(
address:
SubscriptionAddress
,
queue:
Queue
)
:
Unit
def
browse
(
from_seq:
Long
,
to:
Option
[
Long
]
,
max:
Long
)
(
func: (
BrowseResult
) ⇒
Unit
)
:
Unit
Definition Classes
Topic
→
DomainDestination
def
check_idle
:
Unit
def
clone
()
:
AnyRef
Attributes
protected[
java.lang
]
Definition Classes
AnyRef
Annotations
@throws
()
var
config
:
TopicDTO
var
config_updater
: () ⇒
TopicDTO
def
connect
(
address:
ConnectAddress
,
producer:
BindableDeliveryProducer
)
:
Unit
Definition Classes
Topic
→
DomainDestination
val
consumers
:
HashMap
[
DeliveryConsumer
,
ProxyDeliveryConsumer
]
val
created_at
:
Long
def
delete
:
Option
[
String
]
def
disconnect
(
producer:
BindableDeliveryProducer
)
:
Unit
Definition Classes
Topic
→
DomainDestination
def
disconnect_producers
:
Unit
def
dispatch_queue
:
DispatchQueue
var
durable_subscriptions
:
ListBuffer
[
Queue
]
final
def
eq
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
def
equals
(
arg0:
Any
)
:
Boolean
Definition Classes
AnyRef → Any
def
finalize
()
:
Unit
Attributes
protected[
java.lang
]
Definition Classes
AnyRef
Annotations
@throws
()
implicit
def
from_link
(
from:
LinkDTO
)
: (
Long
,
Long
,
Long
)
implicit
def
from_session
(
from:
DeliverySession
)
: (
Long
,
Long
,
Long
)
final
def
getClass
()
:
Class
[_]
Definition Classes
AnyRef → Any
def
hashCode
()
:
Int
Definition Classes
AnyRef → Any
def
id
:
String
Definition Classes
DomainDestination
→
SecuredResource
var
idled_at
:
Long
final
def
isInstanceOf
[
T0
]
:
Boolean
Definition Classes
Any
final
def
ne
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
final
def
notify
()
:
Unit
Definition Classes
AnyRef
final
def
notifyAll
()
:
Unit
Definition Classes
AnyRef
def
now
:
Long
val
producer_tracker
:
DeliveryConsumer
{ ... /* 2 definitions in type refinement */ }
val
producers
:
HashMap
[
BindableDeliveryProducer
,
LinkDTO
]
var
proxy_sessions
:
HashSet
[
DeliverySession
]
def
refresh_config
:
Unit
val
resource_kind
:
TopicKind
.type
Definition Classes
Topic
→
SecuredResource
var
retained_message
:
Delivery
val
router
:
LocalRouter
var
rules_cache
:
SecurityRules
Definition Classes
SecuredResource
def
slow_consumer_policy
:
String
var
state
:
String
def
status
(
show_producers:
Boolean
,
show_consumers:
Boolean
,
on_complete: (
TopicStatusDTO
) ⇒
Unit
)
:
Unit
def
status
(
show_producers:
Boolean
,
show_consumers:
Boolean
)
:
FutureResult
[
TopicStatusDTO
]
final
def
synchronized
[
T0
]
(
arg0: ⇒
T0
)
:
T0
Definition Classes
AnyRef
def
toString
()
:
String
Definition Classes
Topic
→ AnyRef → Any
val
topic_metrics
:
DestMetricsDTO
var
topic_queue
:
Queue
var
topic_queue_consumers
:
HashMap
[
DeliveryConsumer
,
DeliveryConsumer
]
def
unbind
(
consumer:
DeliveryConsumer
,
persistent:
Boolean
)
:
Unit
Definition Classes
Topic
→
DomainDestination
def
unbind_durable_subscription
(
queue:
Queue
)
:
Unit
def
update
(
on_completed:
Task
)
:
Unit
Definition Classes
Topic
→
DomainDestination
def
virtual_host
:
VirtualHost
Definition Classes
Topic
→
DomainDestination
final
def
wait
()
:
Unit
Definition Classes
AnyRef
Annotations
@throws
()
final
def
wait
(
arg0:
Long
,
arg1:
Int
)
:
Unit
Definition Classes
AnyRef
Annotations
@throws
()
final
def
wait
(
arg0:
Long
)
:
Unit
Definition Classes
AnyRef
Annotations
@throws
()
Inherited from
DomainDestination
Inherited from
SecuredResource
Inherited from
AnyRef
Inherited from
Any
Ungrouped
A logical messaging topic