blob: b6039ee72d9c0a32328505ed88da3ce981d8258c (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
|
// $Id$
//
// ============================================================================
//
// = FILENAME
// PushConsumerFactory.java
//
// = AUTHOR
// Michael Kircher (mk1@cs.wustl.edu)
//
// = DESCRIPTION
// This is the administor/factory for a PushConsumer.
//
// ============================================================================
public class PushConsumerFactory
{
private org.omg.CORBA.ORB orb_;
private org.omg.CORBA.Object naming_service_object_;
private DataHandler dataHandler_;
private Navigation navigation_;
private Weapons weapons_;
public PushConsumerFactory (DataHandler dataHandler,
String nameServiceIOR,
String[] args,
java.applet.Applet applet)
{
try {
dataHandler_ = dataHandler;
// if the DOVE Browser is running as an Applet
if (applet != null) {
orb_ = org.omg.CORBA.ORB.init (applet, null);
}
else { // not running as an Applet, but as an normal Application
orb_ = org.omg.CORBA.ORB.init (args, null);
}
// Get the Naming Service initial reference
// Name Service Lookup cannot be used when running as an Applet
if (nameServiceIOR == null && applet != null) {
System.out.println (" Name Service Lookup cannot be used when running as an Applet! Quit!");
System.exit (1);
}
if (nameServiceIOR == null) { // only used when running via "java" or "vbj"
System.out.println ("Using the lookup protocol!");
NS_Resolve ns_resolve = new NS_Resolve ();
naming_service_object_ = ns_resolve.resolve_name_service (orb_);
}
else {
System.out.println ("Using the following IOR: " + nameServiceIOR);
naming_service_object_ = orb_.string_to_object (nameServiceIOR);
}
}
catch(org.omg.CORBA.SystemException e) {
System.err.println ("PushConsumerFactory constructor: ORB and Name Service initialization");
System.err.println(e);
}
}
public class Object_is_null_exception extends Exception
{
Object_is_null_exception (String s)
{
super (s);
}
}
public void run ()
{
try
{
// Get the Naming Context to allow resolving the EventService and
// ScheduleService
CosNaming.NamingContext naming_context =
CosNaming.NamingContextHelper.narrow (naming_service_object_);
if (naming_context == null)
{
System.err.println ("The Naming Context is null");
System.exit (1);
}
System.out.println ("Reference to the Naming Service is ok.");
// Get a reference for the EventService
CosNaming.NameComponent[] ec_name_components = new CosNaming.NameComponent[1];
ec_name_components[0] = new CosNaming.NameComponent ("EventService","");
org.omg.CORBA.Object event_channel_object = naming_context.resolve (ec_name_components);
if (event_channel_object == null)
{
throw new Object_is_null_exception("EventService Object is null");
}
RtecEventChannelAdmin.EventChannel event_channel =
RtecEventChannelAdmin.EventChannelHelper.narrow (event_channel_object);
System.out.println ("Reference to the Event Service is ok.");
// Get a reference for the ScheduleService
CosNaming.NameComponent[] s_name_components = new CosNaming.NameComponent[1];
s_name_components[0] = new CosNaming.NameComponent ("ScheduleService","");
org.omg.CORBA.Object scheduler_object = naming_context.resolve (s_name_components);
if (scheduler_object == null)
{
throw new Object_is_null_exception("ScheduleService Object is null");
}
RtecScheduler.Scheduler scheduler =
RtecScheduler.SchedulerHelper.narrow (scheduler_object);
System.out.println ("Reference to the Naming Service is ok.");
// Start the consumer
System.out.println ("Instantiating the Push Consumer.");
PushConsumer pushConsumer = new PushConsumer (orb_, dataHandler_);
System.out.println ("Initializing the Push Consumer.");
pushConsumer.open_consumer (event_channel, scheduler, "demo_consumer");
// Tell the CORBA environment that we are ready
orb_.connect (pushConsumer);
System.out.println ("Going into the event dispatching loop.");
java.lang.Object sync = new java.lang.Object();
synchronized (sync) {
sync.wait();
}
}
catch (java.lang.InterruptedException e)
{
}
catch (CosNaming.NamingContextPackage.CannotProceed e)
{
System.err.println ("CosNaming.NamingContextPackage.CannotProceed");
System.err.println (e);
}
catch (CosNaming.NamingContextPackage.InvalidName e)
{
System.err.println ("CosNaming.NamingContextPackage.InvalidName");
System.err.println (e);
}
catch (CosNaming.NamingContextPackage.NotFound e)
{
System.err.println ("CosNaming.NamingContextPackage.NotFound");
System.err.println (e);
}
catch (Object_is_null_exception e)
{
System.err.println (e);
}
catch(org.omg.CORBA.SystemException e)
{
System.err.println ("PushConsumerFactory.run: Failure");
System.err.println(e);
}
}
} // public class PushConsumerFactory
|
