Examples of resumeOnBroadcast()

Examples of org.atmosphere.annotation.Broadcast.resumeOnBroadcast()

188
189
190
191
192
193
194
195
196
197
198
           
            view = doBroadcast(entity, req, config, clusterBroadcastFilters,
                    broadcastAnnotation.delay(), 0,
                    broadcastAnnotation.filters(),
                    broadcastAnnotation.writeEntity(), null,
                    broadcastAnnotation.resumeOnBroadcast());
        }
       
        Asynchronous asyncAnnotation = ctx.getActionAnnotation(Asynchronous.class);
        if (asyncAnnotation != null) {
            doAsynchronous();
View Full Code Here

Examples of org.atmosphere.annotation.Schedule.resumeOnBroadcast()

248
249
250
251
252
253
254
255
256
257
258
        if (scheduleAnnotation != null) {
           
            doSchedule(scheduleAnnotation.period(),
                    scheduleAnnotation.waitFor(),
                    entity, marshalledEntity, resource, req, resp,
                    scheduleAnnotation.resumeOnBroadcast());
        }
       
        /*
         * TODO
         * in org.atmosphere.jersey.AtmosphereFilter there are often
View Full Code Here

Examples of org.atmosphere.annotation.Suspend.resumeOnBroadcast()

212
213
214
215
216
217
218
219
220
221
222
            boolean writeEntity = true;
            //TODO used eventually in executeSuspend()
            String contentType = suspendAnnotation.contentType();
           
            doSuspend(entity, req, resp, resource, config, topic, suspendTimeout, scope,
                    writeEntity, listeners, false, suspendAnnotation.resumeOnBroadcast(),
                    useResumeAnnotation);
        }
       
        Subscribe subscribeAnnotation = ctx.getActionAnnotation(Subscribe.class);
        if (subscribeAnnotation != null) {
View Full Code Here

Examples of org.atmosphere.cpr.AtmosphereResourceImpl.resumeOnBroadcast()

218
219
220
221
222
223
224
225
226
227
228
    public void onStateChange(AtmosphereResourceEvent event) throws IOException {

        // Original Value
        AtmosphereResourceImpl r = AtmosphereResourceImpl.class.cast(event.getResource());
        AtmosphereRequest request = r.getRequest(false);
        Boolean resumeOnBroadcast = r.resumeOnBroadcast();
        if (!resumeOnBroadcast) {
            // For legacy reason, check the attribute as well
            Object o = request.getAttribute(ApplicationConfig.RESUME_ON_BROADCAST);
            if (o != null && Boolean.class.isAssignableFrom(o.getClass())) {
                resumeOnBroadcast = Boolean.class.cast(o);
View Full Code Here

Examples of org.atmosphere.cpr.AtmosphereResourceImpl.resumeOnBroadcast()

229
230
231
232
233
234
235
236
237
238
239
            }
        }

        // Disable resume so cached message can be send in one chunk.
        if (resumeOnBroadcast) {
            r.resumeOnBroadcast(false);
            request.setAttribute(ApplicationConfig.RESUME_ON_BROADCAST, false);
        }

        RemoteEndpointImpl remoteEndpoint = (RemoteEndpointImpl) request.getAttribute(RemoteEndpointImpl.class.getName());
View Full Code Here

Examples of org.atmosphere.cpr.AtmosphereResourceImpl.resumeOnBroadcast()

171
172
173
174
175
176
177
178
179
180
181
        // Between event.isCancelled and resource, the connection has been remotly closed.
        if (r == null) {
            logger.trace("Event {} returned a null AtmosphereResource", event);
            return;
        }
        Boolean resumeOnBroadcast = r.resumeOnBroadcast();
        if (!resumeOnBroadcast) {
            // For legacy reason, check the attribute as well
            Object o = r.getRequest(false).getAttribute(ApplicationConfig.RESUME_ON_BROADCAST);
            if (o != null && Boolean.class.isAssignableFrom(o.getClass())) {
                resumeOnBroadcast = Boolean.class.cast(o);
View Full Code Here

Examples of org.atmosphere.cpr.AtmosphereResourceImpl.resumeOnBroadcast()

181
182
183
184
185
186
187
188
189
190
191
    public void onStateChange(AtmosphereResourceEvent event) throws IOException {
        Object msg = event.getMessage();

        // Original Value
        AtmosphereResourceImpl r = AtmosphereResourceImpl.class.cast(event.getResource());
        Boolean resumeOnBroadcast = r.resumeOnBroadcast();
        if (!resumeOnBroadcast) {
            // For legacy reason, check the attribute as well
            Object o = r.getRequest(false).getAttribute(ApplicationConfig.RESUME_ON_BROADCAST);
            if (o != null && Boolean.class.isAssignableFrom(o.getClass())) {
                resumeOnBroadcast = Boolean.class.cast(o);
View Full Code Here

Examples of org.atmosphere.cpr.AtmosphereResourceImpl.resumeOnBroadcast()

192
193
194
195
196
197
198
199
200
201
202
            }
        }

        // Disable resume so cached message can be send in one chunk.
        if (resumeOnBroadcast) {
            r.resumeOnBroadcast(false);
            r.getRequest(false).setAttribute(ApplicationConfig.RESUME_ON_BROADCAST, false);
        }

        if (event.isCancelled() || event.isClosedByClient()) {
            invoke(onDisconnectMethod, event);
View Full Code Here

Examples of org.atmosphere.cpr.AtmosphereResourceImpl.resumeOnBroadcast()

218
219
220
221
222
223
224
225
226
227
228
    public void onStateChange(AtmosphereResourceEvent event) throws IOException {

        // Original Value
        AtmosphereResourceImpl r = AtmosphereResourceImpl.class.cast(event.getResource());
        AtmosphereRequest request = r.getRequest(false);
        Boolean resumeOnBroadcast = r.resumeOnBroadcast();
        if (!resumeOnBroadcast) {
            // For legacy reason, check the attribute as well
            Object o = request.getAttribute(ApplicationConfig.RESUME_ON_BROADCAST);
            if (o != null && Boolean.class.isAssignableFrom(o.getClass())) {
                resumeOnBroadcast = Boolean.class.cast(o);
View Full Code Here

Examples of org.atmosphere.cpr.AtmosphereResourceImpl.resumeOnBroadcast()

229
230
231
232
233
234
235
236
237
238
239
            }
        }

        // Disable resume so cached message can be send in one chunk.
        if (resumeOnBroadcast) {
            r.resumeOnBroadcast(false);
            request.setAttribute(ApplicationConfig.RESUME_ON_BROADCAST, false);
        }

        RemoteEndpointImpl remoteEndpoint = (RemoteEndpointImpl) request.getAttribute(RemoteEndpointImpl.class.getName());
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.