Uses of Interface
com.caucho.bam.stream.MessageStream

Packages that use MessageStream
com.caucho.bam.actor   
com.caucho.bam.broker   
com.caucho.bam.client   
com.caucho.bam.mailbox   
com.caucho.bam.manager   
com.caucho.bam.packet   
com.caucho.bam.proxy   
com.caucho.bam.query   
com.caucho.bam.stream   
com.caucho.boot   
com.caucho.hemp.broker   
com.caucho.hemp.services   
com.caucho.hemp.servlet   
com.caucho.hmtp   
com.caucho.hmtp.server   
com.caucho.jsmp   
com.caucho.quercus.lib.bam   
com.caucho.server.admin   
com.caucho.server.cluster   
com.caucho.server.resin   
 

Uses of MessageStream in com.caucho.bam.actor
 

Subinterfaces of MessageStream in com.caucho.bam.actor
 interface Actor
          A BAM Actor sends and receives messages as the core class in a service-oriented architecture.
 interface ManagedActor
          A BAM Actor sends and receives messages as the core class in a service-oriented architecture.
 

Classes in com.caucho.bam.actor that implement MessageStream
 class AbstractActor
          Abstract implementation of a BAM actor.
 class SimpleActor
          Base class for implementing an Agent.
 class SkeletonActorFilter<T>
          Base ActorStream implementation using introspection and @Message annotations to simplify Actor development.
 

Methods in com.caucho.bam.actor that return MessageStream
 MessageStream ActorProxy.getActorStream()
          Returns the stream to this client.
 MessageStream ActorProxy.getClientStream()
          Returns the registered callback MessageStream.
 MessageStream ActorProxy.getLinkStream()
          The ActorStream to the link.
 MessageStream Agent.getMailbox()
          The stream to send messages to the actor.
 

Methods in com.caucho.bam.actor with parameters of type MessageStream
 void BamSkeleton.message(S actor, MessageStream fallback, java.lang.String to, java.lang.String from, java.io.Serializable payload)
          Dispatches a message to the actorStream.
 void BamSkeleton.messageError(S actor, MessageStream fallback, java.lang.String to, java.lang.String from, java.io.Serializable payload, BamError error)
           
 void BamSkeleton.query(S actor, MessageStream fallback, Broker broker, long id, java.lang.String to, java.lang.String from, java.io.Serializable payload)
           
 void BamSkeleton.queryError(S actor, MessageStream fallback, long id, java.lang.String to, java.lang.String from, java.io.Serializable payload, BamError error)
           
 void BamSkeleton.queryResult(S actor, MessageStream fallback, long id, java.lang.String to, java.lang.String from, java.io.Serializable payload)
           
 void ActorProxy.setClientStream(MessageStream clientStream)
          Registers a callback MessageStream with the client
 void ActorProxy.setLinkStream(MessageStream linkStream)
          Sets the ActorStream to the link.
 

Uses of MessageStream in com.caucho.bam.broker
 

Subinterfaces of MessageStream in com.caucho.bam.broker
 interface Broker
          Broker is the hub which routes messages to mailboxes.
 interface LinkBroker
          Client/Server Broker from the perspective of the client, i.e.
 interface ManagedBroker
          Broker is the hub which routes messages to mailboxes.
 

Classes in com.caucho.bam.broker that implement MessageStream
 class AbstractBroker
          Broker is the hub which routes messages to actors.
 class AbstractBrokerStream
          The abstract implementation of an MessageStream returns query errors for RPC packets, and ignores unknown packets for messages and presence announcement.
 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.
 

Methods in com.caucho.bam.broker that return MessageStream
protected  MessageStream AbstractBrokerStream.getQueryErrorStream(java.lang.String from)
           
 

Methods in com.caucho.bam.broker with parameters of type MessageStream
 Agent AbstractManagedBroker.createAgent(MessageStream actorStream)
          Creates an agent
 Agent ManagedBroker.createAgent(MessageStream actorStream)
          Creates an agent
 Agent AbstractManagedBroker.createAgent(MessageStream actorStream, MailboxType mailboxType)
          Creates an agent
 Agent ManagedBroker.createAgent(MessageStream actorStream, MailboxType mailboxType)
          Creates an agent
