Modifier and Type | Method and Description |
---|---|
Broker |
Agent.getBroker()
Returns the actor's broker.
|
Broker |
AbstractActorHolder.getBroker()
The stream to the link is used by the Actor to send messages to
all other Actors in the system.
|
Broker |
SkeletonActorFilter.getBroker()
Returns the stream to the broker for query results or errors, or
low-level messaging.
|
Broker |
ActorSender.getBroker()
The underlying broker.
|
abstract Broker |
AbstractActorSender.getBroker()
The underlying broker.
|
Broker |
SimpleActorSender.getBroker()
The underlying, low-level stream to the link
|
Broker |
ActorHolder.getBroker() |
Broker |
SimpleActor.getBroker() |
Broker |
AbstractAgent.getBroker()
Returns the actor's broker.
|
Modifier and Type | Method and Description |
---|---|
void |
BamSkeleton.query(S actor,
MessageStream fallback,
Broker broker,
long id,
java.lang.String to,
java.lang.String from,
java.io.Serializable payload) |
void |
AbstractActorHolder.setBroker(Broker broker)
The stream to the link is used by the Actor to send messages to
all other Actors in the system.
|
void |
ManagedActor.setBroker(Broker broker) |
void |
SimpleActorSender.setBroker(Broker broker) |
void |
ActorHolder.setBroker(Broker broker) |
void |
SimpleActor.setBroker(Broker broker) |
Constructor and Description |
---|
AbstractAgent(java.lang.String address,
Mailbox mailbox,
Broker broker) |
SimpleActor(java.lang.String address,
Broker broker) |
SimpleActorRef(java.lang.String address,
Broker broker) |
SimpleActorSender(java.lang.String address,
Actor next,
Broker broker) |
SimpleActorSender(java.lang.String address,
Broker broker) |
Modifier and Type | Interface and Description |
---|---|
interface |
LinkBroker
Client/Server Broker from the perspective of the client, i.e.
|
interface |
ManagedBroker
Broker is the hub which routes messages to mailboxes.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractBroker
Broker is the hub which routes messages to actors.
|
class |
AbstractLinkBroker
Broker is the hub which routes messages to actors.
|
class |
AbstractManagedBroker
Broker is the hub which routes messages to actors.
|
class |
HashMapBroker
The abstract implementation of an
MessageStream
returns query errors for RPC packets, and ignores unknown packets
for messages and presence announcement. |
class |
ManagedBrokerAdapter
Broker is the hub which routes messages to actors.
|
class |
PassthroughBroker
Broker is the hub which routes messages to actors.
|
Modifier and Type | Method and Description |
---|---|
Broker |
ManagedBrokerAdapter.getBroker() |
Broker |
ActorMissingEvent.getBroker()
Returns the Broker which sent the missing actor event.
|
Broker |
AbstractBroker.getBroker()
The broker returns itself for the broker.
|
Modifier and Type | Method and Description |
---|---|
static ManagedBroker |
ManagedBrokerAdapter.create(Broker broker) |
Constructor and Description |
---|
ActorMissingEvent(Broker broker,
java.lang.String address) |
ManagedBrokerAdapter(Broker broker) |
Modifier and Type | Method and Description |
---|---|
Broker |
OutboundMessageStream.getBroker() |
Broker |
LinkClient.getBroker() |
Modifier and Type | Method and Description |
---|---|
protected Mailbox |
LinkClient.createInboundMailbox(MessageStream inboundStream,
Broker outboundBroker) |
protected Mailbox |
LinkClient.createOutboundMailbox(MessageStream outboundStream,
Broker inboundBroker) |
LinkConnection |
LinkConnectionFactory.open(Broker broker) |
Constructor and Description |
---|
OutboundMessageStream(LinkConnectionFactory linkFactory,
Broker inboundBroker) |
Modifier and Type | Method and Description |
---|---|
Broker |
PassthroughMailbox.getBroker() |
Broker |
DualSizeMailbox.getBroker() |
Broker |
MultiworkerMailbox.getBroker()
Returns the stream back to the link for error packets
|
Constructor and Description |
---|
ActorMailbox(MessageStream actorStream,
Broker broker) |
ActorMailbox(java.lang.String address,
MessageStream actorStream,
Broker broker) |
DualSizeMailbox(java.lang.String address,
Broker broker,
Mailbox smallMailbox,
Mailbox largeMailbox) |
MultiworkerMailbox(MessageStream actorStream,
Broker broker,
int threadMax) |
MultiworkerMailbox(java.lang.String address,
MessageStream actorStream,
Broker broker,
int threadMax) |
PassthroughMailbox(java.lang.String address,
MessageStream actorStream,
Broker broker) |
Modifier and Type | Method and Description |
---|---|
Broker |
BamManager.getBroker()
Returns the managed broker
|
Constructor and Description |
---|
SimpleBamManager(Broker broker) |
Modifier and Type | Method and Description |
---|---|
Broker |
ProxyActor.getBroker() |
Modifier and Type | Method and Description |
---|---|
void |
ProxySkeleton.query(S actor,
MessageStream fallback,
Broker broker,
long id,
java.lang.String to,
java.lang.String from,
java.io.Serializable payload) |
Constructor and Description |
---|
ProxyActor(T bean,
java.lang.String address,
Broker broker) |
Modifier and Type | Method and Description |
---|---|
Broker |
QuerySender.getBroker()
The underlying broker.
|
Broker |
QueryMessageStreamFilter.getBroker() |
Broker |
QueryActorFilter.getBroker() |
Modifier and Type | Method and Description |
---|---|
Broker |
AbstractMessageStream.getBroker() |
Broker |
NullMessageStream.getBroker()
The stream to the link.
|
Broker |
MessageStream.getBroker()
Returns the owning broker
|
Broker |
AbstractMessageStreamFilter.getBroker()
Returns the broker of the final actor.
|
Modifier and Type | Method and Description |
---|---|
protected void |
NullMessageStream.setBroker(Broker broker) |
void |
NullActor.setBroker(Broker broker) |
Constructor and Description |
---|
FallbackMessageStream(java.lang.String address,
Broker broker,
java.lang.Class<?> actorClass) |
NullActor(java.lang.String address,
Broker broker) |
NullMessageStream(java.lang.String address,
Broker broker) |
Constructor and Description |
---|
CloudServerActorRef(java.lang.String address,
Broker broker,
CloudPod pod,
int index) |
CloudServerNullActorRef(java.lang.String address,
Broker broker) |
CloudServerRemoteActorRef(java.lang.String address,
Broker broker,
CloudPod pod,
int index) |
GlobalTriadFirstRouter(java.lang.String uid,
ClusterRouteManager routeManager,
TriadOwner owner,
Broker broker) |
HmtpStream(ClientSocketFactory socketPool,
ClientSocket stream,
Broker broker,
SecurityService security) |
ProDomainManager(CloudServer selfServer,
Broker broker) |
RouterQueryCallback(long id,
java.lang.String to,
java.lang.String from,
Broker broker) |
TriadAllRouter(java.lang.String uid,
ClusterRouteManager routeManager,
TriadOwner owner,
Broker broker) |
TriadFirstRouter(java.lang.String uid,
ClusterRouteManager routeManager,
TriadOwner owner,
Broker broker,
BamTriadDispatcher.RemoteEnum isRemote) |
Modifier and Type | Class and Description |
---|---|
class |
HempBroker
Broker
|
Modifier and Type | Method and Description |
---|---|
Broker |
HempBrokerManager.findBroker(java.lang.String name) |
Broker |
HempBrokerManager.removeBroker(java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
void |
HempBrokerManager.addBroker(java.lang.String name,
Broker broker) |
Modifier and Type | Class and Description |
---|---|
class |
ServerGatewayBroker
Handles the requests to the server from the link, dispatching requests to
the link service and the broker.
|
class |
ServerProxyBroker
Handles the requests to the server from the link, dispatching requests to
the link service and the broker.
|
Constructor and Description |
---|
ServerGatewayBroker(Broker broker,
ClientStubManager clientManager,
MessageStream linkActor) |
ServerLinkActor(Broker toLinkBroker,
ClientStubManager clientManager,
ServerAuthManager authManager,
java.lang.String ipAddress) |
ServerProxyBroker(Broker broker,
ClientStubManager clientManager,
MessageStream linkActor) |
Modifier and Type | Class and Description |
---|---|
class |
HmtpWebSocketContextWriter
HmtpWriteStream writes HMTP packets to an OutputStream.
|
class |
HmtpWebSocketWriter
HmtpWriteStream writes HMTP packets to an OutputStream.
|
Modifier and Type | Method and Description |
---|---|
Broker |
HmtpClient.getBroker() |
Constructor and Description |
---|
HmtpWebSocketListener(Broker broker) |
Modifier and Type | Method and Description |
---|---|
void |
HmtpServlet.setBroker(Broker broker) |
Modifier and Type | Method and Description |
---|---|
Broker |
HmuxClient.getBroker() |
Broker |
ServletService.getBroker()
Returns the admin broker.
|
Modifier and Type | Method and Description |
---|---|
Broker |
Host.getBamBroker()
Returns the bam broker.
|
Modifier and Type | Method and Description |
---|---|
Broker |
Resin.getAdminBroker()
Returns the admin broker
|