Examples of org.apache.etch.bindings.java.msg.Message

Package org.apache.etch.bindings.java.msg

Examples of org.apache.etch.bindings.java.msg.Message

org.apache.etch.bindings.java.msg.Message
A message is modeled as a command and some argments. The command is an arbitrary integer value, and the arguments are key / value pairs, where the key is an arbitrary integer value and the value is any one of the standard java objects, an ArrayValue, a StructValue, or any type which may be serialized by the ValueFactory.

    
    assertNull( transport.what );
    assertNull( transport.recipient );
    assertNull( transport.msg );
    
    Message msg = constructAddMessage();
    assertNull( msg.getMessageId() );
    assertNull( msg.getInReplyTo() );
    
    Mailbox mb = mmgr.transportCall( who, msg );
    
    assertSame( transport.what, What.TRANSPORT_MESSAGE );
    assertSame( transport.recipient, who );
    assertSame( transport.msg, msg );
    assertNotNull( mb );
    
    assertEquals( 1, mmgr.size() );
    assertNotNull( msg.getMessageId() );
    assertNull( msg.getInReplyTo() );
    assertSame( mb, mmgr.getMailbox( msg.getMessageId() ) );
    
    mb.closeDelivery();
    
    assertEquals( 0, mmgr.size() );
    assertNull( mmgr.getMailbox( msg.getMessageId() ) );
  }

View Full Code Here

    
    assertNull( transport.what );
    assertNull( transport.recipient );
    assertNull( transport.msg );
    
    Message msg = constructAddMessage();
    assertNull( msg.getMessageId() );
    assertNull( msg.getInReplyTo() );
    msg.setMessageId( 1L );


    try
    {
      // this should trigger msg already sent
      mmgr.transportCall( who, msg );
    }
    finally
    {
      assertEquals( 0, mmgr.size() );
      assertNull( mmgr.getMailbox( msg.getMessageId() ) );
    }
  }

View Full Code Here

  {
    assertNull( transport.what );
    assertNull( transport.recipient );
    assertNull( transport.msg );
    
    Message msg = constructAddResultMessage();
    assertNull( msg.getMessageId() );
    assertNull( msg.getInReplyTo() );
    msg.setInReplyTo( 1L );
    
    try
    {
      // this should trigger message is marked as a reply
      mmgr.transportCall( who, msg );
    }
    finally
    {
      assertEquals( 0, mmgr.size() );
      assertNull( mmgr.getMailbox( msg.getMessageId() ) );
    }
  }

View Full Code Here

   * @param type the type of the message.
   * @return a new message
   */
  public final Message _newMessage( Type type )
  {
    return new Message( type, _vf );
  }

View Full Code Here

0 1 2 3 4 5 6 7 8

TOP

Related Classes of org.apache.etch.bindings.java.msg.Message

org.apache.etch.bindings.java.support.RemoteBase

org.apache.etch.bindings.java.support.TestDefaultValueFactory

org.apache.etch.bindings.java.support.TestRemoteBase

org.apache.etch.bindings.java.support.TestStubBase

org.apache.etch.bindings.java.transport.DefaultDeliveryService

org.apache.etch.bindings.java.transport.filters.KeepAlive

org.apache.etch.bindings.java.transport.filters.PwAuth

org.apache.etch.bindings.java.transport.filters.TestKeepAlive

org.apache.etch.bindings.java.transport.filters.TestLogger

org.apache.etch.bindings.java.transport.filters.TestPwAuth

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.