0

シリアライズ不可能なオブジェクトをキャメルキャッシュに入れて取得したい。以下に示すように、キャッシュのルート構成で objectCache パラメータを true に設定しました。 

 from("cache://MyCache"
           + "?maxElementsInMemory=5" +
            "&memoryStoreEvictionPolicy=" +
            "MemoryStoreEvictionPolicy.FIFO" +
            "&overflowToDisk=false" +
            "&timeToLiveSeconds=300" +
            "&objectCache=true" +
            "&diskExpiryThreadIntervalSeconds=30").to("mock:endpoint");

以下のコードでキャッシュに挿入しても問題ありません。

from("direct:addToCache").process(new Processor() {
            @Override
            public void process(Exchange exchange) throws Exception {
                MyObject ad = (MyObject) exchange.getIn().getBody();
                String key= ad.getId();
                WebServiceResponse value= ad.getWebServiceResponse();
                exchange.getIn().setHeader(CacheConstants.CACHE_OPERATION, CacheConstants.CACHE_OPERATION_ADD);
                exchange.getIn().setHeader(CacheConstants.CACHE_KEY, key);
                exchange.getIn().setBody(value);
            }
        }).to("cache://MyCache");

しかし、スローされた例外に続いてキャッシュから要素を取得している間。

org.apache.camel.NoTypeConversionAvailableException: No type converter available to convert from type: com.aaa.model.WebServiceResponse to the required type: java.io.InputStream with value com.aaa.model.WebServiceResponse@5781f3d4
 at org.apache.camel.impl.converter.BaseTypeConverterRegistry.mandatoryConvertTo(BaseTypeConverterRegistry.java:185)
 at org.apache.camel.impl.converter.BaseTypeConverterRegistry.mandatoryConvertTo(BaseTypeConverterRegistry.java:156)
 at org.apache.camel.component.cache.CacheProducer.createElementFromBody(CacheProducer.java:132)
 at org.apache.camel.component.cache.CacheProducer.performCacheOperation(CacheProducer.java:82)
 at org.apache.camel.component.cache.CacheProducer.process(CacheProducer.java:71)
 at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)
 at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:141)
 at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
 at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:460)
 at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
 at org.apache.camel.processor.Pipeline.process(Pipeline.java:121)
 at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
 at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
 at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:62)
 at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
 at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:109)
 at org.apache.camel.processor.UnitOfWorkProducer.process(UnitOfWorkProducer.java:68)
 at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:412)
 at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:380)
 at org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:270)
 at org.apache.camel.impl.ProducerCache.sendExchange(ProducerCache.java:380)

CacheProducerClass.createElementFromBody メソッドのデバッグ中に、objectCache パラメーターが false に設定されていることに気付きました。他のすべてのパラメーターはデフォルト値として設定されます (maxElementsInMemory=1000 および memoryStoreEvictionPolicy = MemoryStoreEvictionPolicy.LFU)。

com.aaa.model.WebServiceResponse クラスはシリアライズ可能ではありません。

この問題について何か考えはありますか？キャッシュ パラメータがキャッシュ定義の値でオーバーライドされないのはなぜですか?

4

1 に答える 1

2

要素がキャッシュに追加されると、すべてのパラメーターがデフォルト値にリセットされます。理由はわかりません。

回避策として見つけた解決策は、要素を追加するときに、すべてのパラメーターとその値を再度指定することです。

たとえば、コードを次のように変更すると、動作するはずです。

from("direct:addToCache").process(new Processor() {
            @Override
            public void process(Exchange exchange) throws Exception {
                MyObject ad = (MyObject) exchange.getIn().getBody();
                String key= ad.getId();
                WebServiceResponse value= ad.getWebServiceResponse();
                exchange.getIn().setHeader(CacheConstants.CACHE_OPERATION, CacheConstants.CACHE_OPERATION_ADD);
                exchange.getIn().setHeader(CacheConstants.CACHE_KEY, key);
                exchange.getIn().setBody(value);
            }
        }).to("cache://MyCache"
           + "?maxElementsInMemory=5" +
            "&memoryStoreEvictionPolicy=" +
            "MemoryStoreEvictionPolicy.FIFO" +
            "&overflowToDisk=false" +
            "&timeToLiveSeconds=300" +
            "&objectCache=true" +
            "&diskExpiryThreadIntervalSeconds=30").to("mock:endpoint");
于 2016-08-02T19:06:47.373 に答える