JAX-WS logger les flux volumineux

J'ai trouvé une solution, on peut rajouter un Handler à chaque web service:

Dans la classe WS:

Code:

1
2
3
4
@WebService()
@HandlerChain(file="/conf/handlerfile.xml")
public class WsBusiness
{....

Le fichier src/conf/handlerfile.xml

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
<?xml version="1.0" encoding="UTF-8"?>
<handler-chains xmlns="http://java.sun.com/xml/ns/javaee"
xmlns:cfg="http://cxf.apache.org/configuration/cfg"
xmlns:jaxb="http://java.sun.com/xml/ns/jaxb"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/javaee">
    <handler-chain>
	<handler>
		<handler-name>LoggingLargeMessageHandler</handler-name>
		<handler-class>com.test.ws.server.utils.TestSoapHandler</handler-class>
	</handler>
    </handler-chain>
</handler-chains>

Le handler:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
public class TestSoapHandler  implements SOAPHandler<SOAPMessageContext> {
 
    @Override
    public Set<QName> getHeaders() {
        return null;
    }
    @Override
    public boolean handleMessage(SOAPMessageContext smc) {
        logToSystemOut(smc);
        return true;
    }
    @Override
    public boolean handleFault(SOAPMessageContext smc) {
        logToSystemOut(smc);
        return true;
    }
 
    // nothing to clean up
    @Override
    public void close(MessageContext messageContext) {
    }
 
    /*
     * Check the MESSAGE_OUTBOUND_PROPERTY in the context
     * to see if this is an outgoing or incoming message.
     * Write a brief message to the print stream and
     * output the message. The writeTo() method can throw
     * SOAPException or IOException
     */
    private void logToSystemOut(SOAPMessageContext smc) {
        try {
            Boolean outboundProperty = (Boolean) smc.get (MessageContext.MESSAGE_OUTBOUND_PROPERTY);
            String sens = "";
            if (outboundProperty.booleanValue()) {
                sens ="sortante";
            } else {
                sens = "entrante";
            }
            SOAPMessage message = smc.getMessage();
 
            SAAJMessage saaj = new SAAJMessage(message);
            if(saaj!=null && saaj.getPayloadLocalPart()!=null){
 
                ByteArrayOutputStream baos = new ByteArrayOutputStream();
                message.writeTo(baos);
                if(baos.size()>1000000){
 
                    String msg = "Attention Taille importante pour la méthode "+sens+": " + saaj.getPayloadLocalPart() + "<br>taille du flux : " + baos.size() + "<br>Flux XML:" + baos.toString();
                    //envoyer par mail ou logger...
                }
            }
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }
}