Задача
Складывать MTOM-оптимизированные SOAP-сообщения в JMS и читать их оттуда.
Решение
Во-первых, перед тем, как класть сообщение в JMS, включаем для него MTOM-оптимизацию (если она выключена глобально на сервере):
<property action="set" name="enableMTOM" scope="axis2"
type="STRING" value="true"/>
Далее указываем axis2 на необходимость положить сообщение как бинарное, а не текстовое:
<property action="set" name="JMS_MESSAGE_TYPE" scope="axis2"
type="STRING" value="JMS_BYTE_MESSAGE"/>
Указываем, что тип сообщения будет multipart/mixed:
<property action="set" name="messageType" scope="axis2"
type="STRING" value="multipart/mixed"/>
Говорим, что content-type нужно положить в JMS-свойство ContentType (сохранение content-type требуется, т.к. в случае с multipart он будет содержать разделитель частей, необходимый для корректного чтения этого multipart'а):
<property action="set" name="transport.jms.ContentTypeProperty" scope="axis2"
type="STRING" value="ContentType"/>
Далее, в принимающей проксе прописываем, что content-type сообщения нужно брать из JMS-свойства ContentType:
<parameter name="transport.jms.ContentType">
<rules xmlns="http://ws.apache.org/ns/synapse">
<jmsProperty>ContentType</jmsProperty>
</rules>
</parameter>
В сценарии JMS -> JMS, когда MTOM-оптимизированное сообщение извлекается из JMS, обрабатывается, и снова кладется в JMS (опять оптимизированным), нужно перед помещением сообщения в исходящую очередь чистить этот самый транспортный заголовок ContentType:
<property action="remove" name="ContentType" scope="transport"
type="STRING"/>
В противном случае WSO2 оставляет в исходящем сообщении тоже значение этого JMS-свойства, что и во входящем сообщении, при этом бинарное тело уже перекодировано с использованием другого MIME-разделителя, что приводит к ошибкам при последующем чтении MIME-а из JMS:
ERROR - JMSMessageReceiver Unknown error processing message
org.apache.axiom.om.OMException: Mime parts not found. Stream ended while searching for the boundary at org.apache.axiom.attachments.Attachments.<init>(Attachments.java:238)
at org.apache.axis2.builder.BuilderUtil.createAttachments(BuilderUtil.java:594)
at org.apache.axis2.builder.BuilderUtil.createAttachmentsMap(BuilderUtil.java:545)
...
Комментариев нет:
Отправить комментарий