2011-12-27 42 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,3.1.1的GlassFish,氣氛0.8.1,運動衫1.11。我在網上搜索了任何可能的解決方案,但沒有任何幫助。

回答

0

看來您需要爲通過Jersey傳輸的類實現所需的MessageBodyWriter。

您可以將@Provider A類,並使其實現MessageBodyWriter如:

@Provider 公共類A實現MessageBodyWriter

這將迫使你重寫所需的方法(的writeTo,的getSize ,isWriteable),而運動衫正在運送方法中的物體。

+0

這並不奏效。我在訂閱之前直接實現了MessageBodyWriter,並且我重寫了這些方法,但是它們從不被調用。 – mejas 2011-12-27 15:44:15

+0

您是否已將MessageBodyWriter註冊到應用程序(javax.ws.rs.core.Application)?在啓動澤西時,Application.getClasses()方法返回一組類,並且提供者(例如MessageBodyWriters)應該返回到此集合中。 – anilsinaci 2011-12-27 16:07:09

8

我有同樣的問題,並沒有澤西的JSON模塊包含在我的類路徑。您可以簡單地通過在maven上添加以下依賴項來修復它:

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

我已經添加jersey-json依賴,但問題依然如此。 – TOUDIdel 2013-03-09 17:58:50

+1

當你想產生json時,這個依賴是必需的,但是OP需要html – rds 2013-05-02 20:45:38

+2

斷開的鏈接,修復pleasE? – 2013-06-30 21:44:56

相關問題