Before a CORBA client can send, publish, or receive messages, it must obtain a MessageService object reference. This code sample performs the setup required for a message service client application:
org.omg.CORBA.*;
import java.util.*;
import SessionManager.*;
import CtsComponents.*;
import java.lang.Object;
public class ReceiveTest
{
public static void main(String[] args)
{
new ReceiveTest().test(args);
}
public void test(String[] args)
{
Properties props = new Properties();
props.put("org.omg.CORBA.ORBClass",
"com.sybase.CORBA.ORB");
ORB orb = ORB.init((String[])null, props);
Manager manager =
ManagerHelper.narrow(orb.string_to_object(
"iiop://localhost:9000"));
Session session =
manager.createSession("jagadmin", "");
MessageService cms =
MessageServiceHelper.narrow(session1.create(
"CtsComponents/MessageService"));
MessageQueue mq =
cms.getMessageQueue("test", "",
REQUIRES_ACKNOWLEDGE.value);
...
| Copyright © 2005. Sybase Inc. All rights reserved. |
|
|
