[prev in list] [next in list] [prev in thread] [next in thread] 

List:       jibx-users
Subject:    [jibx-users] Across network unmarshalling.
From:       Ugo Enyioha <donniebr2k () yahoo ! com>
Date:       2005-06-17 14:44:58
Message-ID: 20050617144458.98720.qmail () web60521 ! mail ! yahoo ! com
[Download RAW message or body]

I'm having quite the problem here. It's a little
difficult for me to explain, my understanding tells me
it should work but I'll do my best to flesh it out
here.

The overall question is, what would be the best
approach to transport a single marshalled XML record
across network? I'm having issues unmarshalling it on
the other end.

Basically my approach was to perform the following
actions.

1. Create, marshall and queue XML records on server 1.
					asp.parseRecord();
					arxm.fillXMLRecord(par);
					arxm.writeXMLRecord(bos);      // bos is a
ByteArrayOutputStream
							aq.add(bos.toByteArray());     // aq is a
Concurrent Array Blocking Queue storing byte arrays
					
bos.reset();

1a. arxm.writeXMLRecord(bos) looks like this
public void writeXMLRecord(OutputStream out)	{
try {
// marshallingContext.setOutput(out, "UTF-8");	
marshallingContext.marshalDocument(rawCER, "UTF-8",
false, out);
} catch (JiBXException e) {
// TODO Auto-generated catch block
e.printStackTrace();
	}
}

2. Write marshalled XML records to socket on server 1

while(true)	{
							// get data from queue and write to socket	
cerRecordData = aq.remove();
						
dataAgentOutputStream.writeInt(cerRecordData.length);
							dataAgentOutputStream.write(cerRecordData);
}

} catch (IOException e) {
						System.out.println("Error: Client Agent was
unable to connect");
						System.err.println(e);
}

3. Read records from socket on server 2 and queue.
while(true)	{
	try {				rdCERRecord.length = 
dataAgentInputStream.readInt();	

// read the entire record off the network	
dataAgentInputStream.read(rdCERRecord.data,0,rdCERRecord.length);


acaq.add(rdCERRecord.data);     // acaq is a
concurrent queue.

} catch (IOException e) {			
System.out.println("Error: Unable to read data from
input stream");
					System.err.println(e);
					System.exit(-1);
}
}

3. Extract the record from the queue.
while(true)	{
anCERRecord.data = acaq.remove();
				
ByteArrayInputStream tempIs = new
ByteArrayInputStream(anCERRecord.data);
				
// unmarshall the common event record
this.cer = (CommonEventRecordType)
arum.readXMLRecord(tempIs);

3a. readXMLRecord(tempIs) looks like this
	public Object readXMLRecord(InputStream is)	{
try {
     obj = unmarshallingContext.unmarshalDocument(is,
"UTF-8");     // right here
} catch (JiBXException e) {
// TODO Auto-generated catch block
	e.printStackTrace();
}
		
System.out.println("Unmarshalled object: " +
obj.toString());
	return obj;
}

From my debugging it seems that my problem is at the
line above indicated (unmarshallDocument). Note that
because I am transporting the xml data across the
network as a byte array and JibX requires at least an
input stream I perform the appropirate converstion
using ByteArrayInputStream.

JiBX is spitting this out as its error message.
org.xmlpull.v1.XmlPullParserException: in epilog non
whitespace content is not allowed but got > (position:
END_TAG seen ...</commonEventRecordType>>... @18:108) 
at
org.xmlpull.mxp1.MXParser.parseEpilog(MXParser.java:1646)
at
org.xmlpull.mxp1.MXParser.nextImpl(MXParser.java:1416)
at
org.xmlpull.mxp1.MXParser.nextToken(MXParser.java:1144)
at
org.jibx.runtime.impl.UnmarshallingContext.advance(UnmarshallingContext.java:315)
at
org.jibx.runtime.impl.UnmarshallingContext.parsePastEndTag(UnmarshallingContext.java:806)
at
com.internet2.eddy.schema.cer.JiBX_bindingCommonEventRecordType_access.unmarshal()
at
org.jibx.runtime.impl.UnmarshallingContext.unmarshalElement(UnmarshallingContext.java:2515)
at
org.jibx.runtime.impl.UnmarshallingContext.unmarshalDocument(UnmarshallingContext.java:2675)
at
com.internet2.eddy.argus.speedtest.ArgusRecordXMLUnmarshaller.readXMLRecord(ArgusRecordXMLUnmarshal

So i think its unmarhshalling correctly but there's
some parsing error. One thing is each byte array
represents a complete marshalled record so my
rationale is that it should unmarshall correctly on
the other end. What could I be doing incorrectly?

I really appreciate assistance on this. Thanks.

--Ugo


		
____________________________________________________ 
Yahoo! Sports 
Rekindle the Rivalries. Sign up for Fantasy Football 
http://football.fantasysports.yahoo.com


-------------------------------------------------------
SF.Net email is sponsored by: Discover Easy Linux Migration Strategies
from IBM. Find simple to follow Roadmaps, straightforward articles,
informative Webcasts and more! Get everything you need to get up to
speed, fast. http://ads.osdn.com/?ad_id=7477&alloc_id=16492&op=click
_______________________________________________
jibx-users mailing list
jibx-users@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/jibx-users
[prev in list] [next in list] [prev in thread] [next in thread]