com.caucho.bam.stream
Class FallbackMessageStream

java.lang.Object
  extended by com.caucho.bam.stream.AbstractMessageStream
      extended by com.caucho.bam.stream.NullMessageStream
          extended by com.caucho.bam.stream.FallbackMessageStream
All Implemented Interfaces:
MessageStream

public class FallbackMessageStream
extends NullMessageStream

Base ActorStream implementation using introspection and @Message annotations to simplify Actor development.

Message Handling

To handle a message, create a method with the proper signature for the expected payload type and annotate it with @Message. To send a response message or query, use getBrokerStream() or getClient().


Constructor Summary
FallbackMessageStream(MessageStream actorStream)
           
FallbackMessageStream(java.lang.String address, Broker broker, java.lang.Class<?> actorClass)
           
 
Method Summary
 java.lang.String toString()
           
 
Methods inherited from class com.caucho.bam.stream.NullMessageStream
getAddress, getBroker, setAddress, setBroker
 
Methods inherited from class com.caucho.bam.stream.AbstractMessageStream
isClosed, message, messageError, query, queryError, queryResult
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

FallbackMessageStream

public FallbackMessageStream(java.lang.String address,
                             Broker broker,
                             java.lang.Class<?> actorClass)

FallbackMessageStream

public FallbackMessageStream(MessageStream actorStream)
Method Detail

toString

public java.lang.String toString()
Overrides:
toString in class AbstractMessageStream