litesoft
Diff Revisions
2
vs
24
for /trunk/Java/core/Server/src/org/litesoft/changemanagement/nonpublic/LowLevelChangeListenerManager.java
|
@@ -199,31 +199,37 @@ |
199 |
199 |
|
super( pListener ); |
200 |
200 |
|
} |
201 |
201 |
|
|
|
202 |
+ |
@Override |
202 |
203 |
|
public boolean isAll() |
203 |
204 |
|
{ |
204 |
205 |
|
return true; |
205 |
206 |
|
} |
206 |
207 |
|
|
|
208 |
+ |
@Override |
207 |
209 |
|
public boolean isAll( String pName ) |
208 |
210 |
|
{ |
209 |
211 |
|
return true; |
210 |
212 |
|
} |
211 |
213 |
|
|
|
214 |
+ |
@Override |
212 |
215 |
|
public boolean hasAll( String[] pNames ) |
213 |
216 |
|
{ |
214 |
217 |
|
return true; |
215 |
218 |
|
} |
216 |
219 |
|
|
|
220 |
+ |
@Override |
217 |
221 |
|
public boolean hasAll( String pName, Serializable[] pUniqueKeys ) |
218 |
222 |
|
{ |
219 |
223 |
|
return true; |
220 |
224 |
|
} |
221 |
225 |
|
|
|
226 |
+ |
@Override |
222 |
227 |
|
public ServerStateChangeSet createListFrom( ServerStateChangeSet pAllChanges_Immutable ) |
223 |
228 |
|
{ |
224 |
229 |
|
return pAllChanges_Immutable; |
225 |
230 |
|
} |
226 |
231 |
|
|
|
232 |
+ |
@Override |
227 |
233 |
|
public String toString() |
228 |
234 |
|
{ |
229 |
235 |
|
return "All POs"; |
|
@@ -286,6 +292,7 @@ |
286 |
292 |
|
private Map<String, KeyInterestHelper> mNamesToKeyInterestHelpers = |
287 |
293 |
|
new HashMap<String, KeyInterestHelper>(); |
288 |
294 |
|
|
|
295 |
+ |
@Override |
289 |
296 |
|
public String toString() |
290 |
297 |
|
{ |
291 |
298 |
|
StringBuilder sb = new StringBuilder( "Only: " ); |
|
@@ -312,12 +319,14 @@ |
312 |
319 |
|
return (helper != null) && helper.isInterestedIn( pUniqueKey ); |
313 |
320 |
|
} |
314 |
321 |
|
|
|
322 |
+ |
@Override |
315 |
323 |
|
public boolean isAll( String pName ) |
316 |
324 |
|
{ |
317 |
325 |
|
KeyInterestHelper helper = mNamesToKeyInterestHelpers.get( pName ); |
318 |
326 |
|
return (helper != null) && helper.isAll(); |
319 |
327 |
|
} |
320 |
328 |
|
|
|
329 |
+ |
@Override |
321 |
330 |
|
public boolean hasAll( String[] pNames ) |
322 |
331 |
|
{ |
323 |
332 |
|
for ( String zName : pNames ) |
|
@@ -330,12 +339,14 @@ |
330 |
339 |
|
return true; |
331 |
340 |
|
} |
332 |
341 |
|
|
|
342 |
+ |
@Override |
333 |
343 |
|
public boolean hasAll( String pName, Serializable[] pUniqueKeys ) |
334 |
344 |
|
{ |
335 |
345 |
|
KeyInterestHelper helper = mNamesToKeyInterestHelpers.get( pName ); |
336 |
346 |
|
return (helper != null) && helper.isInterestedInAll( pUniqueKeys ); |
337 |
347 |
|
} |
338 |
348 |
|
|
|
349 |
+ |
@Override |
339 |
350 |
|
public ServerStateChangeSet createListFrom( ServerStateChangeSet pAllChanges ) |
340 |
351 |
|
{ |
341 |
352 |
|
List<ServerStateChange> zAllChanges_Immutable = pAllChanges.getChanges(); |
|
@@ -426,21 +437,25 @@ |
426 |
437 |
|
super( pClassName ); |
427 |
438 |
|
} |
428 |
439 |
|
|
|
440 |
+ |
@Override |
429 |
441 |
|
public boolean isAll() |
430 |
442 |
|
{ |
431 |
443 |
|
return true; |
432 |
444 |
|
} |
433 |
445 |
|
|
|
446 |
+ |
@Override |
434 |
447 |
|
public boolean isInterestedIn( Serializable pUniqueKey ) |
435 |
448 |
|
{ |
436 |
449 |
|
return true; |
437 |
450 |
|
} |
438 |
451 |
|
|
|
452 |
+ |
@Override |
439 |
453 |
|
public boolean isInterestedInAll( Serializable[] pUniqueKeys ) |
440 |
454 |
|
{ |
441 |
455 |
|
return true; |
442 |
456 |
|
} |
443 |
457 |
|
|
|
458 |
+ |
@Override |
444 |
459 |
|
public String toString() |
445 |
460 |
|
{ |
446 |
461 |
|
return getClassName(); |
|
@@ -468,16 +483,19 @@ |
468 |
483 |
|
mUniqueKeys.addAll( pHelper.mUniqueKeys ); |
469 |
484 |
|
} |
470 |
485 |
|
|
|
486 |
+ |
@Override |
471 |
487 |
|
public boolean isAll() |
472 |
488 |
|
{ |
473 |
489 |
|
return false; |
474 |
490 |
|
} |
475 |
491 |
|
|
|
492 |
+ |
@Override |
476 |
493 |
|
public boolean isInterestedIn( Serializable pUniqueKey ) |
477 |
494 |
|
{ |
478 |
495 |
|
return mUniqueKeys.contains( pUniqueKey ); |
479 |
496 |
|
} |
480 |
497 |
|
|
|
498 |
+ |
@Override |
481 |
499 |
|
public boolean isInterestedInAll( Serializable[] pUniqueKeys ) |
482 |
500 |
|
{ |
483 |
501 |
|
for ( Serializable key : pUniqueKeys ) |
|
@@ -490,6 +508,7 @@ |
490 |
508 |
|
return true; |
491 |
509 |
|
} |
492 |
510 |
|
|
|
511 |
+ |
@Override |
493 |
512 |
|
public String toString() |
494 |
513 |
|
{ |
495 |
514 |
|
return getClassName() + mUniqueKeys; |
|
@@ -564,6 +583,7 @@ |
564 |
583 |
|
private Node mHead = null; |
565 |
584 |
|
private Node mTail = null; |
566 |
585 |
|
|
|
586 |
+ |
@Override |
567 |
587 |
|
public NodeQueue start() |
568 |
588 |
|
{ |
569 |
589 |
|
Thread zThread = new Thread( this ); |
|
@@ -573,6 +593,7 @@ |
573 |
593 |
|
} |
574 |
594 |
|
|
575 |
595 |
|
@SuppressWarnings({"InfiniteLoopStatement"}) |
|
596 |
+ |
@Override |
576 |
597 |
|
public void run() |
577 |
598 |
|
{ |
578 |
599 |
|
while ( true ) |
|
@@ -581,6 +602,7 @@ |
581 |
602 |
|
} |
582 |
603 |
|
} |
583 |
604 |
|
|
|
605 |
+ |
@Override |
584 |
606 |
|
public synchronized void waitTillEmpty() |
585 |
607 |
|
{ |
586 |
608 |
|
while ( mHead != null ) |
|
@@ -623,6 +645,7 @@ |
623 |
645 |
|
} |
624 |
646 |
|
} |
625 |
647 |
|
|
|
648 |
+ |
@Override |
626 |
649 |
|
public synchronized void put( ServerStateChangedListener pListener, ServerStateChangeSet pAllChanges ) |
627 |
650 |
|
{ |
628 |
651 |
|
Node zNode = new Node( pListener, pAllChanges ); |