Examples of com.caucho.bam.stream.MessageStream

com.caucho.bam.stream.MessageStream
Primary stream handling all message packets. {@link com.caucho.bam.actor.ActorHolder Actors} send packets to the {@link com.caucho.bam.broker.Broker} for delivery to other Actors.Messages are divided into two groups:
- message - unidirectional messages
- query - RPC call/reply packets

    Mailbox inboundMailbox = createInboundMailbox(sender.getActor(),
                                                  outboundBroker);
    
    inboundBroker.setMailbox(inboundMailbox);
    
    MessageStream outboundStream
      = new OutboundMessageStream(_linkFactory, inboundBroker);
    
    Mailbox outboundMailbox = createOutboundMailbox(outboundStream,
                                                    inboundBroker);
    outboundBroker.setMailbox(outboundMailbox);

View Full Code Here

   * Returns the current stream to the actor, throwing an exception if
   * it's unavailable
   */
  public MessageStream getActorStream()
  {
    MessageStream stream = _actorStream;


    if (stream != null)
      return stream;
    else
      throw new RemoteConnectionFailedException("connection has been closed");

View Full Code Here

  }
  
  @Override
  public MessageStream getOutboundStream()
  {
    MessageStream stream = _hmtpListener.getOutboundStream();


    return stream;
  }

View Full Code Here


    Mailbox mailbox;
    
    // queue
    if (threadMax > 0) {
      MessageStream actorStream = bamActor.getActor();
      mailbox = new MultiworkerMailbox(address, actorStream, this, threadMax);
      // bamActor.setActorStream(actorStream);
    }
    else {
      mailbox = new PassthroughMailbox(address, bamActor.getActor(), this);

View Full Code Here


    ActorHolder bamActor = actor;
    Mailbox mailbox = null;
    // queue
    if (threadMax > 0) {
      MessageStream actorStream = bamActor.getActor();
      mailbox = new MultiworkerMailbox(address, actorStream, this, threadMax);
      bamActor.setMailbox(mailbox);
    }


    addMailbox(mailbox);

View Full Code Here

0 1

TOP

Related Classes of com.caucho.bam.stream.MessageStream

com.caucho.bam.actor.SimpleActorSender

com.caucho.bam.broker.AbstractBrokerStream

com.caucho.bam.client.LinkClient

com.caucho.hemp.broker.HempBroker

com.caucho.hmtp.HmtpLinkConnection

com.caucho.hmtp.HmtpLinkWorker

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.