| 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  | LinkBrokerClient/Server Broker from the perspective of the client, i.e. | 
| interface  | ManagedBrokerBroker is the hub which routes messages to mailboxes. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | AbstractBrokerBroker is the hub which routes messages to actors. | 
| class  | AbstractLinkBrokerBroker is the hub which routes messages to actors. | 
| class  | AbstractManagedBrokerBroker is the hub which routes messages to actors. | 
| class  | HashMapBrokerThe abstract implementation of an  MessageStreamreturns query errors for RPC packets, and ignores unknown packets
 for messages and presence announcement. | 
| class  | ManagedBrokerAdapterBroker is the hub which routes messages to actors. | 
| class  | PassthroughBrokerBroker 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  | HempBrokerBroker | 
| 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  | ServerGatewayBrokerHandles the requests to the server from the link, dispatching requests to
 the link service and the broker. | 
| class  | ServerProxyBrokerHandles 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  | HmtpWebSocketContextWriterHmtpWriteStream writes HMTP packets to an OutputStream. | 
| class  | HmtpWebSocketWriterHmtpWriteStream 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 |