Hi Arnaud,
Thanks for your email.
So it should be like this:
-----------
...
...
// schema hash
decoder.readBin128());
// get the decoded properties contents
int propCnt = decoder.readUint16();
int statCnt = decoder.readUint16();
int methodCnt = decoder.readUint16();
int eventCnt = decoder.readUint16();
//System.out.println("Property content: " + propCnt);
for( int i = 0; i < propCnt; i++ )
{ // decode the MAP
Map<String,Object> map = decoder.readMap();
}
for( int i = 0; i < statCnt; i++ )
{ // decode the MAP
Map<String,Object> map = decoder.readMap();
}
for( int i = 0; i < methodCnt; i++ )
{ // decode the MAP
Map<String,Object> map = decoder.readMap();
}
for( int i = 0; i < eventCnt; i++ )
{ // decode the MAP
Map<String,Object> map = decoder.readMap();
}
....
....
-------
However, I have not compiled it yet. Just wanted to know your view.
BR,
Rahul
On Jun 27 2008, Arnaud Simon wrote:
Hi,
> Rafael mentioned last night that AbastractDecoder does not know it so
> we added another method i.e. readBin128() in AbstractDecoder.java
> (under org.apache.qpidity.transport.codec) for decoding 16 bytes of
> opaque binary data. It produced some unknown characters (e.g. output:
> Schema hash is:
> �\�W�p�`؞??V�?) as schema hash
> is an md5 digest and md5 hashes are binary data so in this case I was
> converting to a string like this System.out.println("Schema hash is " +
> new String(decoder.readBin128()));
>
> So I converted this non printable characters to hex (with Rafael's
> advice just to get rid off these some unknown character) by using
> org.apache.qpidity.transport.util.Functions.str(decoder.readBin128())
> method. so the schema hash printed as (Schema is:
> "\x85\x5c\xea\x96W\xe3p\xcc`\xd8\x9e\x1a\x08V\xa4\x0e")...
>
> 1) I want to see the Schema hash in the correct way ? How would I
> print it?
I don't think you want to print the hash, you only need it for sending
further requests. So, the hash is only 16 bytes of opaque binary, that's
all.
> -----
>
> As i was ignoring what i was getting for "schema hash" field (hax
> value) and moving on to next field... i.e. propCnt (properties
> content), i am doing this
> int propCnt = decoder.readUint16();
> System.out.println("Property content: " + propCnt);
>
> for( int i = 0; i < propCnt; i++ )
> {
> Map<String,Object> map = decoder.readMap();
> printMap(map);
> }
> public void printMap(Map mapnew)
> {
> Set s=mapnew.entrySet();
> Iterator it=s.iterator();
> for (Iterator iterator = s.iterator(); iterator.hasNext();) {
> Object object = (Object) iterator.next();
> System.out.println(object.toString());
>
> }
>
> BUT, getting an exception here
> A
> M
> 1
> s
> 15
> Package Name: qpid
> Class Name: vhost
> Schema is: "\x85\x5c\xea\x96W\xe3p\xcc`\xd8\x9e\x1a\x08V\xa4\x0e"
> Property content: 2
> code is : 6
>
> Error reading messagejava.lang.IllegalArgumentException: unknown code: 6
> at
> org.apache.qpidity.transport.codec.AbstractDecoder.getType(AbstractDecoder.java:302)
> at
> org.apache.qpidity.transport.codec.AbstractDecoder.readMap(AbstractDecoder.java:253)
> at apache.qpid.client.ListenerReply.onMessage(ListenerReply.java:109)
> at
> org.apache.qpidity.nclient.util.MessagePartListenerAdapter.messageReceived(MessagePartListenerAdapter.java:56)
> at
> org.apache.qpidity.nclient.impl.ClientSessionDelegate.data(ClientSessionDelegate.java:41)
> at
> org.apache.qpidity.transport.SessionDelegate.data(SessionDelegate.java:1)
> at org.apache.qpidity.transport.Data.delegate(Data.java:78)
> at org.apache.qpidity.transport.Channel.data(Channel.java:114)
> at org.apache.qpidity.transport.Channel.data(Channel.java:1)
> at org.apache.qpidity.transport.Data.delegate(Data.java:78)
> at org.apache.qpidity.transport.Channel.received(Channel.java:75)
> at org.apache.qpidity.transport.Connection.received(Connection.java:84)
> at org.apache.qpidity.transport.Connection.received(Connection.java:1)
> at
> org.apache.qpidity.transport.network.Assembler.emit(Assembler.java:92)
> at
> org.apache.qpidity.transport.network.Assembler.emit(Assembler.java:97)
> at
> org.apache.qpidity.transport.network.Assembler.frame(Assembler.java:125)
> at org.apache.qpidity.transport.network.Frame.delegate(Frame.java:145)
> at
> org.apache.qpidity.transport.network.Assembler.received(Assembler.java:102)
> at
> org.apache.qpidity.transport.network.Assembler.received(Assembler.java:1)
> at
> org.apache.qpidity.transport.network.InputHandler.frame(InputHandler.java:103)
> at
> org.apache.qpidity.transport.network.InputHandler.next(InputHandler.java:204)
> at
> org.apache.qpidity.transport.network.InputHandler.received(InputHandler.java:116)
> at
> org.apache.qpidity.transport.network.InputHandler.received(InputHandler.java:1)
> at
> org.apache.qpidity.transport.network.mina.MinaHandler.messageReceived(MinaHandler.java:87)
> at
> org.apache.mina.common.support.AbstractIoFilterChain$TailFilter.messageReceived(AbstractIoFilterChain.java:703)
> at
> org.apache.mina.common.support.AbstractIoFilterChain.callNextMessageReceived(AbstractIoFilterChain.java:362)
> at
> org.apache.mina.common.support.AbstractIoFilterChain.access$1200(AbstractIoFilterChain.java:54)
> at
> org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.messageReceived(AbstractIoFilterChain.java:800)
> at
> org.apache.mina.common.support.AbstractIoFilterChain$HeadFilter.messageReceived(AbstractIoFilterChain.java:617)
> at
> org.apache.mina.common.support.AbstractIoFilterChain.callNextMessageReceived(AbstractIoFilterChain.java:362)
> at
> org.apache.mina.common.support.AbstractIoFilterChain.fireMessageReceived(AbstractIoFilterChain.java:353)
> at
> org.apache.mina.transport.socket.nio.SocketIoProcessor.read(SocketIoProcessor.java:281)
> at
> org.apache.mina.transport.socket.nio.SocketIoProcessor.process(SocketIoProcessor.java:241)
> at
> org.apache.mina.transport.socket.nio.SocketIoProcessor.access$500(SocketIoProcessor.java:44)
> at
> org.apache.mina.transport.socket.nio.SocketIoProcessor$Worker.run(SocketIoProcessor.java:559)
> at
> org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:43)
> at java.lang.Thread.run(Thread.java:619)
>
>
> I have just an idea why it is raising but how to mitigate it I dont
> know.
>
> 2) How to fix it? Can anyone help me?
Looking at http://cwiki.apache.org/qpid/management-design-notes.html,
the message format is as follows:
+-----+-----+-----+-----+-----------------------+
| 'A' | 'M' | '1' | 's' | seq |
+-----+-----+-----+-----+-----------------------+----------+
| packageName (short string) |
+----------------------------------------------------------+
| className (short string) |
+----------------------------------------------------------+
| schema-hash (bin128) |
+-----------+-----------+-----------+-----------+----------+
| propCnt | statCnt | methodCnt | eventCnt |
+-----------+-----------+-----------+-----------+----------------------------+
| propCnt property records |
+----------------------------------------------------------------------------+
| statCnt statistic records |
+----------------------------------------------------------------------------+
| methodCnt method records |
+----------------------------------------------------------------------------+
| eventCnt event records |
+----------------------------------------------------------------------------+
This means that you need to read propCnt, statCnt, methodCnt and then
eventCnt before you can read propCnt maps. statCnt maps, methodCnt maps
and then eventCnt maps. You are currently not reading statCnt, methodCnt
and eventCnt.
Arnaud
