Nagrywarka treści wiadomości dla klasy Java ... i nie znaleziono nośnika typu MIME tekst/html

Question

Korzystam z frameworka jms/atmosfera do komunikacji między dwiema aplikacjami. Jednym z zastosowań jest producentem wiadomość o temacie, wysyłanie niestandardowych obiektów typu:

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

    /* some private properties */ 

    } 

po drugiej stronie więcej niż jeden konsumenci słuchania na ten temat i zrobić różne subskrypcje zależności od 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); 
    } 

} 

Co mi jest fakt, że wiadomości są prawidłowo przybyciu na temat JMS, ale pojawia się następujący wyjątek:

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 

używam Netbeans 7.0.1 GlassFish 3.1.1, atmosfera 0,8.1, koszulka 1,11. Szukałem w Internecie wypróbowanego rozwiązania, ale nic nie pomogło.

Answer 1

Wygląda na to, że musisz zaimplementować wymagany MessageBodyWriter dla klas, które transportujesz przez Jersey.

Możesz dołączyć @Provider do klasy A, i sprawiają, że realizuje MessageBodyWriter takich jak:

@Provider public class A implementuje MessageBodyWriter

To zmusi Cię zastąpić wymaganych metod (writeTo, getSize , isWriteable), podczas gdy koszulka przenosi obiekty w twoich metodach.

Answer 2

Miałem ten sam problem i było to spowodowane brakiem modułu json Jersey w mojej ścieżce klasowej. Możesz to naprawić, dodając następującą zależność od maven:

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