62 |
|
objRef = ncRef.resolve(ncRef.to_name("iscream.Logger")); |
63 |
|
Logger logger = LoggerHelper.narrow(objRef); |
64 |
|
|
65 |
– |
objRef = ncRef.resolve(ncRef.to_name("iscream.FilterManager")); |
66 |
– |
FilterManager filterManager = FilterManagerHelper.narrow(objRef); |
67 |
– |
|
65 |
|
logger.write(toString, Logger.SYSINIT, "coming up"); |
66 |
|
|
67 |
|
|
73 |
|
|
74 |
|
// read some config here |
75 |
|
int port = 0; |
76 |
+ |
String parentFilterName = null; |
77 |
|
|
78 |
|
// did we? |
79 |
|
if (myConfig == null) { |
85 |
|
try { |
86 |
|
//QUERY HERE.... ??? |
87 |
|
port = new Integer(myConfig.getProperty("Filter.listenPort")).intValue(); |
88 |
+ |
parentFilterName = myConfig.getProperty("Filter.parentFilter"); |
89 |
|
} catch (org.omg.CORBA.MARSHAL e) { |
90 |
|
System.out.println("Caught org.omg.CORBA.MARSHAL, must be a null we got back"); |
91 |
|
//System.exit(1); |
99 |
|
// **** INITIAL FILTER MANAGER COMMUNICATIONS HERE |
100 |
|
|
101 |
|
// get a root (CHANGE to use FilterManager) |
102 |
< |
objRef = ncRef.resolve(ncRef.to_name("iscream.Filter.root1")); |
103 |
< |
Filter root = FilterHelper.narrow(objRef); |
105 |
< |
|
106 |
< |
// register ourselves |
107 |
< |
|
108 |
< |
// **** END COMMENT |
102 |
> |
objRef = ncRef.resolve(ncRef.to_name("iscream.Filter." + parentFilterName)); |
103 |
> |
Filter parentFilter = FilterHelper.narrow(objRef); |
104 |
|
|
105 |
|
// SETUP our Servant |
106 |
|
|
107 |
|
// create the FilterServant |
108 |
< |
FilterServant filterServant = new FilterServant(logger, root, ourName); |
109 |
< |
|
108 |
> |
FilterServant filterServant = new FilterServant(logger, parentFilter, ourName, new Integer(port).toString() , new Integer(port).toString()); |
109 |
> |
|
110 |
> |
// register ourselves |
111 |
> |
|
112 |
|
// and advertise it to the naming context |
113 |
|
objRef = poa.servant_to_reference(filterServant); |
114 |
|
ncRef.bind(ncRef.to_name("iscream.Filter."+ourName), objRef); |
115 |
+ |
|
116 |
+ |
// **** END COMMENT |
117 |
|
|
118 |
|
// END SETUP |
119 |
|
|
139 |
|
**************************************************************/ |
140 |
|
|
141 |
|
logger.write(toString, Logger.SYSINIT, "starting Filter UDP listener"); |
142 |
< |
UDPReader udpReader = new UDPReader(port, root, logger); |
142 |
> |
UDPReader udpReader = new UDPReader(port, parentFilter, logger); |
143 |
|
udpReader.start(); |
144 |
|
logger.write(toString, Logger.SYSINIT, "Filter UDP listener started"); |
145 |
|
|
146 |
|
// TEST |
147 |
< |
root.receiveXML("<?xml version=\"1.0\" encoding=\"ISO8859-1\"?><packet><test>This is just a debugging test, we ("+ourName+") are live on port: "+port+"</test></packet>"); |
147 |
> |
parentFilter.receiveXML("<?xml version=\"1.0\" encoding=\"ISO8859-1\"?><packet><test>This is just a debugging test, we ("+ourName+") are live on port: "+port+"</test></packet>"); |
148 |
|
|
149 |
|
// start the POA off |
150 |
|
poa.the_POAManager().activate(); |