litesoft
Diff Revisions 969 vs 970 for /trunk/Java/GWT/OldClient/src/org/litesoft/GWT/eventbus/client/nonpublic/StatePeerSupportingEventBusRegular.java
| @@ -4,7 +4,6 @@ | |||
| 4 | 4 | import org.litesoft.GWT.eventbus.client.*; | |
| 5 | 5 | import org.litesoft.GWT.eventbus.client.rpc.*; | |
| 6 | 6 | import org.litesoft.commonfoundation.base.*; | |
| 7 | - | import org.litesoft.commonfoundation.issues.*; | |
| 8 | 7 | import org.litesoft.commonfoundation.typeutils.*; | |
| 9 | 8 | import org.litesoft.logger.*; | |
| 10 | 9 | ||
| @@ -55,11 +54,13 @@ | |||
| 55 | 54 | new SavedEventsExpectingResponseTracker( pLogger ) ); | |
| 56 | 55 | } | |
| 57 | 56 | ||
| 57 | + | @Override | |
| 58 | 58 | public void disposing() { | |
| 59 | 59 | mRemotePeerService.stopUnrequestedMessages(); | |
| 60 | 60 | mProcessingManager.waitTillNoOthers(); | |
| 61 | 61 | } | |
| 62 | 62 | ||
| 63 | + | @Override | |
| 63 | 64 | public synchronized void dispose() { | |
| 64 | 65 | mPeerInterestManager.clear(); | |
| 65 | 66 | mSubscriptionManager.clear(); | |
| @@ -67,11 +68,13 @@ | |||
| 67 | 68 | super.dispose(); | |
| 68 | 69 | } | |
| 69 | 70 | ||
| 71 | + | @Override | |
| 70 | 72 | public IStatePeerSupportingEventBus suspendedToRegular( EventConstrictor pEventConstrictor, | |
| 71 | 73 | EventBus pEventBus ) { | |
| 72 | 74 | throw new IllegalStateException( "Not Suspended" ); | |
| 73 | 75 | } | |
| 74 | 76 | ||
| 77 | + | @Override | |
| 75 | 78 | public void publishExpectingResponse( EventPackage pPackage ) { | |
| 76 | 79 | String sourceName = pPackage.getSourceName(); | |
| 77 | 80 | synchronized ( this ) { | |
| @@ -84,6 +87,7 @@ | |||
| 84 | 87 | releaseCollected(); | |
| 85 | 88 | } | |
| 86 | 89 | ||
| 90 | + | @Override | |
| 87 | 91 | public boolean releaseCollected() { | |
| 88 | 92 | boolean rv = true; | |
| 89 | 93 | if ( mProcessingManager.incThreadsAndIndicateIfWeAreFirst() ) { | |
| @@ -97,6 +101,7 @@ | |||
| 97 | 101 | return rv; | |
| 98 | 102 | } | |
| 99 | 103 | ||
| 104 | + | @Override | |
| 100 | 105 | protected synchronized EventBusMessageCollector getEventBusMessageCollector() { | |
| 101 | 106 | return mCollector; | |
| 102 | 107 | } | |
| @@ -148,11 +153,11 @@ | |||
| 148 | 153 | distributeToLocals( member ); | |
| 149 | 154 | } else { | |
| 150 | 155 | mEventBus.handleUnexpectedProblem( "EventConstrictor:" + error, | |
| 151 | - | new Problem( "DistributionNotAllowed", // | |
| 152 | - | error, // | |
| 153 | - | member.getSourceName(), // | |
| 154 | - | member.getTargetName(), // | |
| 155 | - | member.getType() ) ); | |
| 156 | + | null ); // new Problem( "DistributionNotAllowed", // TODO: XXX | |
| 157 | + | // error, // | |
| 158 | + | // member.getSourceName(), // | |
| 159 | + | // member.getTargetName(), // | |
| 160 | + | // member.getType() ) ); | |
| 156 | 161 | } | |
| 157 | 162 | } | |
| 158 | 163 | ||
| @@ -211,8 +216,7 @@ | |||
| 211 | 216 | mLogger.error.log( e, zListenerType, pPackage ); | |
| 212 | 217 | // Note: GWT does not provide stack traces in client mode | |
| 213 | 218 | mEventBus.handleUnexpectedProblem( ClassName.simple( zListener ), // | |
| 214 | - | new Problem( e, "UnableDistributeToLocals", | |
| 215 | - | pPackage.toString() ) ); | |
| 219 | + | null ); // new Problem( e, "UnableDistributeToLocals", pPackage.toString() ) ); // TODO: XXX | |
| 216 | 220 | } | |
| 217 | 221 | } | |
| 218 | 222 | } | |
View this file contents
View the full history
Commits for