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); |
65 |
> |
objRef = ncRef.resolve(ncRef.to_name("iscream.FilterManager")); |
66 |
> |
FilterManager filterManager = FilterManagerHelper.narrow(objRef); |
67 |
|
|
68 |
|
logger.write(toString, Logger.SYSINIT, "coming up"); |
69 |
|
|
97 |
|
|
98 |
|
// **** END COMMENT |
99 |
|
|
100 |
+ |
// **** INITIAL FILTER MANAGER COMMUNICATIONS HERE |
101 |
+ |
|
102 |
+ |
// get a root (CHANGE to use FilterManager) |
103 |
+ |
objRef = ncRef.resolve(ncRef.to_name("iscream.Filter.root1")); |
104 |
+ |
Filter root = FilterHelper.narrow(objRef); |
105 |
+ |
|
106 |
+ |
// register ourselves |
107 |
+ |
|
108 |
+ |
// **** END COMMENT |
109 |
+ |
|
110 |
|
// SETUP our Servant |
111 |
|
|
112 |
|
// create the FilterServant |
113 |
< |
FilterServant filterServant = new FilterServant(logger, ourName); |
113 |
> |
FilterServant filterServant = new FilterServant(logger, root, ourName); |
114 |
|
|
115 |
|
// and advertise it to the naming context |
116 |
|
objRef = poa.servant_to_reference(filterServant); |
118 |
|
|
119 |
|
// END SETUP |
120 |
|
|
121 |
+ |
|
122 |
|
/************************************************************** |
123 |
|
Here would be an ideal place to start another thread to do |
124 |
|
the listening part of the Filter. Ideally it should just be |
138 |
|
- our "identifier" name |
139 |
|
|
140 |
|
**************************************************************/ |
141 |
< |
|
141 |
> |
|
142 |
|
logger.write(toString, Logger.SYSINIT, "starting Filter UDP listener"); |
143 |
< |
UDPReader udpReader = new UDPReader(port, logger); |
143 |
> |
UDPReader udpReader = new UDPReader(port, root, logger); |
144 |
|
udpReader.start(); |
145 |
|
logger.write(toString, Logger.SYSINIT, "Filter UDP listener started"); |
146 |
< |
|
136 |
< |
// **** INITIAL FILTER MANAGER COMMUNICATIONS HERE |
137 |
< |
|
138 |
< |
// get a root (CHANGE to use FilterManager) |
139 |
< |
objRef = ncRef.resolve(ncRef.to_name("iscream.Filter.root1")); |
140 |
< |
Filter root = FilterHelper.narrow(objRef); |
141 |
< |
|
142 |
< |
// register ourselves |
143 |
< |
|
144 |
< |
// **** END COMMENT |
145 |
< |
|
146 |
> |
|
147 |
|
// TEST |
148 |
< |
root.receiveXML("This is just a debugging test, we ("+ourName+") are live on port: "+port); |
148 |
> |
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>"); |
149 |
|
|
150 |
|
// start the POA off |
151 |
|
poa.the_POAManager().activate(); |