未使用自定义可序列化处理 Sling 作业 属性

Sling job not being processed with custom serializable property

我创建了自定义可序列化 class,并将其添加到必要的 Sling Job 的负载中

public SomeClass extends Serializable {
    //Implementaton details
}

.......
//some service

Map<String, Object> payload = new HashMap<>();
payload.put("property1", someClassObject);

jobManager.createJob("some/job/topic").properties(payload).add();

由于成功创建并分配了结果作业,但未触发 JobConsumerprocess 方法。

我在 org.apache.sling.event.jobs 上启用了 TRACE 日志级别,日志显示相同的内容:作业已添加并分配,没有其他任何事情发生:

20.03.2019 11:15:00.263 DEBUG [sling-threadpool-15f9e0b4-a24d-4b0d-bf4a-433ec604e41d-(apache-sling-job-thread-pool)-27-<main queue>(com/some/Service)] org.apache.sling.event.jobs.audit ASSIGN OK bb92b672-1b0d-4fe8-bf5e-9194a934f249 : 2019/3/20/11/15/bb92b672-1b0d-4fe8-bf5e-9194a934f249_50
20.03.2019 11:15:00.263 DEBUG [sling-threadpool-15f9e0b4-a24d-4b0d-bf4a-433ec604e41d-(apache-sling-job-thread-pool)-27-<main queue>(com/some/Service)] org.apache.sling.event.jobs.audit ADD OK topic=some/job/topic, properties={spreadsheet=com.some.project.SomeClass@7acdf4a2} : 2019/3/20/11/15/bb92b672-1b0d-4fe8-bf5e-9194a934f249_50

如果我传递标准的可序列化对象,如字符串、整数等;作业已启动,我可以在日志中找到证据:

20.03.2019 11:15:00.012 DEBUG [sling-threadpool-15f9e0b4-a24d-4b0d-bf4a-433ec604e41d-(apache-sling-job-thread-pool)-27-<main queue>(com/some/Service)] org.apache.sling.event.jobs.audit START OK : 2019/3/20/11/15/bb92b672-1b0d-4fe8-bf5e-9194a934f249_49

如何解决 Sling Job 处理的问题?

已在 AEM 6.4.2 和 6.4.3 上测试

问题是您的自定义 class 被禁止反序列化。实际上,所有 classes 都被禁止按照 here 的描述进行反序列化。您应该将您希望反序列化的 classes 列入白名单。

特定的 RuntimeException 只有在 org.apache.sling.event.impl 而不是 [= 上创建调试记录器时才会出现26=] :

*DEBUG* [sling-default-137-Registered Service.4303] org.apache.sling.event.impl.jobs.queues.QueueJobCache Unable to read resource.
java.lang.UnsupportedOperationException: Deserialization not allowed for class TestEnum
    at org.kantega.notsoserial.DefaultNotSoSerial.preventDeserialization(DefaultNotSoSerial.java:256)
    at org.kantega.notsoserial.DefaultNotSoSerial.onBeforeResolveClass(DefaultNotSoSerial.java:248)
    at org.kantega.notsoserial.ObjectInputStreamClassVisitor.onBeforeResolveClass(ObjectInputStreamClassVisitor.java:48)
    at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1868)
    at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1751)
    at java.io.ObjectInputStream.readEnum(ObjectInputStream.java:1994)
    at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1570)
    at java.io.ObjectInputStream.readObject(ObjectInputStream.java:431)
    at org.apache.sling.jcr.resource.internal.helper.JcrPropertyMapCacheEntry.convertToType(JcrPropertyMapCacheEntry.java:330) [org.apache.sling.jcr.resource:3.0.8]
    at org.apache.sling.jcr.resource.internal.helper.JcrPropertyMapCacheEntry.convertToType(JcrPropertyMapCacheEntry.java:231) [org.apache.sling.jcr.resource:3.0.8]
    at org.apache.sling.jcr.resource.internal.JcrValueMap.get(JcrValueMap.java:105) [org.apache.sling.jcr.resource:3.0.8]
    at org.apache.sling.event.impl.support.ResourceHelper.cloneValueMap(ResourceHelper.java:203) [org.apache.sling.event:4.2.10]
  at org.apache.sling.event.impl.jobs.Utility.readJob(Utility.java:181) [org.apache.sling.event:4.2.10]


Here 是捕获此异常的代码行。