43.3. 在逻辑处理程序中处理消息

普通消息处理由 handleMessage（） 方法处理。

handleMessage（） 方法收到 LogicalMessageContext 对象，提供对消息正文和消息上下文中存储的任何属性的访问。

handleMessage（） 方法根据消息处理方式返回 true 或 false。它还可能会引发异常。

传递给逻辑消息处理程序的 LogicalMessageContext 对象允许使用上下文 getMessage（） 方法访问消息正文。getMessage（） 方法（如 例 43.2 “在逻辑处理程序中获取消息 Payload 的方法” 所示）返回消息有效负载作为 LogicalMessage 对象。

具有 LogicalMessage 对象后，就可以使用它来操作消息正文。LogicalMessage 接口（在 例 43.3 “逻辑消息冻结器” 所示）具有 getter 和 setters，以用于实际消息正文。

逻辑消息的一对 getters 和 setters 将消息有效负载用作 javax.xml.transform.dom.DOMSource 对象。

没有参数的 getPayload（） 方法将消息有效负载返回为 DOMSource 对象。返回的对象是实际消息有效负载。对返回的对象进行的任何更改都会立即更改消息正文。

您可以使用使用单一 Source 对象的 setPayload（） 方法将消息的正文替换为 DOMSource 对象。

通过另一对 getter 和 setters，您可以将消息有效负载用作 JAXB 对象。它们使用 JAXBContext 对象，将消息有效负载转换为 JAXB 对象。

要使用您要执行以下操作的 JAXB 对象：

传递给逻辑处理程序的逻辑消息上下文是应用消息上下文的实例，可访问其中存储的所有属性。处理程序能够访问 APPLICATION 范围和 HANDLER 范围的属性。

与应用程序的消息上下文一样，逻辑消息上下文是 Java Map 的子类。要访问存储在上下文中的属性，请使用 get（） 方法以及从 Map 接口继承的 put（） 方法。

默认情况下，您在逻辑处理程序内部的消息上下文中设置的任何属性将被分配为 HANDLER 的范围。如果您希望应用程序代码能够访问您需要使用上下文的 setScope（） 方法的 属性，以显式将属性的范围设置为 APPLICATION。

有关在消息上下文中使用属性的更多信息，请参阅 第 42.1 节 “了解上下文”。

通常务必要知道消息通过处理程序链的方向。例如，您要从传入请求检索安全令牌，并将安全令牌附加到传出响应。

消息方向存储在消息上下文的出站消息属性中。您可以使用 MessageContext.MESSAGE_OUTBOUND_PROPERTY 键从消息上下文中检索出站消息属性，如 例 43.6 “从 SOAP 消息上下文获取消息方向” 所示。

Boolean outbound;
outbound = (Boolean)smc.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY);

属性存储为 布尔值 对象。您可以使用对象的 booleanValue（） 方法来确定属性值。如果该属性设为 true，则消息被出站。如果该属性设为 false，则消息被入站。

handleMessage（） 方法如何完成其消息处理会对消息处理处理方式有直接影响。此操作可以通过执行以下操作之一完成：

例 43.7 “逻辑消息处理程序消息处理” 显示服务消费者使用的逻辑消息处理程序的 handleMessage（） 消息的实施。它会在请求发送到服务供应商之前处理请求。

public class SmallNumberHandler implements LogicalHandler<LogicalMessageContext>
{
    public final boolean handleMessage(LogicalMessageContext messageContext)
    {
        try
        {
            boolean outbound = (Boolean)messageContext.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY);

            if (outbound)
            {
                LogicalMessage msg = messageContext.getMessage();

                JAXBContext jaxbContext = JAXBContext.newInstance(ObjectFactory.class);
                Object payload = msg.getPayload(jaxbContext);
                if (payload instanceof JAXBElement)
                {
                    payload = ((JAXBElement)payload).getValue();
                }

                if (payload instanceof AddNumbers)
                {
                    AddNumbers req = (AddNumbers)payload;

                    int a = req.getArg0();
                    int b = req.getArg1();
                    int answer = a + b;

                    if (answer < 20)
                    {
                      AddNumbersResponse resp = new AddNumbersResponse();
                      resp.setReturn(answer);
                      msg.setPayload(new ObjectFactory().createAddNumbersResponse(resp),
                                                      jaxbContext);

                      return false;
                    }
                }
                else
                {
                   throw new WebServiceException("Bad Request");
                }
            }
            return true;
        }
        catch (JAXBException ex)
        {
            throw new ProtocolException(ex);
        }
    }
...
}

例 43.7 “逻辑消息处理程序消息处理” 中的代码执行以下操作：

检查消息是否为出站请求。

如果消息是出站请求，处理程序会执行额外的消息处理。

从消息上下文获取消息有效负载的 LogicalMessage representation。

获取实际消息 payload 作为 JAXB 对象。

检查以确保请求是正确类型。

如果出现这种情况，处理程序将继续处理消息。

检查 sum 的值。

如果小于 20 的阈值，则它构建响应并将其返回到客户端。

构建响应。

返回 false 以停止消息处理并返回对客户端的响应。

如果消息不是正确的类型，则抛出运行时异常。

这个异常将返回到客户端。

如果消息是入站响应，则返回 true，或者 sum 不符合阈值。

消息处理正常继续。

如果遇到 JAXB marshalling 错误，则抛出 ProtocolException。

异常会在由当前处理程序和客户端之间处理程序的 handleFault（） 方法处理后传回客户端。