2011-12-27 2 views
15

Я использую среду jms/атмосфера для связи между двумя приложениями. Одним из применений является производителем сообщения для темы, отправляя пользовательские объекты следующего типа:Писатель тела сообщения для класса Java ... и MIME тип текста text/html не был найден

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

    /* some private properties */ 

    } 

С другой стороны, более чем один потребителем прослушиваемыхом по этой теме и сделать различные подписки в зависимости от идентификатора.

@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); 
    } 

} 

Что я замечаю, что сообщения правильно прибывающие на тему JMS, но я получаю следующее исключение:

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 

Я использую Netbeans 7.0.1 GlassFish 3.1.1, атмосфера 0.8.1, майка 1.11. Я искал в Интернете попытку любого возможного решения, но ничего не помогло.

ответ

0

Кажется, что вам необходимо реализовать требуемый MessageBodyWriter для классов, которые ваш транспорт через Джерси.

Вы можете прикрепить @Provider к классу А, и сделать его реализует MessageBodyWriter, такие как:

@Provider общественного класса А реализует MessageBodyWriter

Это заставит вас переопределить необходимые методы (WriteTo, GETSIZE , isWriteable), в то время как трикотаж транслирует объекты в ваших методах.

+0

Это не работает. Я реализую MessageBodyWriter непосредственно перед подпиской, и я переопределяю методы, но они никогда не вызываются. – mejas

+0

Вы зарегистрировали свой MessageBodyWriter в приложении (javax.ws.rs.core.Application)? В то время как трикотаж инициируется, метод Application.getClasses() возвращает набор классов, и в этом наборе должны быть возвращены поставщики (такие как MessageBodyWriters). – anilsinaci

8

У меня была одна и та же проблема, и мне не приходилось включать Json-модуль Джерси в мой класс. Вы можете просто исправить это, добавив следующую зависимость от maven

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

Я добавил зависимость jersey-json, но проблема все та же. – TOUDIdel

+1

Эти зависимости необходимы, когда вы хотите создать json, но OP хочет html – rds

+2

неработающую ссылку, исправить pleasE? –