You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2006/02/24 13:40:39 UTC
svn commit: r380653 -
/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/messaging/DeliveryChannelImpl.java
Author: gnodet
Date: Fri Feb 24 04:40:35 2006
New Revision: 380653
URL: http://svn.apache.org/viewcvs?rev=380653&view=rev
Log:
Add more infos to debug output
Modified:
incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/messaging/DeliveryChannelImpl.java
Modified: incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/messaging/DeliveryChannelImpl.java
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/messaging/DeliveryChannelImpl.java?rev=380653&r1=380652&r2=380653&view=diff
==============================================================================
--- incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/messaging/DeliveryChannelImpl.java (original)
+++ incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/messaging/DeliveryChannelImpl.java Fri Feb 24 04:40:35 2006
@@ -273,20 +273,34 @@
private void traceMessageExchange(String header, MessageExchange me) {
try {
+ int maxSize = 1500;
StringBuffer sb = new StringBuffer();
sb.append(header);
sb.append(": ");
sb.append("MessageExchange[\n");
sb.append(" id: ").append(me.getExchangeId()).append('\n');
sb.append(" status: ").append(me.getStatus()).append('\n');
+ sb.append(" role: ").append(me.getRole() == Role.CONSUMER ? "consumer" : "provider").append('\n');
+ if (me.getInterfaceName() != null) {
+ sb.append(" interface: ").append(me.getInterfaceName()).append('\n');
+ }
+ if (me.getService() != null) {
+ sb.append(" service: ").append(me.getService()).append('\n');
+ }
+ if (me.getEndpoint() != null) {
+ sb.append(" endpoint: ").append(me.getEndpoint().getEndpointName()).append('\n');
+ }
+ if (me.getOperation() != null) {
+ sb.append(" operation: ").append(me.getOperation()).append('\n');
+ }
if (me.getMessage("in") != null) {
sb.append(" in: ");
if (me.getMessage("in").getContent() != null) {
Node node = new SourceTransformer().toDOMNode(me.getMessage("in").getContent());
me.getMessage("in").setContent(new DOMSource(node));
String str = DOMUtil.asXML(node);
- if (str.length() > 150) {
- sb.append(str.substring(0, 150)).append("...");
+ if (str.length() > maxSize) {
+ sb.append(str.substring(0, maxSize)).append("...");
} else {
sb.append(str);
}
@@ -299,12 +313,31 @@
Node node = new SourceTransformer().toDOMNode(me.getMessage("out").getContent());
me.getMessage("out").setContent(new DOMSource(node));
String str = DOMUtil.asXML(node);
- if (str.length() > 150) {
- sb.append(str.substring(0, 150)).append("...");
+ if (str.length() > maxSize) {
+ sb.append(str.substring(0, maxSize)).append("...");
} else {
sb.append(str);
}
}
+ sb.append('\n');
+ }
+ if (me.getMessage("fault") != null) {
+ sb.append(" fault: ");
+ if (me.getMessage("fault").getContent() != null) {
+ Node node = new SourceTransformer().toDOMNode(me.getMessage("fault").getContent());
+ me.getMessage("fault").setContent(new DOMSource(node));
+ String str = DOMUtil.asXML(node);
+ if (str.length() > maxSize) {
+ sb.append(str.substring(0, maxSize)).append("...");
+ } else {
+ sb.append(str);
+ }
+ }
+ sb.append('\n');
+ }
+ if (me.getError() != null) {
+ sb.append(" error: ");
+ sb.append(me.getError().getMessage());
sb.append('\n');
}
sb.append("]");