2011-12-27 17 views
15

Sto utilizzando la struttura jms/atmosfera per rendere la comunicazione tra due applicazioni. Una delle applicazioni è un produttore di messaggi per un argomento, l'invio di oggetti personalizzati del seguente tipo:Un writer del corpo del messaggio per la classe Java ... e il tipo di supporto MIME text/html non è stato trovato

@XmlRootElement 
    public class A implements Serializable{ 
    public A(){} 

    /* some private properties */ 

    } 

D'altra parte più di un consumatore sono in ascolto sul tema e fare abbonamenti diversi a seconda della id.

@GET 
    @Produces({MediaType.APPLICATION_JSON}) 
    public SuspendResponse<A> subscribe() { 
    return new SuspendResponse.SuspendResponseBuilder<A>() 
      .broadcaster(topic) 
      .outputComments(true) 
      .addListener(new EventsLogger()).build(); 
    } 
    @Override 
public void incomingBroadcast() { 
    try { 
     String id = getID(); 
     if (id.startsWith("/*")) { 
      id = "atmosphere"; 
     } 

     logger.info("Looking up Connection Factory {}", FACTORY_NAME); 
     Context ctx = new InitialContext(); 
     ConnectionFactory connectionFactory = (ConnectionFactory) ctx.lookup(FACTORY_NAME); 

     logger.info("Looking up topic: {}", TOPIC_NAME); 
     Topic topic = (Topic) ctx.lookup(TOPIC_NAME); 

     connection = connectionFactory.createConnection(); 
     session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 

     logger.info("Create consumer for : {}", id); 
     String selector = String.format("BroadcasterId = '%s'", id); 

     consumer = session.createConsumer(topic, selector); 
     consumer.setMessageListener(new MessageListener() { 

      @Override 
      public void onMessage(Message msg) { 
       try { 
        ObjectMessage om = (ObjectMessage) msg; 
        A a = (A) om.getObject(); 
        if (a!= null && bc != null) { 
         broadcastReceivedMessage(a); 
        } 
        logger.info("Broadcasted message: {} ", a); 
       } catch (JMSException ex) { 
        logger.warn("Failed to broadcast message", ex); 
       } 
      } 
     }); 
     publisher = session.createProducer(topic); 
     connection.start(); 
     logger.info("JMS created for topic {}, with filter {}", TOPIC_NAME, selector); 
    } catch (Throwable ex) { 
     throw new IllegalStateException("Unable to initialize MyBroadcaster", ex); 
    } 

} 

Quello che noto è che i messaggi sono in arrivo in modo corretto sul tema JMS, ma ricevo la seguente eccezione:

SEVERE: A message body writer for Java class A, and Java type class A, and MIME  
    media type text/html was not found 

    SEVERE: The registered message body writers compatible with the MIME media type are: 

    */* -> 
    com.sun.jersey.core.impl.provider.entity.FormProvider 
    com.sun.jersey.core.impl.provider.entity.MimeMultipartProvider 
    com.sun.jersey.core.impl.provider.entity.StringProvider 
    com.sun.jersey.core.impl.provider.entity.ByteArrayProvider 
    com.sun.jersey.core.impl.provider.entity.FileProvider 
    com.sun.jersey.core.impl.provider.entity.InputStreamProvider 
    com.sun.jersey.core.impl.provider.entity.DataSourceProvider 
    com.sun.jersey.core.impl.provider.entity.XMLJAXBElementProvider$General 
    com.sun.jersey.core.impl.provider.entity.ReaderProvider 
    com.sun.jersey.core.impl.provider.entity.DocumentProvider 
    com.sun.jersey.core.impl.provider.entity.StreamingOutputProvider 
    com.sun.jersey.core.impl.provider.entity.SourceProvider$SourceWriter 
    com.sun.jersey.json.impl.provider.entity.JSONJAXBElementProvider$General 
    com.sun.jersey.json.impl.provider.entity.JSONArrayProvider$General 
    com.sun.jersey.json.impl.provider.entity.JSONObjectProvider$General 
    com.sun.jersey.json.impl.provider.entity.JSONWithPaddingProvider 
    com.sun.jersey.server.impl.template.ViewableMessageBodyWriter 
    com.sun.jersey.core.impl.provider.entity.XMLRootElementProvider$General 
    com.sun.jersey.core.impl.provider.entity.XMLListElementProvider$General 
    com.sun.jersey.json.impl.provider.entity.JSONRootElementProvider$General 
    com.sun.jersey.json.impl.provider.entity.JSONListElementProvider$General 
    com.sun.jersey.json.impl.provider.entity.JacksonProviderProxy 
    com.sun.jersey.moxy.MoxyMessageBodyWorker 
    com.sun.jersey.moxy.MoxyListMessageBodyWorker 

Sto usando Netbeans 7.0.1, 3.1.1 GlassFish, l'atmosfera 0.8.1, maglia 1.11. Ho cercato sul web un tentativo di qualsiasi soluzione possibile ma nulla ha aiutato.

risposta

0

Sembra che sia necessario implementare MessageBodyWriter richiesto per le classi che vengono trasportate attraverso Jersey.

È possibile allegare @Provider alla classe A, e renderlo implementa MessageBodyWriter come ad esempio:

@Provider public class A implementa MessageBodyWriter

Questo vi costringerà a sostituire i metodi richiesti (WriteTo, getSize , è scrivibile) mentre la jersey trasporta gli oggetti nei tuoi metodi.

+0

Questo non funziona. Implemento MessageBodyWriter direttamente prima della sottoscrizione e sovrascrivo i metodi, ma non vengono mai richiamati. – mejas

+0

Avete registrato MessageBodyWriter in Application (javax.ws.rs.core.Application)? Mentre la jersey sta iniziando, il metodo Application.getClasses() restituisce un insieme di classi e i provider (come MessageBodyWriters) devono essere restituiti in questo set. – anilsinaci

8

Ho avuto lo stesso problema ed è stato impossibile non includere il modulo json di Jersey nel mio classpath. Si può semplicemente risolvere aggiungendo la seguente dipendenza su Maven

<dependency> 
    <groupId>com.sun.jersey</groupId> 
    <artifactId>jersey-json</artifactId> 
    <version>1.14</version> 
</dependency> 
+8

Ho aggiunto la dipendenza jersey-json ma il problema è sempre lo stesso. – TOUDIdel

+1

Queste dipendenze sono necessarie quando si vuole produrre json, ma l'OP vuole html – rds

+2

collegamento interrotto, correggere pleasE? –