cvs commit: incubator-geronimo/sandbox/messaging/src/test/org/apache/geronimo/messaging/remotenode/network NodeServerImplTest.java

[gdamour]

gdamour     2004/05/27 08:41:14

  Modified:    
sandbox/messaging/src/test/org/apache/geronimo/messaging/remotenode/network
                        NodeServerImplTest.java
  Log:
  Miss one commit related to the initial Msgs exchanged between two Nodes.
  
  Revision  Changes    Path
  1.2       +13 -2     
incubator-geronimo/sandbox/messaging/src/test/org/apache/geronimo/messaging/remotenode/network/NodeServerImplTest.java
  
  Index: NodeServerImplTest.java
  ===================================================================
  RCS file: 
/home/cvs/incubator-geronimo/sandbox/messaging/src/test/org/apache/geronimo/messaging/remotenode/network/NodeServerImplTest.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -r1.1 -r1.2
  --- NodeServerImplTest.java   11 May 2004 12:06:43 -0000      1.1
  +++ NodeServerImplTest.java   27 May 2004 15:41:14 -0000      1.2
  @@ -22,6 +22,9 @@
   import junit.framework.TestCase;
   
   import org.apache.geronimo.messaging.Msg;
  +import org.apache.geronimo.messaging.MsgBody;
  +import org.apache.geronimo.messaging.MsgHeader;
  +import org.apache.geronimo.messaging.MsgHeaderConstants;
   import org.apache.geronimo.messaging.NodeInfo;
   import org.apache.geronimo.messaging.interceptors.MsgOutInterceptor;
   import org.apache.geronimo.messaging.io.MockStreamManager;
  @@ -99,9 +102,17 @@
               new RemoteNodeJoiner(nodeInfo1, ioContext, factory);
           remoteNode.setMsgProducerOut(dispatcher);
           remoteNode.connect();
  -
  +        
           NodeInfo nodeInfo2 = new NodeInfo("Node2", address, 8082);
           Msg msg = new Msg();
  +        MsgHeader header = msg.getHeader();
  +        header.addHeader(MsgHeaderConstants.CORRELATION_ID, "");
  +        header.addHeader(MsgHeaderConstants.DEST_ENDPOINT, "");
  +        header.addHeader(MsgHeaderConstants.DEST_NODE, "");
  +        header.addHeader(MsgHeaderConstants.DEST_NODES, "");
  +        header.addHeader(MsgHeaderConstants.SRC_ENDPOINT, "");
  +        header.addHeader(MsgHeaderConstants.SRC_NODE, "");
  +        header.addHeader(MsgHeaderConstants.BODY_TYPE, 
MsgBody.Type.RESPONSE);
           msg.getBody().setContent(nodeInfo2);
           remoteNode.getMsgConsumerOut().push(msg);