wso2 msf4j: Как настроить свойства сервера

Question

В настоящее время я пытаюсь использовать MSF4J с StreamingOutput API. Однако вместо потоковой передачи файла я хочу передать последовательность нескончаемых коротких строк/текстов. Я хочу, чтобы строки были немедленно очищены от клиента. Однако клиент не получает его после флеша. Я считаю, что это связано с 8KB-буфером по умолчанию, потому что через несколько секунд мои строки размываются. Как переопределить этот буфер по умолчанию так же, как это делается в стеклянной платке? https://jersey.java.net/apidocs/2.22/jersey/org/glassfish/jersey/server/ServerProperties.html#OUTBOUND_CONTENT_LENGTH_BUFFER

Я хочу что-то вроде ...

Properties properties = new Properties() 
properties.set("jersey.config.server.contentLength.buffer", 0);** 

new MicroservicesRunner() 
    .setProperties(properties)** 
    .addInterceptor(new HTTPMonitoringInterceptor()) 
    .deploy(new MyService()) 
    .start(); 

Мой streamingout класс

new StreamingOutput(){  
    public void write(OutputStream os) throws IOException, WebApplicationException  { 
     while(true){ 
      os.write("some string".getBytes()); 
      os.flush(); 
     }  
     } 
} 

спасибо.

Answer 1

Это код целиком. Он работает, но я хочу, чтобы я мог переопределить свойства сервера.

например. properties.set ("jersey.config.server.contentLength.buffer", 0); спасибо.

упаковка ph.sample.api.ms;

импорт org.wso2.msf4j.MicroservicesRunner; import org.wso2.msf4j.analytics.httpmonitoring.HTTPMonitoringInterceptor;

общественного класса Application { государственной статической силы основных (String [] арг) {

new MicroservicesRunner(9000) 
      .addInterceptor(new HTTPMonitoringInterceptor()) 
      .deploy(new StreamService()) 
      .start(); 
} } 

пакет ph.sample.api.ms;

импорт javax.ws.rs.GET; import javax.ws.rs.Path; импорт javax.ws.rs.core.Response;

импорт org.wso2.carbon.metrics.core.annotation.Timed; import java.io.IOException; import java.io.OutputStream;

import javax.ws.rs.WebApplicationException; импорт javax.ws.rs.core.StreamingOutput;

@Path ("/ поток") общественного класса StreamService { @GET @Path ("/ подписка") @Timed общественный резонанс подписаться() {

return Response.ok(new StreamingOutput(){ 
     @Override   
     public void write(OutputStream os) throws IOException, WebApplicationException { 
     while(true){ 
      os.write("some string".getBytes()); 
      os.flush(); 
     }    
     } 
    }).build(); 
} 

}