litesoft
Diff Revisions 969 vs 970 for /trunk/Java/GWT/OldClient/src/org/litesoft/GWT/eventbus/client/rpc/ClientSideRemotePeerService.java
| @@ -3,7 +3,6 @@ | |||
| 3 | 3 | ||
| 4 | 4 | import org.litesoft.GWT.client.*; | |
| 5 | 5 | import org.litesoft.GWT.eventbus.client.nonpublic.*; | |
| 6 | - | import org.litesoft.commonfoundation.issues.*; | |
| 7 | 6 | import org.litesoft.core.simpletypes.temporal.*; | |
| 8 | 7 | import org.litesoft.logger.nonpublic.*; | |
| 9 | 8 | ||
| @@ -33,15 +32,18 @@ | |||
| 33 | 32 | return "ClientSideRemotePeerService"; | |
| 34 | 33 | } | |
| 35 | 34 | ||
| 35 | + | @Override | |
| 36 | 36 | public boolean forwardTo( ChannelServicePackage pFromPeer ) { | |
| 37 | 37 | return (pFromPeer == null) || pFromPeer.isEmpty() || // | |
| 38 | 38 | sendEm( ForwardToAsyncCallback.INSTANCE, pFromPeer ); | |
| 39 | 39 | } | |
| 40 | 40 | ||
| 41 | + | @Override | |
| 41 | 42 | public void stopUnrequestedMessages() { | |
| 42 | 43 | sPollTimer.cancel(); | |
| 43 | 44 | } | |
| 44 | 45 | ||
| 46 | + | @Override | |
| 45 | 47 | public RemotePeerService dispose() { | |
| 46 | 48 | return RemotePeerService.Null.INSTANCE; | |
| 47 | 49 | } | |
| @@ -62,7 +64,7 @@ | |||
| 62 | 64 | } | |
| 63 | 65 | catch ( RuntimeException e ) { | |
| 64 | 66 | sClientEventBus.handleUnexpectedProblem( COMMUNICATION_FAILURE, // | |
| 65 | - | new Problem( e, "SendingToServer" ) ); | |
| 67 | + | null ); // new Problem( e, "SendingToServer" ) ); // TODO: XXX | |
| 66 | 68 | } | |
| 67 | 69 | sPollTimer.schedule(); | |
| 68 | 70 | return sent; | |
| @@ -75,12 +77,14 @@ | |||
| 75 | 77 | } | |
| 76 | 78 | ||
| 77 | 79 | private static class RealPollTimer extends Timer implements PollTimer { | |
| 80 | + | @Override | |
| 78 | 81 | public void run() { | |
| 79 | 82 | if ( !AbstractClientMainAppEntryPoint.sWindowClosing ) { | |
| 80 | 83 | sendEm( PollAsyncCallback.INSTANCE, null ); | |
| 81 | 84 | } | |
| 82 | 85 | } | |
| 83 | 86 | ||
| 87 | + | @Override | |
| 84 | 88 | public void schedule() { | |
| 85 | 89 | schedule( sPollMillisecs ); | |
| 86 | 90 | } | |
| @@ -89,9 +93,11 @@ | |||
| 89 | 93 | private static class NoPollTimer implements PollTimer { | |
| 90 | 94 | public static final PollTimer INSTANCE = new NoPollTimer(); | |
| 91 | 95 | ||
| 96 | + | @Override | |
| 92 | 97 | public void cancel() { | |
| 93 | 98 | } | |
| 94 | 99 | ||
| 100 | + | @Override | |
| 95 | 101 | public void schedule() { | |
| 96 | 102 | } | |
| 97 | 103 | } | |
| @@ -103,6 +109,7 @@ | |||
| 103 | 109 | mTypeString = pTypeString; | |
| 104 | 110 | } | |
| 105 | 111 | ||
| 112 | + | @Override | |
| 106 | 113 | public void onSuccess( Object pObject ) { | |
| 107 | 114 | if ( !AbstractClientMainAppEntryPoint.sWindowClosing ) { | |
| 108 | 115 | ChannelServiceResult result = (ChannelServiceResult) pObject; | |
| @@ -131,6 +138,7 @@ | |||
| 131 | 138 | mResult = pResult; | |
| 132 | 139 | } | |
| 133 | 140 | ||
| 141 | + | @Override | |
| 134 | 142 | public void execute() { | |
| 135 | 143 | trace( "#", mAsyncCallback, mResult.getMessageSequenceNumber() ); | |
| 136 | 144 | ChannelServicePackage zPackage = mResult.getPackage(); | |
| @@ -141,11 +149,11 @@ | |||
| 141 | 149 | } | |
| 142 | 150 | } | |
| 143 | 151 | ||
| 152 | + | @Override | |
| 144 | 153 | public void onFailure( Throwable pThrowable ) { | |
| 145 | 154 | if ( !AbstractClientMainAppEntryPoint.sWindowClosing ) { | |
| 146 | - | sClientEventBus.handleUnexpectedProblem( COMMUNICATION_FAILURE, new Problem( pThrowable, | |
| 147 | - | "Failed to contact the server", | |
| 148 | - | toString() ) ); | |
| 155 | + | sClientEventBus.handleUnexpectedProblem( COMMUNICATION_FAILURE, | |
| 156 | + | null ); // new Problem( pThrowable, "Failed to contact the server", toString() ) ); // TODO: XXX | |
| 149 | 157 | } | |
| 150 | 158 | } | |
| 151 | 159 | ||
View this file contents
View the full history
Commits for