|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |