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

Packages that use MessageStream

Package	Description
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.cloud.bam
com.caucho.cloud.license
com.caucho.cloud.network
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.resin

Uses of MessageStream in com.caucho.bam.actor

Subinterfaces of MessageStream in com.caucho.bam.actor

Modifier and Type	Interface and Description
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

Modifier and Type	Class and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Interface and Description
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

Modifier and Type	Class and Description
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

Modifier and Type	Method and Description
protected MessageStream	AbstractBrokerStream.getQueryErrorStream(java.lang.String from)

Methods in com.caucho.bam.broker with parameters of type MessageStream

Modifier and Type	Method and Description
Agent	ManagedBroker.createAgent(MessageStream actorStream) Creates an agent
Agent	AbstractManagedBroker.createAgent(MessageStream actorStream) Creates an agent
Agent	ManagedBroker.createAgent(MessageStream actorStream, MailboxType mailboxType) Creates an agent
Agent	AbstractManagedBroker.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

Modifier and Type	Class and Description
class	OutboundMessageStream HMTP client protocol

Methods in com.caucho.bam.client that return MessageStream

Modifier and Type	Method and Description
MessageStream	LinkConnection.getOutboundStream()

Methods in com.caucho.bam.client with parameters of type MessageStream

Modifier and Type	Method and Description
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

Modifier and Type	Interface and Description
interface	Mailbox Mailbox for an actor

Classes in com.caucho.bam.mailbox that implement MessageStream

Modifier and Type	Class and Description
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

Modifier and Type	Method and Description
MessageStream	PassthroughMailbox.getActorStream()
MessageStream	DualSizeMailbox.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

Constructor and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
void	Message.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.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	Query.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

Modifier and Type	Class and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Class and Description
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

Modifier and Type	Method and Description
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

Constructor and Description
QueryMessageStreamFilter(MessageStream next, QueryManager queryManager)

Uses of MessageStream in com.caucho.bam.stream

Classes in com.caucho.bam.stream that implement MessageStream

Modifier and Type	Class and Description
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

Modifier and Type	Method and Description
protected abstract MessageStream	AbstractMessageStreamFilter.getNext()

Constructors in com.caucho.bam.stream with parameters of type MessageStream

Constructor and Description
FallbackMessageStream(MessageStream actorStream)

Uses of MessageStream in com.caucho.boot

Classes in com.caucho.boot that implement MessageStream

Modifier and Type	Class and Description
class	WatchdogChildActor Service for handling the distributed cache

Uses of MessageStream in com.caucho.cloud.bam

Classes in com.caucho.cloud.bam that implement MessageStream

Modifier and Type	Class and Description
class	AbstractCloudActor Abstract actor for handling messages in the cloud.
class	ClusterRouteActor Abstract actor for handling cluster routing.
class	GlobalTriadFirstRouter Routes a message to all pods in the system,
class	HmuxQueue Queue of hmtp packets
class	TriadAllRouter Routes a message to all members of a triad.
class	TriadFirstRouter Routes a message to all members of a triad.

Methods in com.caucho.cloud.bam that return MessageStream

Modifier and Type	Method and Description
MessageStream	HmuxQueue.getConnErrorStream()

Uses of MessageStream in com.caucho.cloud.license

Classes in com.caucho.cloud.license that implement MessageStream

Modifier and Type	Class and Description
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

Modifier and Type	Class and Description
class	NetworkAddressActor Service for handling the cache messages

Uses of MessageStream in com.caucho.hemp.broker

Classes in com.caucho.hemp.broker that implement MessageStream

Modifier and Type	Class and Description
class	HempBroker Broker

Methods in com.caucho.hemp.broker that return MessageStream

Modifier and Type	Method and Description
MessageStream	HempDomainManager.removeDomain(java.lang.String name)

Uses of MessageStream in com.caucho.hemp.services

Classes in com.caucho.hemp.services that implement MessageStream

Modifier and Type	Class and Description
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

Modifier and Type	Interface and Description
interface	LinkActor ServerLinkActor handles link messages, i.e.

Classes in com.caucho.hemp.servlet that implement MessageStream

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	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

Modifier and Type	Method and Description
protected MessageStream	ServerProxyBroker.getQueryErrorStream(java.lang.String from)

Constructors in com.caucho.hemp.servlet with parameters of type MessageStream

Constructor and Description
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

Modifier and Type	Class and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Class and Description
class	HmtpServlet HmtpWriteStream writes HMTP packets to an OutputStream.

Methods in com.caucho.hmtp.server that return MessageStream

Modifier and Type	Method and Description
protected MessageStream	HmtpServlet.getFallbackStream()

Methods in com.caucho.hmtp.server with parameters of type MessageStream

Modifier and Type	Method and Description
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

Modifier and Type	Class and Description
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

Modifier and Type	Class and Description
class	JsmpWebSocketWriter JsmpWriteStream writes JSMP packets to an OutputStream.

Methods in com.caucho.jsmp with parameters of type MessageStream

Modifier and Type	Method and Description
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

Modifier and Type	Class and Description
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

Modifier and Type	Class and Description
class	ClusterStatService Service for handling the distributed cache
class	JMXService Remote administration service for JMX
class	ManagerActor

Uses of MessageStream in com.caucho.server.cluster

Methods in com.caucho.server.cluster that return MessageStream

Modifier and Type	Method and Description
MessageStream	ServletService.getHmtpStream() Returns any HMTP stream

Uses of MessageStream in com.caucho.server.resin

Classes in com.caucho.server.resin that implement MessageStream

Modifier and Type	Class and Description
class	ResinActor Actor communicating with the watchdog.