Package org.glassfish.jersey.media.sse

Examples of org.glassfish.jersey.media.sse.EventOutput

573
574
575
576
577
578
579
580
581
582
583
        }
    }

    protected Response actSse(final CommandInvoker invoker) {
        final boolean includeResourceLinks = includeResourceLinks();
        EventOutput eo = executeSseCommand(getSubject(), invoker.getCommand(), invoker.getParams(), new ResponseBodyBuilderImpl() {
            @Override
            protected ResponseBody success(ActionReport report) {
                invoker.setResult(report.getExtraProperties());
                SseResponseBody responseBody = new SseResponseBody();
                responseBody.addSuccess(invoker.getSuccessMessage());
View Full Code Here
604
605
606
607
608
609
610
611
612
613
614
    }

    protected Response createSse(final CreateCommandInvoker invoker) throws Exception {
        final String collectionUri = uriInfo.getAbsolutePathBuilder().build().toString();
        final boolean includeResourceLinks = includeResourceLinks();
        EventOutput eo = executeSseCommand(getSubject(), invoker.getCommand(), invoker.getParams(), new ResponseBodyBuilderImpl() {
            @Override
            protected ResponseBody success(ActionReport report) {
                invoker.setResult(report.getExtraProperties());
                SseResponseBody responseBody = new SseResponseBody();
                responseBody.addHeader("Location", collectionUri + "/id/" + invoker.getNewItemName())
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
        if (process != null) {
            if (testSource) {
                process.release();
            }
            final EventOutput eventOutput = new EventOutput();
            process.getBroadcaster().add(eventOutput);
            return eventOutput;
        } else {
            throw new NotFoundException();
        }
View Full Code Here
72
73
74
75
76
77
78
    }

    @DELETE
    public void close() throws IOException {
        eventOutput.close();
        eventOutput = new EventOutput();
    }
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
    @POST
    @Path("domains/{id}")
    @Produces(SseFeature.SERVER_SENT_EVENTS)
    public EventOutput startDomain(@PathParam("id") final String id) {
        final EventOutput seq = new EventOutput();

        new Thread() {
            public void run() {
                try {
                    seq.write(new OutboundEvent.Builder().name("domain-progress").data(String.class, "starting domain " + id + " ...").build());
                    Thread.sleep(200);
                    seq.write(new OutboundEvent.Builder().name("domain-progress").data(String.class, "50%").build());
                    Thread.sleep(200);
                    seq.write(new OutboundEvent.Builder().name("domain-progress").data(String.class, "60%").build());
                    Thread.sleep(200);
                    seq.write(new OutboundEvent.Builder().name("domain-progress").data(String.class, "70%").build());
                    Thread.sleep(200);
                    seq.write(new OutboundEvent.Builder().name("domain-progress").data(String.class, "99%").build());
                    Thread.sleep(200);
                    seq.write(new OutboundEvent.Builder().name("domain-progress").data(String.class, "done").build());
                    seq.close();

                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (IOException e) {
                    e.printStackTrace();
View Full Code Here
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
public class ExampleService {

  @GET
  @Produces( SseFeature.SERVER_SENT_EVENTS )
  public EventOutput getServerSentEvents() {
    final EventOutput eventOutput = new EventOutput();
    new Thread( new Runnable() {

      @Override
      public void run() {
        try {
          for( int i = 0; i < 10; i++ ) {
            Thread.sleep( 1000 );
            final OutboundEvent.Builder eventBuilder = new OutboundEvent.Builder();
            eventBuilder.name( "message-to-client" );
            eventBuilder.data( String.class, "Hello world " + i + "!" );
            final OutboundEvent event = eventBuilder.build();
            eventOutput.write( event );
          }
        } catch( IOException e ) {
          throw new RuntimeException( "Error when writing the event.", e );
        } catch( InterruptedException e ) {
          e.printStackTrace();
        } finally {
          try {
            eventOutput.close();
          } catch( IOException ioClose ) {
            throw new RuntimeException( "Error when closing the event output.", ioClose );
          }
        }
      }
View Full Code Here
145
146
147
148
149
150
151
152
153
154
155
    @GET
    @Path("events")
    @Produces(SseFeature.SERVER_SENT_EVENTS)
    public EventOutput itemEvents(
            @HeaderParam(SseFeature.LAST_EVENT_ID_HEADER) @DefaultValue("-1") int lastEventId) {
        final EventOutput eventOutput = new EventOutput();

        if (lastEventId >= 0) {
            LOGGER.info("Received last event id :" + lastEventId);

            // decide the reconnect handling strategy based on current reconnect delay value.
View Full Code Here
87
88
89
90
91
92
93
94
95
    @GET
    @Path("events")
    @Produces(SseFeature.SERVER_SENT_EVENTS)
    public EventOutput connect() {
        EventOutput output = new EventOutput();
        SimEngine.register(output);
        return output;
    }
View Full Code Here
72
73
74
75
76
77
78
    }

    @DELETE
    public void close() throws IOException {
        eventOutput.close();
        ServerSentEventsResource.setEventOutput(new EventOutput());
    }
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
    @POST
    @Path("domains/{id}")
    @Produces(SseFeature.SERVER_SENT_EVENTS)
    public EventOutput startDomain(@PathParam("id") final String id) {
        final EventOutput seq = new EventOutput();

        new Thread() {
            public void run() {
                try {
                    seq.write(new OutboundEvent.Builder().name("domain-progress").data(String.class, "starting domain " + id + " ...").build());
                    Thread.sleep(200);
                    seq.write(new OutboundEvent.Builder().name("domain-progress").data(String.class, "50%").build());
                    Thread.sleep(200);
                    seq.write(new OutboundEvent.Builder().name("domain-progress").data(String.class, "60%").build());
                    Thread.sleep(200);
                    seq.write(new OutboundEvent.Builder().name("domain-progress").data(String.class, "70%").build());
                    Thread.sleep(200);
                    seq.write(new OutboundEvent.Builder().name("domain-progress").data(String.class, "99%").build());
                    Thread.sleep(200);
                    seq.write(new OutboundEvent.Builder().name("domain-progress").data(String.class, "done").build());
                    seq.close();

                } catch (final InterruptedException | IOException e) {
                    e.printStackTrace();
                }
            }
View Full Code Here
TOP

Related Classes of org.glassfish.jersey.media.sse.EventOutput

  • com.eclipsesource.jaxrs.sse.example.ExampleService
  • org.glassfish.admin.rest.composite.CompositeResource
  • org.glassfish.admin.rest.resources.admin.CommandResource
  • org.glassfish.admin.rest.resources.TemplateExecCommand
  • org.glassfish.jersey.examples.aggregator.MessageStreamResource
  • org.glassfish.jersey.examples.flight.resources.FlightSimResource
  • org.glassfish.jersey.examples.sse.DomainResource
  • org.glassfish.jersey.examples.sse.ServerSentEventsResource
  • org.glassfish.jersey.examples.sseitemstore.ItemStoreResource
  • org.glassfish.jersey.osgi.test.basic.SseTest$SseResource
    • Copyright © 2018 www.massapicom. 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.