Hi,
I am trying to integrate another part of our system that will publish
XML events to a camel route. I am having difficulty getting JAXB and my
camel route to work correctly and I've narrowed it down to the following
that shows my xpath expression I expect to match isn't.
At this point I'd appreciate any help on this - I *really* need to get
this finished, and I've spent days trying to resolve this.
Info:
1 - Route definition
2 - Log file
3 - XML
Thanks,
John
[1] Route:
DataFormat jaxb = new JaxbDataFormat("com.example.services.schemas.events");
Namespaces ns = new Namespaces("",
"http://www.example.com/services/resource/schemas/events";);
from("activemq:my.events")
.choice()
.when(ns.xpath("/event/context[type='inbound:file-receive']"))
.to("direct:inboundHandler")
.otherwise().log("Processing ${id} did not match namespace.");
from("direct:inboundHandler")
.unmarshal(jaxb)
.process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
System.out.println("trying to get the marshalled event");
Event evt = exchange.getIn().getBody(Event.class);
System.out.println("event.type = " + EventUtils.getType(evt));
}
});
[2] Log File:
00:29:05,656 | DEBUG | umer[my.events] |
EndpointMessageListener | 106 - org.apache.camel.camel-jms -
2.10.7 | Endpoint[activemq://my.events] consumer received JMS message:
ActiveMQTextMessage {commandId = 3, responseRequired = false, messageId
= ID:dubchak-mbp-53315-1395991558715-8:1:-1:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:dubchak-mbp-53315-1395991558715-8:1:-1:1, destination =
queue://my.events, transactionId = null, expiration = 0, timestamp =
1395991745644, arrival = 0, brokerInTime = 1395991745644, brokerOutTime
= 1395991745647, correlationId = null, replyTo = null, persistent =
false, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
null, marshalledProperties = null, dataStructure = null,
redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties =
true, readOnlyBody = true, droppable = false, text = <?xml version="1.0"
encoding="UTF-8" standalo.../tns:event>
}
*00:29:05,676 | DEBUG | umer[my.events] |
ChoiceProcessor | 100 - org.apache.camel.camel-core -
2.10.7 | #0 - XPath: /event/context[type='inbound:file-receive']
matches: false for: Exchange[JmsMessage[JmsMessageID:
ID:dubchak-mbp-53315-1395991558715-8:1:-1:1:1]]**
**00:29:05,676 | INFO | umer[my.events] |
route3 | 100 - org.apache.camel.camel-core -
2.10.7 | Processing ID:dubchak-mbp-53315-1395991558715-8:1:-1:1:1 did
not match namespace.**
**00:29:07,634 | DEBUG | .0.1:53353@61613 |
Transport | 63 -
org.apache.activemq.activemq-core - 5.7.0 | Transport Connection to:
tcp://127.0.0.1:53353 failed: java.io.EOFException**
**java.io.EOFException**
** at
java.io.DataInputStream.readByte(DataInputStream.java:267)[:1.7.0_45]**
** at
org.apache.activemq.transport.stomp.StompWireFormat.readHeaderLine(StompWireFormat.java:155)[63:org.apache.activemq.activemq-core:5.7.0]**
** at
org.apache.activemq.transport.stomp.StompWireFormat.readLine(StompWireFormat.java:148)[63:org.apache.activemq.activemq-core:5.7.0]**
** at
org.apache.activemq.transport.stomp.StompWireFormat.parseAction(StompWireFormat.java:170)[63:org.apache.activemq.activemq-core:5.7.0]**
** at
org.apache.activemq.transport.stomp.StompWireFormat.unmarshal(StompWireFormat.java:98)[63:org.apache.activemq.activemq-core:5.7.0]**
** at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:229)[63:org.apache.activemq.activemq-core:5.7.0]**
** at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:221)[63:org.apache.activemq.activemq-core:5.7.0]**
** at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:204)[63:org.apache.activemq.activemq-core:5.7.0]**
** at java.lang.Thread.run(Thread.java:744)[:1.7.0_45]*
00:29:07,636 | DEBUG | .0.1:53353@61613 |
ManagementContext | 63 -
org.apache.activemq.activemq-core - 5.7.0 | Unregistering MBean
org.apache.activemq:BrokerName=default,Type=Connection,ConnectorName=stomp,Connection=ID_dubchak-mbp-53315-1395991558715-8_1
0
[3] XML:
<?xml version="1.0" encoding="UTF-8"?>
<event xmlns="http://www.example.com/services/resource/schemas/events";
event-id="12345" timestamp="2014-03-27T12:50:10.993-07:00">
<context>
<type>inbound:file-receive</type>
<attributes>
<attribute>
<name>source</name>
<value>file:///integration/work/provider_directory/in/infile.tar.gz</value>
</attribute>
<attribute>
<name>target</name>
<value>file:///integration/work/provider_directory/ready/reformatted.tar.gz</value>
</attribute>
<attribute>
<name>datasource</name>
<value>foo</value>
</attribute>
</attributes>
</context>
<source>
<uri>
<host-name>localhost</host-name>
<host-id>localhost</host-id>
<domain>example.com</domain>
<fully-qualified>file:///integration/work/provider_directory/in/infile.tar.gz</fully-qualified>
</uri>
</source>
<target>
<uri>
<host-name>localhost</host-name>
<host-id>internal2.example.com</host-id>
<domain>example.com</domain>
<fully-qualified>file:///integration/work/provider_directory/ready/aetna_v4_05.zip</fully-qualified>
</uri>
</target>
<event-data>
<payload/>
</event-data>
</event>
