incubator-cvs mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hamm...@apache.org
Subject cvs commit: incubator-altrmi/src/test/org/apache/altrmi/test/messenger SynchronousMessengerTestCase.java
Date Fri, 28 Mar 2003 07:44:20 GMT
hammant     2003/03/27 23:44:20

  Modified:    src/java/org/apache/altrmi/server/impl/messenger
                        SynchronousMessengerServer.java
               src/test/org/apache/altrmi/test/messenger
                        SynchronousMessengerTestCase.java
  Log:
  Use of CorrelationID on return of msg
  
  Revision  Changes    Path
  1.5       +3 -2      incubator-altrmi/src/java/org/apache/altrmi/server/impl/messenger/SynchronousMessengerServer.java
  
  Index: SynchronousMessengerServer.java
  ===================================================================
  RCS file: /home/cvs/incubator-altrmi/src/java/org/apache/altrmi/server/impl/messenger/SynchronousMessengerServer.java,v
  retrieving revision 1.4
  retrieving revision 1.5
  diff -u -r1.4 -r1.5
  --- SynchronousMessengerServer.java	26 Mar 2003 20:23:03 -0000	1.4
  +++ SynchronousMessengerServer.java	28 Mar 2003 07:44:20 -0000	1.5
  @@ -142,9 +142,10 @@
                                   Request req = (Request) SerializationHelper.getInstanceFromBytes(requestBytes);
                                   Reply reply = handleInvocation(req, "JMS:" + message.getJMSReplyTo().toString());
                                   Destination dest = message.getJMSReplyTo();
  +                                String correlationID = message.getJMSCorrelationID();
                                   byte[] replyBytes = SerializationHelper.getBytesFromInstance(reply);
                                   ObjectMessage om = m_messenger.createObjectMessage( replyBytes
);
  -                                //TODO-JAMES om.setJMSMessageID(??);
  +                                om.setJMSCorrelationID(correlationID);
                                   m_messenger.send(dest, om);
                               }
                           }
  
  
  
  1.2       +3 -3      incubator-altrmi/src/test/org/apache/altrmi/test/messenger/SynchronousMessengerTestCase.java
  
  Index: SynchronousMessengerTestCase.java
  ===================================================================
  RCS file: /home/cvs/incubator-altrmi/src/test/org/apache/altrmi/test/messenger/SynchronousMessengerTestCase.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -r1.1 -r1.2
  --- SynchronousMessengerTestCase.java	25 Mar 2003 08:07:30 -0000	1.1
  +++ SynchronousMessengerTestCase.java	28 Mar 2003 07:44:20 -0000	1.2
  @@ -93,7 +93,7 @@
           Thread.currentThread().setContextClassLoader(getClass().getClassLoader());
   
           serverMessenger = MessengerManager.get("cacheTopicConnection");
  -        server = new SynchronousMessengerServer(serverMessenger, "Server-Subject");
  +        server = new SynchronousMessengerServer(serverMessenger, "ASubject");
           testServer = new TestInterfaceImpl();
           PublicationDescription pd = new PublicationDescription(TestInterface.class,
                   new Class[]{TestInterface3.class, TestInterface2.class});
  @@ -104,7 +104,7 @@
           altrmiFactory = new ClientSideClassFactory();
           clientMessenger = MessengerManager.get("cacheTopicConnection");
           //TODO-JAMES - gets here
  -        altrmiFactory.setHostContext(new SynchronousMessengerHostContext(clientMessenger,
"Client-Subject"), false);
  +        altrmiFactory.setHostContext(new SynchronousMessengerHostContext(clientMessenger,
"ASubject"), false);
           //TODO-JAMES - but not here
           testClient = (TestInterface) altrmiFactory.lookup("Hello");
   
  
  
  

---------------------------------------------------------------------
To unsubscribe, e-mail: cvs-unsubscribe@incubator.apache.org
For additional commands, e-mail: cvs-help@incubator.apache.org


Mime
View raw message