protected  Mailbox AbstractManagedBroker.createMailbox(MessageStream actorStream, MailboxType mailboxType)
           
protected  Mailbox AbstractManagedBroker.createMailbox(java.lang.String address, MessageStream actorStream, MailboxType mailboxType)
           
 void HashMapBroker.removeMailbox(MessageStream actor)
          Removes an actor from the broker.
 

Uses of MessageStream in com.caucho.bam.client
 

Classes in com.caucho.bam.client that implement MessageStream
 class OutboundMessageStream
          HMTP client protocol
 

Methods in com.caucho.bam.client that return MessageStream
 MessageStream LinkConnection.getOutboundStream()
           
 

Methods in com.caucho.bam.client with parameters of type MessageStream
protected  Mailbox LinkClient.createInboundMailbox(MessageStream inboundStream, Broker outboundBroker)
           
protected  Mailbox LinkClient.createOutboundMailbox(MessageStream outboundStream, Broker inboundBroker)
           
 

Uses of MessageStream in com.caucho.bam.mailbox
 

Subinterfaces of MessageStream in com.caucho.bam.mailbox
 interface Mailbox
          Mailbox for an actor
 

Classes in com.caucho.bam.mailbox that implement MessageStream
 class ActorMailbox
          mailbox for BAM messages waiting to be sent to the Actor.
 class DualSizeMailbox
          Mailbox which filters large messages to a separate queue, so large messages don't block small messages.
 class MultiworkerMailbox
          mailbox for BAM messages waiting to be sent to the Actor.
 class PassthroughMailbox
          mailbox for BAM messages waiting to be sent to the Actor.
 

Methods in com.caucho.bam.mailbox that return MessageStream
 MessageStream DualSizeMailbox.getActorStream()
           
 MessageStream Mailbox.getActorStream()
          Returns the actor stream for the actor itself.
 MessageStream MultiworkerMailbox.getActorStream()
           
 MessageStream PassthroughMailbox.getActorStream()
           
 

Constructors in com.caucho.bam.mailbox with parameters of type MessageStream
ActorMailbox(MessageStream actorStream, Broker broker)
           
ActorMailbox(java.lang.String address, MessageStream actorStream, Broker broker)
           
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)
           
 

Uses of MessageStream in com.caucho.bam.manager
 

Methods in com.caucho.bam.manager with parameters of type MessageStream
 Agent BamManager.createAgent(MessageStream actorStream)
          Creates an agent
 Agent SimpleBamManager.createAgent(MessageStream actorStream)
          Creates an agent
 Agent BamManager.createAgent(MessageStream actorStream, MailboxType mailboxType)
          Creates an agent
 Agent SimpleBamManager.createAgent(MessageStream actorStream, MailboxType mailboxType)
          Creates an agent
protected  Mailbox SimpleBamManager.createMailbox(MessageStream actorStream, MailboxType mailboxType)
           
protected  Mailbox SimpleBamManager.createMailbox(java.lang.String address, MessageStream actorStream, MailboxType mailboxType)
           
 

Uses of MessageStream in com.caucho.bam.packet
 

Methods in com.caucho.bam.packet with parameters of type MessageStream
 void Message.dispatch(MessageStream handler, MessageStream toSource)
          SPI method to dispatch the packet to the proper handler
 void MessageError.dispatch(MessageStream handler, MessageStream toSource)
          SPI method to dispatch the packet to the proper handler
 void Packet.dispatch(MessageStream handler, MessageStream toSource)
          SPI method to dispatch the packet to the proper handler
 void Query.dispatch(MessageStream handler, MessageStream toSource)
          SPI method to dispatch the packet to the proper handler
 void QueryError.dispatch(MessageStream handler, MessageStream toSource)
          SPI method to dispatch the packet to the proper handler
 void QueryResult.dispatch(MessageStream handler, MessageStream toSource)
          SPI method to dispatch the packet to the proper handler
 void Packet.dispatchError(MessageStream handler, MessageStream toSource, BamError error)
          SPI method to dispatch the packet to the proper handler
 void Query.dispatchError(MessageStream handler, MessageStream toSource, BamError error)
          SPI method to dispatch the packet to the proper handler
 

Uses of MessageStream in com.caucho.bam.proxy
 

Classes in com.caucho.bam.proxy that implement MessageStream
 class ProxyActor<T>
          The Skeleton introspects and dispatches messages for a SimpleActor or SkeletonActorFilter.
 

Methods in com.caucho.bam.proxy with parameters of type MessageStream
 void ProxySkeleton.message(S actor, MessageStream fallback, java.lang.String to, java.lang.String from, java.io.Serializable payload)
          Dispatches a message to the actorStream.
 void ProxySkeleton.messageError(S actor, MessageStream fallback, java.lang.String to, java.lang.String from, java.io.Serializable payload, BamError error)
           
 void ProxySkeleton.query(S actor, MessageStream fallback, Broker broker, long id, java.lang.String to, java.lang.String from, java.io.Serializable payload)
           
 void ProxySkeleton.queryError(S actor, MessageStream fallback, long id, java.lang.String to, java.lang.String from, java.io.Serializable payload, BamError error)
           
 void ProxySkeleton.queryResult(S actor, MessageStream fallback, long id, java.lang.String to, java.lang.String from, java.io.Serializable payload)
           
 

Uses of MessageStream in com.caucho.bam.query
 

Classes in com.caucho.bam.query that implement MessageStream
 class QueryActorFilter
          An ActorStream filter that intercepts query results and passes them to the QueryManager to be matched with pending queries.
 class QueryMessageStreamFilter
          An ActorStream filter that intercepts query results and passes them to the QueryManager to be matched with pending queries.
 

Methods in com.caucho.bam.query with parameters of type MessageStream
 java.io.Serializable QueryManager.query(MessageStream stream, java.lang.String to, java.lang.String from, java.io.Serializable payload, long timeout)
          Queries through to a stream.
 void QueryManager.query(MessageStream stream, java.lang.String to, java.lang.String from, java.io.Serializable payload, QueryCallback cb, long timeout)
          Queries through to a stream.
 

Constructors in com.caucho.bam.query with parameters of type MessageStream
QueryMessageStreamFilter(MessageStream next, QueryManager queryManager)
           
 

Uses of MessageStream in com.caucho.bam.stream
 

Classes in com.caucho.bam.stream that implement MessageStream
 class AbstractMessageStream
          The abstract implementation of an MessageStream returns query errors for RPC packets, and ignores unknown packets for messages and presence announcement.
 class AbstractMessageStreamFilter
          Abstract implementation of a BAM filter.
 class FallbackMessageStream
          Base ActorStream implementation using introspection and @Message annotations to simplify Actor development.
 class NullActor
          NullActorStream always ignores messages and returns errors for RPC calls.
 class NullMessageStream
          NullActorStream always ignores messages and returns errors for RPC calls.
 

Methods in com.caucho.bam.stream that return MessageStream
protected abstract  MessageStream AbstractMessageStreamFilter.getNext()
           
 

Constructors in com.caucho.bam.stream with parameters of type MessageStream
FallbackMessageStream(MessageStream actorStream)
           
 

Uses of MessageStream in com.caucho.boot
 

Classes in com.caucho.boot that implement MessageStream
 class WatchdogChildActor
          Service for handling the distributed cache
 

Uses of MessageStream in com.caucho.hemp.broker
 

Classes in com.caucho.hemp.broker that implement MessageStream
 class HempBroker
          Broker
 

Methods in com.caucho.hemp.broker that return MessageStream
 MessageStream HempDomainManager.removeDomain(java.lang.String name)
           
 

Uses of MessageStream in com.caucho.hemp.services
 

Classes in com.caucho.hemp.services that implement MessageStream
 class BamJmsService
          jms service
 class BamLogService
          log service
 class BamMailService
          mail service
 

Uses of MessageStream in com.caucho.hemp.servlet
 

Subinterfaces of MessageStream in com.caucho.hemp.servlet
 interface LinkActor
          ServerLinkActor handles link messages, i.e.
 

Classes in com.caucho.hemp.servlet that implement MessageStream
 class ServerGatewayBroker
          Handles the requests to the server from the link, dispatching requests to the link service and the broker.
 class ServerLinkActor
          ServerLinkActor handles link messages, i.e.
 class ServerProxyBroker
          Handles the requests to the server from the link, dispatching requests to the link service and the broker.
 

Methods in com.caucho.hemp.servlet that return MessageStream
protected  MessageStream ServerProxyBroker.getQueryErrorStream(java.lang.String from)
           
 

Constructors in com.caucho.hemp.servlet with parameters of type MessageStream
ServerGatewayBroker(Broker broker, ClientStubManager clientManager, MessageStream linkActor)
           
ServerProxyBroker(Broker broker, ClientStubManager clientManager, MessageStream linkActor)
           
 

Uses of MessageStream in com.caucho.hmtp
 

Classes in com.caucho.hmtp that implement MessageStream
 class HmtpWebSocketContextWriter
          HmtpWriteStream writes HMTP packets to an OutputStream.
 class HmtpWebSocketWriter
          HmtpWriteStream writes HMTP packets to an OutputStream.
 

Methods in com.caucho.hmtp that return MessageStream
 MessageStream HmtpLinkWorker.getActorStream()
          Returns the current stream to the actor, throwing an exception if it's unavailable
 MessageStream HmtpLinkWorker.getLinkStream()
           
 

Methods in com.caucho.hmtp with parameters of type MessageStream
 boolean HmtpReader.readPacket(java.io.InputStream is, MessageStream actorStream)
          Reads the next HMTP packet from the stream, returning false on end of file.
 boolean HmtpWebSocketReader.readPacket(MessageStream actorStream)
          Reads the next HMTP packet from the stream, returning false on end of file.
 

Uses of MessageStream in com.caucho.hmtp.server
 

Classes in com.caucho.hmtp.server that implement MessageStream
 class HmtpServlet
          HmtpWriteStream writes HMTP packets to an OutputStream.
 

Methods in com.caucho.hmtp.server that return MessageStream
protected  MessageStream HmtpServlet.getFallbackStream()
           
 

Methods in com.caucho.hmtp.server with parameters of type MessageStream
protected  com.caucho.hmtp.server.ClientLinkActor HmtpServlet.createClientLinkActor(java.lang.String uid, MessageStream hmtpStream)
          Creates and returns the actor for the client link
 

Uses of MessageStream in com.caucho.jsmp
 

Classes in com.caucho.jsmp that implement MessageStream
 class JsmpWebSocketWriter
          JsmpWriteStream writes JSMP packets to an OutputStream.
 

Methods in com.caucho.jsmp with parameters of type MessageStream
 boolean JsmpReader.readPacket(MessageStream actorStream)
          Reads the next HMTP packet from the stream, returning false on end of file.
 

Uses of MessageStream in com.caucho.quercus.lib.bam
 

Classes in com.caucho.quercus.lib.bam that implement MessageStream
 class BamPhpActor
          BAM actor that calls into a PHP script to handle messages/queries.
 class BamPhpRootService
          BAM actor spawns a new BamPhpActor when requested.
 

Uses of MessageStream in com.caucho.server.admin
 

Classes in com.caucho.server.admin that implement MessageStream
 class ManagerActor
           
 

Uses of MessageStream in com.caucho.server.cluster
 

Methods in com.caucho.server.cluster that return MessageStream
 MessageStream ServletService.getHmtpStream()
          Returns any HMTP stream
 

Uses of MessageStream in com.caucho.server.resin
 

Classes in com.caucho.server.resin that implement MessageStream
 class ResinActor
          Actor communicating with the watchdog.