Overview
Package
Class
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes
A
B
C
D
E
F
G
H
I
J
L
M
N
O
P
R
S
T
U
V
W
A
add(String, MemberHandle)
- Static method in class org.apache.qpid.server.cluster.
ClusterCapability
add(K, V)
- Method in class org.apache.qpid.server.cluster.util.
MultiValuedMap
addFailureListener(MemberFailureListener)
- Method in interface org.apache.qpid.server.cluster.
Member
addHandler(B, StateAwareMethodListener<A>)
- Method in class org.apache.qpid.server.cluster.
MethodHandlerRegistry
addListener(T)
- Method in class org.apache.qpid.server.cluster.util.
InvokeMultiple
addMemberhipChangeListener(MembershipChangeListener)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
addMemberhipChangeListener(MembershipChangeListener)
- Method in interface org.apache.qpid.server.cluster.
GroupManager
addRemoteSubcriber(MemberHandle)
- Method in class org.apache.qpid.server.queue.
ClusteredQueue
ASYNCH_POLICY
- Static variable in interface org.apache.qpid.server.cluster.policy.
StandardPolicies
AsynchBroadcastPolicy
- Class in
org.apache.qpid.server.cluster.policy
AsynchBroadcastPolicy()
- Constructor for class org.apache.qpid.server.cluster.policy.
AsynchBroadcastPolicy
autodelete()
- Method in class org.apache.qpid.server.queue.
ClusteredQueue
autodelete()
- Method in class org.apache.qpid.server.queue.
PrivateQueue
B
bind(int, ConnectorConfiguration)
- Method in class org.apache.qpid.server.cluster.
Main
bind(K1, K2, V)
- Method in class org.apache.qpid.server.cluster.util.
Bindings
Bindings
<
K1
,
K2
,
V
> - Class in
org.apache.qpid.server.cluster.util
Maps two separate keys to a list of values.
Bindings()
- Constructor for class org.apache.qpid.server.cluster.util.
Bindings
BlockingHandler
- Class in
org.apache.qpid.server.cluster
BlockingHandler()
- Constructor for class org.apache.qpid.server.cluster.
BlockingHandler
BlockingHandler(Class<? extends AMQMethodBody>)
- Constructor for class org.apache.qpid.server.cluster.
BlockingHandler
broadcast(Sendable)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
broadcast(Sendable, BroadcastPolicy, GroupResponseHandler)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
broadcast(Sendable)
- Method in interface org.apache.qpid.server.cluster.
GroupManager
broadcast(Sendable, BroadcastPolicy, GroupResponseHandler)
- Method in interface org.apache.qpid.server.cluster.
GroupManager
BroadcastPolicy
- Interface in
org.apache.qpid.server.cluster
C
canRelay(AMQMessage, MemberHandle)
- Static method in class org.apache.qpid.server.cluster.
ClusteredProtocolSession
ChainedClusterMethodHandler
<
A
extends org.apache.qpid.framing.AMQMethodBody> - Class in
org.apache.qpid.server.cluster.handler
ChainedClusterMethodHandler(List<ClusterMethodHandler<A>>)
- Constructor for class org.apache.qpid.server.cluster.handler.
ChainedClusterMethodHandler
ChainedClusterMethodHandler(ClusterMethodHandler<A>...)
- Constructor for class org.apache.qpid.server.cluster.handler.
ChainedClusterMethodHandler
changed(List<MemberHandle>)
- Method in interface org.apache.qpid.server.cluster.
MembershipChangeListener
client(AMQStateManager, QueueRegistry, ExchangeRegistry, AMQProtocolSession, AMQMethodEvent<A>)
- Method in class org.apache.qpid.server.cluster.handler.
ChainedClusterMethodHandler
client(AMQStateManager, QueueRegistry, ExchangeRegistry, AMQProtocolSession, AMQMethodEvent<A>)
- Method in class org.apache.qpid.server.cluster.handler.
ClusterMethodHandler
client(AMQStateManager, QueueRegistry, ExchangeRegistry, AMQProtocolSession, AMQMethodEvent<A>)
- Method in class org.apache.qpid.server.cluster.handler.
PeerHandler
ClientHandlerRegistry
- Class in
org.apache.qpid.server.cluster
An extension of client.AMQStateManager that allows different handlers to be registered.
ClientHandlerRegistry(MemberHandle)
- Constructor for class org.apache.qpid.server.cluster.
ClientHandlerRegistry
ClusterCapability
- Class in
org.apache.qpid.server.cluster
ClusterCapability()
- Constructor for class org.apache.qpid.server.cluster.
ClusterCapability
ClusteredProtocolHandler
- Class in
org.apache.qpid.server.cluster
ClusteredProtocolHandler(InetSocketAddress)
- Constructor for class org.apache.qpid.server.cluster.
ClusteredProtocolHandler
ClusteredProtocolHandler(IApplicationRegistry, InetSocketAddress)
- Constructor for class org.apache.qpid.server.cluster.
ClusteredProtocolHandler
ClusteredProtocolHandler(QueueRegistry, ExchangeRegistry, InetSocketAddress)
- Constructor for class org.apache.qpid.server.cluster.
ClusteredProtocolHandler
ClusteredProtocolHandler(ClusteredProtocolHandler)
- Constructor for class org.apache.qpid.server.cluster.
ClusteredProtocolHandler
ClusteredProtocolSession
- Class in
org.apache.qpid.server.cluster
ClusteredProtocolSession(IoSession, QueueRegistry, ExchangeRegistry, AMQCodecFactory, AMQStateManager)
- Constructor for class org.apache.qpid.server.cluster.
ClusteredProtocolSession
ClusteredQueue
- Class in
org.apache.qpid.server.queue
Represents a shared queue in a cluster.
ClusteredQueue(GroupManager, String, boolean, String, boolean, QueueRegistry)
- Constructor for class org.apache.qpid.server.queue.
ClusteredQueue
ClusteredQueue(GroupManager, String, boolean, String, boolean, QueueRegistry, Executor)
- Constructor for class org.apache.qpid.server.queue.
ClusteredQueue
ClusterMethodHandler
<
A
extends org.apache.qpid.framing.AMQMethodBody> - Class in
org.apache.qpid.server.cluster.handler
ClusterMethodHandler()
- Constructor for class org.apache.qpid.server.cluster.handler.
ClusterMethodHandler
ClusterMethodHandlerFactory
- Class in
org.apache.qpid.server.cluster.handler
ClusterMethodHandlerFactory(GroupManager, LoadTable)
- Constructor for class org.apache.qpid.server.cluster.handler.
ClusterMethodHandlerFactory
contains(String)
- Static method in class org.apache.qpid.server.cluster.
ClusterCapability
create(MemberHandle)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
create(MemberHandle)
- Method in class org.apache.qpid.server.cluster.
MinaBrokerProxyFactory
createList()
- Method in class org.apache.qpid.server.cluster.util.
MultiValuedMap
createName()
- Method in class org.apache.qpid.server.cluster.handler.
LocalQueueDeclareHandler
createQueue(QueueDeclareBody, QueueRegistry, AMQProtocolSession)
- Method in class org.apache.qpid.server.cluster.handler.
LocalQueueDeclareHandler
createSession(IoSession, QueueRegistry, ExchangeRegistry, AMQCodecFactory)
- Method in class org.apache.qpid.server.cluster.
ClusteredProtocolHandler
D
decrementLocalLoad()
- Method in class org.apache.qpid.server.cluster.
LoadTable
DefaultGroupManager
- Class in
org.apache.qpid.server.cluster
deliver(IoSession, Object)
- Method in class org.apache.qpid.server.cluster.
ClusteredProtocolHandler
deliver(AMQMessage)
- Method in class org.apache.qpid.server.queue.
ClusteredQueue
deliver(AMQMessage)
- Method in class org.apache.qpid.server.queue.
RemoteQueueProxy
E
equals(Object)
- Method in class org.apache.qpid.server.cluster.
SimpleMemberHandle
establish()
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
establish()
- Method in interface org.apache.qpid.server.cluster.
GroupManager
Establish a new cluster with the local member as the leader.
F
failed(MemberHandle)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
findStateTransitionHandler(AMQState, AMQMethodBody)
- Method in class org.apache.qpid.server.cluster.
ClientHandlerRegistry
G
get(K)
- Method in class org.apache.qpid.server.cluster.util.
MultiValuedMap
getChannel(int)
- Method in class org.apache.qpid.server.cluster.
ClusteredProtocolSession
getDetails()
- Method in interface org.apache.qpid.server.cluster.
MemberHandle
getDetails()
- Method in class org.apache.qpid.server.cluster.
SimpleMemberHandle
getHandler(B)
- Method in class org.apache.qpid.server.cluster.
MethodHandlerRegistry
getHost()
- Method in interface org.apache.qpid.server.cluster.
MemberHandle
getHost()
- Method in class org.apache.qpid.server.cluster.
SimpleMemberHandle
getLeader()
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
getLocal()
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
getLocal()
- Method in interface org.apache.qpid.server.cluster.
GroupManager
getLocalLoad()
- Method in class org.apache.qpid.server.cluster.
LoadTable
getMember(MemberHandle)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
getPeer(String)
- Static method in class org.apache.qpid.server.cluster.
ClusterCapability
getPort()
- Method in interface org.apache.qpid.server.cluster.
MemberHandle
getPort()
- Method in class org.apache.qpid.server.cluster.
SimpleMemberHandle
getProxy()
- Method in class org.apache.qpid.server.cluster.util.
InvokeMultiple
getSessionPeer()
- Method in class org.apache.qpid.server.cluster.
ClusteredProtocolSession
getSessionPeer(AMQProtocolSession)
- Static method in class org.apache.qpid.server.cluster.
ClusteredProtocolSession
getSessionPeer(IoSession)
- Static method in class org.apache.qpid.server.cluster.
ClusteredProtocolSession
getState()
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
getState()
- Method in interface org.apache.qpid.server.cluster.
GroupManager
getWrappableFrameTypes(AMQState)
- Method in class org.apache.qpid.server.cluster.handler.
WrappingMethodHandlerFactory
getWrappableFrameTypes(AMQState)
- Method in class org.apache.qpid.server.cluster.replay.
RecordingMethodHandlerFactory
GroupManager
- Interface in
org.apache.qpid.server.cluster
GroupResponseHandler
- Interface in
org.apache.qpid.server.cluster
H
handle(int, AMQMethodBody)
- Method in class org.apache.qpid.server.cluster.
MinaBrokerProxy
handleJoin(MemberHandle)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
handleJoin(MemberHandle)
- Method in interface org.apache.qpid.server.cluster.
GroupManager
handleLeave(MemberHandle)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
handleLeave(MemberHandle)
- Method in interface org.apache.qpid.server.cluster.
GroupManager
handleMembershipAnnouncement(String)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
handleMembershipAnnouncement(String)
- Method in interface org.apache.qpid.server.cluster.
GroupManager
handlePing(MemberHandle, long)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
handlePing(MemberHandle, long)
- Method in interface org.apache.qpid.server.cluster.
GroupManager
HandlerUtils
- Class in
org.apache.qpid.server.cluster.handler
HandlerUtils()
- Constructor for class org.apache.qpid.server.cluster.handler.
HandlerUtils
handleSuspect(MemberHandle)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
handleSuspect(MemberHandle)
- Method in interface org.apache.qpid.server.cluster.
GroupManager
handleSynch(MemberHandle)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
handleSynch(MemberHandle)
- Method in interface org.apache.qpid.server.cluster.
GroupManager
hashCode()
- Method in class org.apache.qpid.server.cluster.
SimpleMemberHandle
I
incrementLocalLoad()
- Method in class org.apache.qpid.server.cluster.
LoadTable
instance
- Variable in class org.apache.qpid.server.cluster.handler.
WrappingMethodHandlerFactory.FrameDescriptor
invoke(Object, Method, Object[])
- Method in class org.apache.qpid.server.cluster.util.
InvokeMultiple
InvokeMultiple
<
T
> - Class in
org.apache.qpid.server.cluster.util
Allows a method to be invoked on a list of listeners with one call
InvokeMultiple(Class<? extends T>)
- Constructor for class org.apache.qpid.server.cluster.util.
InvokeMultiple
isComplete(int, int)
- Method in interface org.apache.qpid.server.cluster.
BroadcastPolicy
isComplete(int, int)
- Method in class org.apache.qpid.server.cluster.policy.
AsynchBroadcastPolicy
isComplete(int, int)
- Method in class org.apache.qpid.server.cluster.policy.
MajorityResponseBroadcastPolicy
isComplete(int, int)
- Method in class org.apache.qpid.server.cluster.policy.
OneResponseBroadcastPolicy
isComplete(int, int)
- Method in class org.apache.qpid.server.cluster.policy.
SynchBroadcastPolicy
isLeader()
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
isLeader(MemberHandle)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
isLeader()
- Method in interface org.apache.qpid.server.cluster.
GroupManager
isLeader(MemberHandle)
- Method in interface org.apache.qpid.server.cluster.
GroupManager
isMember(MemberHandle)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
isMember(MemberHandle)
- Method in interface org.apache.qpid.server.cluster.
GroupManager
isPayloadFromPeer(AMQMessage)
- Static method in class org.apache.qpid.server.cluster.
ClusteredProtocolSession
isPeerSession()
- Method in class org.apache.qpid.server.cluster.
ClusteredProtocolSession
isPeerSession(IoSession)
- Static method in class org.apache.qpid.server.cluster.
ClusteredProtocolSession
isPeerSession(AMQProtocolSession)
- Static method in class org.apache.qpid.server.cluster.
ClusteredProtocolSession
isShared(AMQQueue)
- Method in class org.apache.qpid.server.cluster.handler.
ReplicatingConsumeHandler
isWrappableState(AMQState)
- Method in class org.apache.qpid.server.cluster.handler.
WrappingMethodHandlerFactory
isWrappableState(AMQState)
- Method in class org.apache.qpid.server.cluster.replay.
RecordingMethodHandlerFactory
J
join(MemberHandle)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
join(MemberHandle)
- Method in interface org.apache.qpid.server.cluster.
GroupManager
Join the cluster to which member belongs
JoinState
- Enum in
org.apache.qpid.server.cluster
L
leave()
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
leave()
- Method in interface org.apache.qpid.server.cluster.
GroupManager
LoadTable
- Class in
org.apache.qpid.server.cluster
Maintains loading information about the local member and its cluster peers.
LoadTable()
- Constructor for class org.apache.qpid.server.cluster.
LoadTable
LocalQueueDeclareHandler
- Class in
org.apache.qpid.server.cluster.handler
LogMessage
- Class in
org.apache.qpid.server.cluster.util
Convenience class to allow log messages to be specified in terms of MessageFormat patterns with a variable set of parameters.
LogMessage(String)
- Constructor for class org.apache.qpid.server.cluster.util.
LogMessage
LogMessage(String, Object...)
- Constructor for class org.apache.qpid.server.cluster.util.
LogMessage
M
Main
- Class in
org.apache.qpid.server.cluster
TODO: This is a cut-and-paste from the original broker Main class.
Main(String[])
- Constructor for class org.apache.qpid.server.cluster.
Main
main(String[])
- Static method in class org.apache.qpid.server.cluster.
Main
MajorityResponseBroadcastPolicy
- Class in
org.apache.qpid.server.cluster.policy
MajorityResponseBroadcastPolicy()
- Constructor for class org.apache.qpid.server.cluster.policy.
MajorityResponseBroadcastPolicy
matches(MemberHandle)
- Method in interface org.apache.qpid.server.cluster.
MemberHandle
matches(String, int)
- Method in interface org.apache.qpid.server.cluster.
MemberHandle
matches(MemberHandle)
- Method in class org.apache.qpid.server.cluster.
SimpleMemberHandle
matches(String, int)
- Method in class org.apache.qpid.server.cluster.
SimpleMemberHandle
Member
- Interface in
org.apache.qpid.server.cluster
MemberHandle
- Interface in
org.apache.qpid.server.cluster
MembershipChangeListener
- Interface in
org.apache.qpid.server.cluster
messageReceived(IoSession, Object)
- Method in class org.apache.qpid.server.cluster.
ClusteredProtocolHandler
MethodHandlerFactory
- Interface in
org.apache.qpid.server.cluster
MethodHandlerRegistry
- Class in
org.apache.qpid.server.cluster
MethodHandlerRegistry()
- Constructor for class org.apache.qpid.server.cluster.
MethodHandlerRegistry
methodReceived(AMQStateManager, QueueRegistry, ExchangeRegistry, AMQProtocolSession, AMQMethodEvent<A>)
- Method in class org.apache.qpid.server.cluster.handler.
ClusterMethodHandler
methodReceived(AMQStateManager, QueueRegistry, ExchangeRegistry, AMQProtocolSession, AMQMethodEvent<T>)
- Method in class org.apache.qpid.server.cluster.handler.
NullListener
methodReceived(AMQStateManager, QueueRegistry, ExchangeRegistry, AMQProtocolSession, AMQMethodEvent<BasicCancelBody>)
- Method in class org.apache.qpid.server.cluster.handler.
RemoteCancelHandler
methodReceived(AMQStateManager, QueueRegistry, ExchangeRegistry, AMQProtocolSession, AMQMethodEvent<BasicConsumeBody>)
- Method in class org.apache.qpid.server.cluster.handler.
RemoteConsumeHandler
methodReceived(AMQStateManager, QueueRegistry, ExchangeRegistry, AMQProtocolSession, AMQMethodEvent<T>)
- Method in class org.apache.qpid.server.cluster.handler.
WrappedListener
methodReceived(AMQStateManager, QueueRegistry, ExchangeRegistry, AMQProtocolSession, AMQMethodEvent)
- Method in class org.apache.qpid.server.cluster.replay.
ReplayStore
MinaBrokerProxy
- Class in
org.apache.qpid.server.cluster
A 'client stub' for a remote cluster peer, using MINA for IO Layer
MinaBrokerProxyFactory
- Class in
org.apache.qpid.server.cluster
MultiValuedMap
<
K
,
V
> - Class in
org.apache.qpid.server.cluster.util
Maps a key to a collection of values
MultiValuedMap()
- Constructor for class org.apache.qpid.server.cluster.util.
MultiValuedMap
N
NullListener
<
T
extends org.apache.qpid.framing.AMQMethodBody> - Class in
org.apache.qpid.server.cluster.handler
NullListener()
- Constructor for class org.apache.qpid.server.cluster.handler.
NullListener
O
OneResponseBroadcastPolicy
- Class in
org.apache.qpid.server.cluster.policy
OneResponseBroadcastPolicy()
- Constructor for class org.apache.qpid.server.cluster.policy.
OneResponseBroadcastPolicy
org.apache.qpid.server.cluster
- package org.apache.qpid.server.cluster
org.apache.qpid.server.cluster.handler
- package org.apache.qpid.server.cluster.handler
org.apache.qpid.server.cluster.policy
- package org.apache.qpid.server.cluster.policy
org.apache.qpid.server.cluster.replay
- package org.apache.qpid.server.cluster.replay
org.apache.qpid.server.cluster.util
- package org.apache.qpid.server.cluster.util
org.apache.qpid.server.queue
- package org.apache.qpid.server.queue
P
PATTERN
- Static variable in class org.apache.qpid.server.cluster.
ClusterCapability
PEER
- Static variable in class org.apache.qpid.server.cluster.
ClusterCapability
peer(AMQStateManager, QueueRegistry, ExchangeRegistry, AMQProtocolSession, AMQMethodEvent<A>)
- Method in class org.apache.qpid.server.cluster.handler.
ChainedClusterMethodHandler
peer(AMQStateManager, QueueRegistry, ExchangeRegistry, AMQProtocolSession, AMQMethodEvent<A>)
- Method in class org.apache.qpid.server.cluster.handler.
ClusterMethodHandler
peer(AMQStateManager, QueueRegistry, ExchangeRegistry, AMQProtocolSession, AMQMethodEvent<A>)
- Method in class org.apache.qpid.server.cluster.handler.
PeerHandler
PeerHandler
<
A
extends org.apache.qpid.framing.AMQMethodBody> - Class in
org.apache.qpid.server.cluster.handler
Base for implementing handlers that carry out different actions based on whether the method they are handling was sent by a peer (i.e.
PrivateQueue
- Class in
org.apache.qpid.server.queue
Used to represent a private queue held locally.
PrivateQueue(GroupManager, String, boolean, String, boolean, QueueRegistry)
- Constructor for class org.apache.qpid.server.queue.
PrivateQueue
PrivateQueue(GroupManager, String, boolean, String, boolean, QueueRegistry, Executor)
- Constructor for class org.apache.qpid.server.queue.
PrivateQueue
R
RecordingMethodHandlerFactory
- Class in
org.apache.qpid.server.cluster.replay
RecordingMethodHandlerFactory(MethodHandlerFactory, ReplayStore)
- Constructor for class org.apache.qpid.server.cluster.replay.
RecordingMethodHandlerFactory
redirect()
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
redirect()
- Method in interface org.apache.qpid.server.cluster.
GroupManager
redirect()
- Method in class org.apache.qpid.server.cluster.
LoadTable
register(AMQState, MethodHandlerRegistry)
- Method in class org.apache.qpid.server.cluster.handler.
ClusterMethodHandlerFactory
register(AMQState, MethodHandlerRegistry)
- Method in class org.apache.qpid.server.cluster.handler.
WrappingMethodHandlerFactory
register(AMQState, MethodHandlerRegistry)
- Method in interface org.apache.qpid.server.cluster.
MethodHandlerFactory
RemoteCancelHandler
- Class in
org.apache.qpid.server.cluster.handler
RemoteCancelHandler()
- Constructor for class org.apache.qpid.server.cluster.handler.
RemoteCancelHandler
RemoteConsumeHandler
- Class in
org.apache.qpid.server.cluster.handler
Handles consume requests from other cluster members.
RemoteConsumeHandler()
- Constructor for class org.apache.qpid.server.cluster.handler.
RemoteConsumeHandler
RemoteQueueProxy
- Class in
org.apache.qpid.server.queue
TODO: separate out an abstract base class from AMQQueue from which this inherits.
RemoteQueueProxy(MemberHandle, GroupManager, String, boolean, String, boolean, QueueRegistry)
- Constructor for class org.apache.qpid.server.queue.
RemoteQueueProxy
RemoteQueueProxy(MemberHandle, GroupManager, String, boolean, String, boolean, QueueRegistry, Executor)
- Constructor for class org.apache.qpid.server.queue.
RemoteQueueProxy
remove(K)
- Method in class org.apache.qpid.server.cluster.util.
MultiValuedMap
removeAllRemoteSubscriber(MemberHandle)
- Method in class org.apache.qpid.server.queue.
ClusteredQueue
removed()
- Method in class org.apache.qpid.server.cluster.
BlockingHandler
removed()
- Method in interface org.apache.qpid.server.cluster.
ResponseHandler
removeListener(T)
- Method in class org.apache.qpid.server.cluster.util.
InvokeMultiple
removeMemberhipChangeListener(MembershipChangeListener)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
removeMemberhipChangeListener(MembershipChangeListener)
- Method in interface org.apache.qpid.server.cluster.
GroupManager
removeRemoteSubscriber(MemberHandle)
- Method in class org.apache.qpid.server.queue.
ClusteredQueue
replay(boolean)
- Method in interface org.apache.qpid.server.cluster.replay.
ReplayManager
replay(boolean)
- Method in class org.apache.qpid.server.cluster.replay.
ReplayStore
ReplayManager
- Interface in
org.apache.qpid.server.cluster.replay
Abstraction of a replay strategy for use in getting joining members up to date with respect to cluster state.
ReplayStore
- Class in
org.apache.qpid.server.cluster.replay
Stores method invocations for replay to new members.
ReplayStore()
- Constructor for class org.apache.qpid.server.cluster.replay.
ReplayStore
replicate(AMQStateManager, QueueRegistry, ExchangeRegistry, AMQProtocolSession, AMQMethodEvent<BasicConsumeBody>)
- Method in class org.apache.qpid.server.cluster.handler.
ReplicatingConsumeHandler
ReplicatingConsumeHandler
- Class in
org.apache.qpid.server.cluster.handler
resolve()
- Method in class org.apache.qpid.server.cluster.
SimpleMemberHandle
resolve(MemberHandle)
- Static method in class org.apache.qpid.server.cluster.
SimpleMemberHandle
responded(AMQMethodBody)
- Method in class org.apache.qpid.server.cluster.
BlockingHandler
responded(AMQMethodBody)
- Method in interface org.apache.qpid.server.cluster.
ResponseHandler
response(List<AMQMethodBody>, List<Member>)
- Method in interface org.apache.qpid.server.cluster.
GroupResponseHandler
ResponseHandler
- Interface in
org.apache.qpid.server.cluster
S
send(MemberHandle, Sendable)
- Method in class org.apache.qpid.server.cluster.
DefaultGroupManager
send(MemberHandle, Sendable)
- Method in interface org.apache.qpid.server.cluster.
GroupManager
send(AMQDataBlock)
- Method in interface org.apache.qpid.server.cluster.
Member
send(AMQDataBlock)
- Method in class org.apache.qpid.server.cluster.
MinaBrokerProxy
send(int, Member)
- Method in interface org.apache.qpid.server.cluster.
Sendable
send(int, Member)
- Method in class org.apache.qpid.server.cluster.
SimpleSendable
Sendable
- Interface in
org.apache.qpid.server.cluster
setLoad(Member, long)
- Method in class org.apache.qpid.server.cluster.
LoadTable
setOptions(Options)
- Method in class org.apache.qpid.server.cluster.
Main
setSessionPeer(MemberHandle)
- Method in class org.apache.qpid.server.cluster.
ClusteredProtocolSession
setSessionPeer(AMQProtocolSession, MemberHandle)
- Static method in class org.apache.qpid.server.cluster.
ClusteredProtocolSession
SimpleMemberHandle
- Class in
org.apache.qpid.server.cluster
SimpleMemberHandle(String, int)
- Constructor for class org.apache.qpid.server.cluster.
SimpleMemberHandle
SimpleMemberHandle(String)
- Constructor for class org.apache.qpid.server.cluster.
SimpleMemberHandle
SimpleMemberHandle(InetSocketAddress)
- Constructor for class org.apache.qpid.server.cluster.
SimpleMemberHandle
SimpleMemberHandle(InetAddress, int)
- Constructor for class org.apache.qpid.server.cluster.
SimpleMemberHandle
SimpleSendable
- Class in
org.apache.qpid.server.cluster
SimpleSendable(AMQBody)
- Constructor for class org.apache.qpid.server.cluster.
SimpleSendable
SimpleSendable(List<AMQBody>)
- Constructor for class org.apache.qpid.server.cluster.
SimpleSendable
StandardPolicies
- Interface in
org.apache.qpid.server.cluster.policy
SYNCH_POLICY
- Static variable in interface org.apache.qpid.server.cluster.policy.
StandardPolicies
SynchBroadcastPolicy
- Class in
org.apache.qpid.server.cluster.policy
SynchBroadcastPolicy()
- Constructor for class org.apache.qpid.server.cluster.policy.
SynchBroadcastPolicy
T
toString()
- Method in class org.apache.qpid.server.cluster.
MinaBrokerProxy
toString()
- Method in class org.apache.qpid.server.cluster.
SimpleMemberHandle
toString()
- Method in class org.apache.qpid.server.cluster.
SimpleSendable
toString()
- Method in class org.apache.qpid.server.cluster.util.
LogMessage
type
- Variable in class org.apache.qpid.server.cluster.handler.
WrappingMethodHandlerFactory.FrameDescriptor
U
unbind1(K1)
- Method in class org.apache.qpid.server.cluster.util.
Bindings
unbind2(K2)
- Method in class org.apache.qpid.server.cluster.util.
Bindings
unregisterProtocolSession(AMQProtocolSession, int, String)
- Method in class org.apache.qpid.server.queue.
ClusteredQueue
V
valueOf(String)
- Static method in enum org.apache.qpid.server.cluster.
JoinState
Returns the enum constant of this type with the specified name.
values()
- Static method in enum org.apache.qpid.server.cluster.
JoinState
Returns an array containing the constants of this enum type, in the order they're declared.
values()
- Method in class org.apache.qpid.server.cluster.util.
Bindings
W
WrappedListener
<
T
extends org.apache.qpid.framing.AMQMethodBody> - Class in
org.apache.qpid.server.cluster.handler
WrappingMethodHandlerFactory
- Class in
org.apache.qpid.server.cluster.handler
WrappingMethodHandlerFactory(MethodHandlerFactory, StateAwareMethodListener, StateAwareMethodListener)
- Constructor for class org.apache.qpid.server.cluster.handler.
WrappingMethodHandlerFactory
WrappingMethodHandlerFactory.FrameDescriptor
<
A
extends org.apache.qpid.framing.AMQMethodBody,
B
extends java.lang.Class<
A
>> - Class in
org.apache.qpid.server.cluster.handler
WrappingMethodHandlerFactory.FrameDescriptor(B, A)
- Constructor for class org.apache.qpid.server.cluster.handler.
WrappingMethodHandlerFactory.FrameDescriptor
A
B
C
D
E
F
G
H
I
J
L
M
N
O
P
R
S
T
U
V
W
Overview
Package
Class
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes