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

Packages that use MessageStream
com.caucho.admin   
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.query   
com.caucho.bam.stream   
com.caucho.boot   
com.caucho.cloud.bam   
com.caucho.cloud.globalcache   
com.caucho.cloud.heartbeat   
com.caucho.cloud.license   
com.caucho.cloud.network   
com.caucho.cloud.notify   
com.caucho.distcache.cluster   
com.caucho.hemp.broker   
com.caucho.hemp.services   
com.caucho.hemp.servlet   
com.caucho.hmtp   
com.caucho.hmtp.server   
com.caucho.jms.cluster   
com.caucho.jsmp   
com.caucho.quercus.lib.bam   
com.caucho.server.admin   
com.caucho.server.cluster   
com.caucho.server.distlock   
com.caucho.server.repository   
com.caucho.server.resin   
com.caucho.xmpp   
 

Uses of MessageStream in com.caucho.admin
 

Classes in com.caucho.admin that implement MessageStream
 class JmxService
          Remote administration service for JMX
 

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 PassthroughBroker
          Broker is the hub which routes messages to actors.
 

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 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 PassthroughMailbox.getActorStream()
           
 MessageStream Mailbox.getActorStream()
          Returns the actor stream for the actor itself.
 MessageStream MultiworkerMailbox.getActorStream()
           
 

Constructors in com.caucho.bam.mailbox with parameters of type MessageStream
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 SimpleBamManager.createAgent(MessageStream actorStream)
          Creates an agent
 Agent BamManager.createAgent(MessageStream actorStream)
          Creates an agent
 Agent SimpleBamManager.createAgent(MessageStream actorStream, MailboxType mailboxType)
          Creates an agent
 Agent BamManager.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 Packet.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 Query.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 MessageError.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.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.
 

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 WatchdogActor
          Service for handling the distributed cache
 

Uses of MessageStream in com.caucho.cloud.bam
 

Classes in com.caucho.cloud.bam that implement MessageStream
 class AbstractCloudActor
          Abstract actor for handling messages in the cloud.
 class HmuxQueue
          Queue of hmtp packets
 

Uses of MessageStream in com.caucho.cloud.globalcache
 

Classes in com.caucho.cloud.globalcache that implement MessageStream
 class GlobalCacheActor
           
 

Uses of MessageStream in com.caucho.cloud.heartbeat
 

Classes in com.caucho.cloud.heartbeat that implement MessageStream
 class HeartbeatActor
          Service for handling the cache messages
 

Uses of MessageStream in com.caucho.cloud.license
 

Classes in com.caucho.cloud.license that implement MessageStream
 class LicenseActor
          Service for handling the cache messages
 

Uses of MessageStream in com.caucho.cloud.network
 

Classes in com.caucho.cloud.network that implement MessageStream
 class NetworkAddressActor
          Service for handling the cache messages
 

Uses of MessageStream in com.caucho.cloud.notify
 

Classes in com.caucho.cloud.notify that implement MessageStream
 class NotifyActor
           
 

Uses of MessageStream in com.caucho.distcache.cluster
 

Classes in com.caucho.distcache.cluster that implement MessageStream
 class CacheDataActor
          Service for handling the distributed cache
 class CacheDataTriadActor
          Actor on a triad server handling the cache data requests.
 class CacheMnodeActor
          Service for handling the distributed cache
 class CacheMnodeTriadActor
          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.
 

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.jms.cluster
 

Classes in com.caucho.jms.cluster that implement MessageStream
 class ClusterQueueActor
          Implements a cluster send queue.
 class ClusterQueueTriadActor
          Implements a cluster send queue.
 

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 ClusterStatService
          Service for handling the distributed cache
 class DeployActor
           
 class JMXService
          Remote administration service for JMX
 class JmxServiceImpl
          Remote administration service for JMX
 class ManagerActor
           
 

Uses of MessageStream in com.caucho.server.cluster
 

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

Uses of MessageStream in com.caucho.server.distlock
 

Classes in com.caucho.server.distlock that implement MessageStream
 class VoteActor
          Service for handling the distributed lock
 

Uses of MessageStream in com.caucho.server.repository
 

Classes in com.caucho.server.repository that implement MessageStream
 class RepositoryActor
           
 

Uses of MessageStream in com.caucho.server.resin
 

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

Uses of MessageStream in com.caucho.xmpp
 

Classes in com.caucho.xmpp that implement MessageStream
 class XmppAgentStream
          Handles callbacks for a xmpp service
 class XmppBindCallback
          Protocol handler from the TCP/XMPP stream forwarding to the broker
 class XmppBrokerStream
          Protocol handler from the TCP/XMPP stream forwarding to the broker
 class XmppWriter
          xmpp client to broker
 

Methods in com.caucho.xmpp that return MessageStream
 MessageStream XmppClient.getBrokerStream()
           
 

Methods in com.caucho.xmpp with parameters of type MessageStream
 void XmppClient.setCallback(MessageStream callback)