Hello Ted,
Yes, this method works for the encoding of schema hash in the Schema
Request (AM1S).
Now I am able to fetch the Schema for the desired class. I have another
question in the format of this schema. You can see it at the end of this
email (output from the Management Client)
Also attached the output.text
with this email.
1. Is this format correct? Am I printing the Schema-hash (from the schema
request correctly)
For example, I am doubtful about access, index, type
I am getting their
corresponding numeric values here
And here is the code snippet for retrieving schema Response
Start of code snippet
-----------
case 's':
String packagename = decoder.readStr8();
System.out.println("Package Name: " + packagename);
String clasnam = decoder.readStr8();
System.out.println("Class Name: " + clasnam);
// decode the schema hash
decoder.readBin128();
// get the decoded properties contents
int propCnt = decoder.readUint16();
System.out.println("Property content: " + propCnt);
long statCnt = decoder.readUint16();
System.out.println("Statistic content: " + statCnt);
int methodCnt = decoder.readUint16();
System.out.println("Method content: " + methodCnt);
int eventCnt = decoder.readUint16();
System.out.println("Event content: " + eventCnt);
for( int i = 0; i < propCnt; i++ )
{ // decode the MAP
Map<String,Object> map = decoder.readMap();
printMap(map);
}
for( int i = 0; i < statCnt; i++ )
{ // decode the MAP
Map<String,Object> map = decoder.readMap();
printMap(map);
}
for( int i = 0; i < methodCnt; i++ )
{ // decode the MAP
Map<String,Object> map = decoder.readMap();
printMap(map);
}
for( int i = 0; i < eventCnt; i++ )
{ // decode the MAP
Map<String,Object> map = decoder.readMap();
printMap(map);
}
break;
}
}catch(Exception e)
{
System.out.print("Error reading message");
e.printStackTrace();
}
}
/*
* print the decoded map
* TODO: fix the warning and comment it when it works
*/
public void printMap(Map<String,Object> 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());
}
}
-------------
End of the code snippet
2. how can I invoke the method for a particular class (meaning method
request AM1M) ?
---------------------------------
-----------
Management Client Output (FOR QUESTION 1.)
-----------
******* MENU *************
#########################################################
1. Broker Query Request
2. Package Query Request
3. Class Query Request
4. Schema Query Request
5. Method Request
0. Exit
#########################################################
Please Enter your choice for REQUEST
4
*************************
1. agent
2. binding
3. bridge
4. broker
5. client
6. consumer
7. destination
8. exchange
9. link
10. producer
11. queue
12. session
13. system
14. vhost
*************************
Enter the class name (in small letters) for which you need SCHEMA
system
Query Schema Request Sent...
A
M
1
s
Sequence No: 444
Package Name: qpid
Class Name: system
Property content: 6
Statistic content: 0
Method content: 0
Event content: 0
access=1
index=1
name=sysId
type=14
access=3
desc=Operating System Name
index=0
name=osName
type=6
access=3
desc=Node Name
index=0
name=nodeName
type=6
access=3
index=0
name=release
type=6
access=3
index=0
name=version
type=6
access=3
index=0
name=machine
type=6
******* MENU *************
#########################################################
1. Broker Query Request
2. Package Query Request
3. Class Query Request
4. Schema Query Request
5. Method Request
0. Exit
#########################################################
Please Enter your choice for REQUEST
4
*************************
1. agent
2. binding
3. bridge
4. broker
5. client
6. consumer
7. destination
8. exchange
9. link
10. producer
11. queue
12. session
13. system
14. vhost
*************************
Enter the class name (in small letters) for which you need SCHEMA
queue
Query Schema Request Sent...
A
M
1
s
Sequence No: 444
Package Name: qpid
Class Name: queue
Property content: 7
Statistic content: 43
Method content: 1
Event content: 0
access=1
index=1
name=vhostRef
type=10
access=1
index=1
name=name
type=6
access=1
index=0
name=durable
type=11
access=1
index=0
name=autoDelete
type=11
access=1
index=0
name=exclusive
type=11
access=3
desc=Arguments supplied in queue.declare
index=0
name=arguments
type=15
access=3
desc=Reference to persistent queue (if durable)
index=0
name=storeRef
type=10
desc=Total messages enqueued
name=msgTotalEnqueues
type=4
unit=message
desc=Total messages dequeued
name=msgTotalDequeues
type=4
unit=message
desc=Transactional messages enqueued
name=msgTxnEnqueues
type=4
unit=message
desc=Transactional messages dequeued
name=msgTxnDequeues
type=4
unit=message
desc=Persistent messages enqueued
name=msgPersistEnqueues
type=4
unit=message
desc=Persistent messages dequeued
name=msgPersistDequeues
type=4
unit=message
desc=Current size of queue in messages
name=msgDepth
type=3
unit=message
desc=Current size of queue in messages (High)
name=msgDepthHigh
type=3
unit=message
desc=Current size of queue in messages (Low)
name=msgDepthLow
type=3
unit=message
desc=Total messages enqueued
name=byteTotalEnqueues
type=4
unit=octet
desc=Total messages dequeued
name=byteTotalDequeues
type=4
unit=octet
desc=Transactional messages enqueued
name=byteTxnEnqueues
type=4
unit=octet
desc=Transactional messages dequeued
name=byteTxnDequeues
type=4
unit=octet
desc=Persistent messages enqueued
name=bytePersistEnqueues
type=4
unit=octet
desc=Persistent messages dequeued
name=bytePersistDequeues
type=4
unit=octet
desc=Current size of queue in bytes
name=byteDepth
type=3
unit=octet
desc=Current size of queue in bytes (High)
name=byteDepthHigh
type=3
unit=octet
desc=Current size of queue in bytes (Low)
name=byteDepthLow
type=3
unit=octet
desc=Total enqueue transactions started
name=enqueueTxnStarts
type=4
unit=transaction
desc=Total enqueue transactions committed
name=enqueueTxnCommits
type=4
unit=transaction
desc=Total enqueue transactions rejected
name=enqueueTxnRejects
type=4
unit=transaction
desc=Current pending enqueue transactions
name=enqueueTxnCount
type=3
unit=transaction
desc=Current pending enqueue transactions (High)
name=enqueueTxnCountHigh
type=3
unit=transaction
desc=Current pending enqueue transactions (Low)
name=enqueueTxnCountLow
type=3
unit=transaction
desc=Total dequeue transactions started
name=dequeueTxnStarts
type=4
unit=transaction
desc=Total dequeue transactions committed
name=dequeueTxnCommits
type=4
unit=transaction
desc=Total dequeue transactions rejected
name=dequeueTxnRejects
type=4
unit=transaction
desc=Current pending dequeue transactions
name=dequeueTxnCount
type=3
unit=transaction
desc=Current pending dequeue transactions (High)
name=dequeueTxnCountHigh
type=3
unit=transaction
desc=Current pending dequeue transactions (Low)
name=dequeueTxnCountLow
type=3
unit=transaction
desc=Current consumers on queue
name=consumers
type=3
unit=consumer
desc=Current consumers on queue (High)
name=consumersHigh
type=3
unit=consumer
desc=Current consumers on queue (Low)
name=consumersLow
type=3
unit=consumer
desc=Current bindings
name=bindings
type=3
unit=binding
desc=Current bindings (High)
name=bindingsHigh
type=3
unit=binding
desc=Current bindings (Low)
name=bindingsLow
type=3
unit=binding
desc=Messages consumed but not yet acked
name=unackedMessages
type=3
unit=message
desc=Messages consumed but not yet acked (High)
name=unackedMessagesHigh
type=3
unit=message
desc=Messages consumed but not yet acked (Low)
name=unackedMessagesLow
type=3
unit=message
desc=Broker latency through this queue (Samples)
name=messageLatencySamples
type=9
unit=nanosecond
desc=Broker latency through this queue (Min)
name=messageLatencyMin
type=9
unit=nanosecond
desc=Broker latency through this queue (Max)
name=messageLatencyMax
type=9
unit=nanosecond
desc=Broker latency through this queue (Average)
name=messageLatencyAverage
type=9
unit=nanosecond
argCount=0
desc=Discard all messages on queue
name=purge
******* MENU *************
#########################################################
1. Broker Query Request
2. Package Query Request
3. Class Query Request
4. Schema Query Request
5. Method Request
0. Exit
#########################################################
Please Enter your choice for REQUEST
0
Management Client is stopping....
------------------
END OF THE OUTPUT
Best Regards,
Rahul
On Jul 9 2008, Ted Ross wrote:
[EMAIL PROTECTED] wrote:
> On Jul 8 2008, Ted Ross wrote:
>
>> [EMAIL PROTECTED] wrote:
>> > Hello Ted,
>> >
>> > encoder is an instance of AbstractEncoder class under >
>> org.apache.qpidity.transport.codec.Encoder. And thanks for pointing >
>> the duplication.
>> >
>> > Yes, you are correct i checked the spec. and it (bin128) is encoded
>> as > 16 octets. I added the following method for encoding the 128 bin
>> > schema hash with help of Rafael. so you mean this will not help to
>> > encode the schema... /* public void writeBin128(byte[] s) { if (s
>> == > null) { s = new byte[16]; } else if (s.length != 16) { throw new
>> > IllegalArgumentException("" + s); }
>> >
>> > put(s);
>> > }
>> > */
>> >
>> > could you please let me know which method can encode this schema or
>> is > there any method in AbstractEncoder which can do this OR How can
>> i > encode this.
>> >
>> > Thanks in advance.
>> >
>> > BR,
>> > Rahul
>> >
>> Rahul,
>>
>> I think your writeBin128 should work correctly. This encoding method
>> should be used to encode the schema hash in the schema request
>> message. Let me know how it works.
>>
>> -Ted
>>
>>
>
> Thank you Ted for your reply. I will let you know but one more
> question before this.
>
> can we send multiple request (AM1B, AM1P, AM1Q, AM1S etc...) to broker
> to fetch the management information on the SAME SESSION ?
Yes, you should be able to do everything on the same session.
>
> I am trying to request multiple request on the same session ang
> getting an exception "IllegalMonitorStateException" on
> session.endData(); statement in the following code snippet.
>
> When while loop goes first time then everything is okay. but for the
> second request when it reaches "session.endData();" then java throws
> this above mentioned exception.
I think the problem is your sequence of calls. The API expects the
following sequence per message:
session.messageTransfer
session.data
session.endData
In your code, the messageTransfer call is outside and before the loop.
This means that the second time you try to transmit, you are calling
session.data without having called session.messageTransfer first. The
session is in the incorrect state for a data call, thus the exception.
>
> Code Snippet
> -----
>
> class ...{
>
> ...
>
> public void main(String a[])..... {
> ....
> ....
>
> Connection con = Client.createConnection();
> ByteBuffer message= ByteBuffer.allocate(500);
> ManagementEncoder encoder=new ManagementEncoder(message);
>
> try
> { // connect to local host on default port 5672
> con.connect("localhost", 5672, "test", "guest", "guest");
> }
> catch(Exception e)
> {
> System.out.print("Error connecting to broker");
> e.printStackTrace();
> }
>
> // Create session
> Session session = con.createSession(0);
> .......
> ......
>
> // transfer message to "qpid.management" exchange
> session.messageTransfer("qpid.management",
> MessageAcceptMode.EXPLICIT,MessageAcquireMode.PRE_ACQUIRED);
> session.header(deliveryProps,messageProps);
> ......
> ......
> boolean flag=true;
>
> while(flag)
> {
>
> BufferedReader br = new BufferedReader(new
> InputStreamReader(System.in));
> int choice=0;
>
> choice = Integer.parseInt(br.readLine().trim());
>
> switch (choice)
> {
> // send broker request
> case 1:
> p.opcode="AM1B";
> message.clear();
> try {
> message.put(p.opcode.getBytes("UTF-8"));
> } catch (UnsupportedEncodingException e1) {
> e1.printStackTrace();
> }
> break;
>
>
> case 2:
>
> // send package request
> p.opcode="AM1P";
> message.clear();
> try {
> message.put(p.opcode.getBytes("UTF-8"));
> } catch (UnsupportedEncodingException e1) {
> e1.printStackTrace();
> }
> break;
>
> case 3:
> // send class request
> p.opcode="AM1Q";
> p.sequenceNo=600;
> p.packageName="qpid";
> message.clear();
> ...
> ...
> break;
>
> case 4:
> // send schema request
> p.opcode="AM1S";
> .....
> .... .
> break;
>
> // switch closed
> }
>
> message.flip();
> // send message
> session.data(message);
>
> // *********GETTING EXCEPTION HERE IllegalMonitorStateException*********
> session.endData();
> // confirm completion
> session.sync();
>
> // while closed
> }
>
> session.sessionDetach(session.getName());
> try
> { // close connection
> con.close();
> }
> catch(Exception e)
> {
> System.out.print("Error closing broker connection");
> e.printStackTrace();
> // main close }
> }
> // class closed
> }
> --------
> End of the code snippet
>
> can i use the same session for sending the multiple request?
>
>
> Thank you so much.
> BR,
> /rahul
>
Management Listener Started...
******* MENU *************
#########################################################
1. Broker Query Request
2. Package Query Request
3. Class Query Request
4. Schema Query Request
5. Method Request
0. Exit
#########################################################
Please Enter your choice for REQUEST
1
Query Broker Request Sent...
A
M
1
b
Sequence No: 3000
Broker Identifier: ce7c7829-9f5c-4859-acf6-2a762fc9a7a7
******* MENU *************
#########################################################
1. Broker Query Request
2. Package Query Request
3. Class Query Request
4. Schema Query Request
5. Method Request
0. Exit
#########################################################
Please Enter your choice for REQUEST
2
Query Package Request Sent...
A
M
1
p
Sequence No: 3000
Package Name: qpid
A
M
1
z
Sequence No: 3000
******* MENU *************
#########################################################
1. Broker Query Request
2. Package Query Request
3. Class Query Request
4. Schema Query Request
5. Method Request
0. Exit
#########################################################
Please Enter your choice for REQUEST
3
Query Class Request Sent...
A
M
1
q
Sequence No: 1000
Package Name: qpid
Class Name: agent
A
M
1
q
Sequence No: 1000
Package Name: qpid
Class Name: binding
A
M
1
q
Sequence No: 1000
Package Name: qpid
Class Name: bridge
A
M
1
q
Sequence No: 1000
Package Name: qpid
Class Name: broker
A
M
1
q
Sequence No: 1000
Package Name: qpid
Class Name: client
A
M
1
q
Sequence No: 1000
Package Name: qpid
Class Name: consumer
A
M
1
q
Sequence No: 1000
Package Name: qpid
Class Name: destination
A
M
1
q
Sequence No: 1000
Package Name: qpid
Class Name: exchange
A
M
1
q
Sequence No: 1000
Package Name: qpid
Class Name: link
A
M
1
q
Sequence No: 1000
Package Name: qpid
Class Name: producer
A
M
1
q
Sequence No: 1000
Package Name: qpid
Class Name: queue
A
M
1
q
Sequence No: 1000
Package Name: qpid
Class Name: session
A
M
1
q
Sequence No: 1000
Package Name: qpid
Class Name: system
A
M
1
q
Sequence No: 1000
Package Name: qpid
Class Name: vhost
A
M
1
z
Sequence No: 1000
******* MENU *************
#########################################################
1. Broker Query Request
2. Package Query Request
3. Class Query Request
4. Schema Query Request
5. Method Request
0. Exit
#########################################################
Please Enter your choice for REQUEST
4
*************************
1. agent
2. binding
3. bridge
4. broker
5. client
6. consumer
7. destination
8. exchange
9. link
10. producer
11. queue
12. session
13. system
14. vhost
*************************
Enter the class name (in small letters) for which you need SCHEMA
broker
Query Schema Request Sent...
A
M
1
s
Sequence No: 444
Package Name: qpid
Class Name: broker
Property content: 11
Statistic content: 0
Method content: 4
Event content: 0
access=1
desc=System ID
index=1
name=systemRef
type=10
access=1
desc=TCP Port for AMQP Service
index=1
name=port
type=2
access=3
desc=Thread pool size
index=0
name=workerThreads
type=2
access=3
desc=Maximum allowed connections
index=0
name=maxConns
type=2
access=3
desc=Connection backlog limit for listening socket
index=0
name=connBacklog
type=2
access=3
desc=Broker stages messages over this size to disk
index=0
name=stagingThreshold
type=3
access=2
desc=Interval for management broadcasts
index=0
min=1
name=mgmtPubInterval
type=2
unit=second
access=3
desc=Name of cluster this server is a member of
index=0
name=clusterName
type=6
access=3
desc=Running software version
index=0
name=version
type=6
access=3
desc=Persistent configuration storage enabled
index=0
name=dataDirEnabled
type=11
access=3
desc=Persistent configuration storage location
index=0
name=dataDir
type=6
argCount=1
name=joinCluster
dir=I
name=clusterName
type=6
argCount=0
name=leaveCluster
argCount=2
desc=Request a response to test the path to the management agent
name=echo
******* MENU *************
#########################################################
1. Broker Query Request
2. Package Query Request
3. Class Query Request
4. Schema Query Request
5. Method Request
0. Exit
#########################################################
Please Enter your choice for REQUEST
4
*************************
1. agent
2. binding
3. bridge
4. broker
5. client
6. consumer
7. destination
8. exchange
9. link
10. producer
11. queue
12. session
13. system
14. vhost
*************************
Enter the class name (in small letters) for which you need SCHEMA
exchange
Query Schema Request Sent...
A
M
1
s
Sequence No: 444
Package Name: qpid
Class Name: exchange
Property content: 4
Statistic content: 12
Method content: 0
Event content: 0
access=1
index=1
name=vhostRef
type=10
access=1
index=1
name=name
type=6
access=3
index=0
name=type
type=6
access=1
index=0
name=durable
type=11
desc=Current producers on exchange
name=producers
type=3
desc=Current producers on exchange (High)
name=producersHigh
type=3
desc=Current producers on exchange (Low)
name=producersLow
type=3
desc=Current bindings
name=bindings
type=3
desc=Current bindings (High)
name=bindingsHigh
type=3
desc=Current bindings (Low)
name=bindingsLow
type=3
desc=Total messages received
name=msgReceives
type=4
desc=Total messages dropped (no matching key)
name=msgDrops
type=4
desc=Total routed messages
name=msgRoutes
type=4
desc=Total bytes received
name=byteReceives
type=4
desc=Total bytes dropped (no matching key)
name=byteDrops
type=4
desc=Total routed bytes
name=byteRoutes
type=4
******* MENU *************
#########################################################
1. Broker Query Request
2. Package Query Request
3. Class Query Request
4. Schema Query Request
5. Method Request
0. Exit
#########################################################
Please Enter your choice for REQUEST
4
*************************
1. agent
2. binding
3. bridge
4. broker
5. client
6. consumer
7. destination
8. exchange
9. link
10. producer
11. queue
12. session
13. system
14. vhost
*************************
Enter the class name (in small letters) for which you need SCHEMA
system
Query Schema Request Sent...
A
M
1
s
Sequence No: 444
Package Name: qpid
Class Name: system
Property content: 6
Statistic content: 0
Method content: 0
Event content: 0
access=1
index=1
name=sysId
type=14
access=3
desc=Operating System Name
index=0
name=osName
type=6
access=3
desc=Node Name
index=0
name=nodeName
type=6
access=3
index=0
name=release
type=6
access=3
index=0
name=version
type=6
access=3
index=0
name=machine
type=6
******* MENU *************
#########################################################
1. Broker Query Request
2. Package Query Request
3. Class Query Request
4. Schema Query Request
5. Method Request
0. Exit
#########################################################
Please Enter your choice for REQUEST
4
*************************
1. agent
2. binding
3. bridge
4. broker
5. client
6. consumer
7. destination
8. exchange
9. link
10. producer
11. queue
12. session
13. system
14. vhost
*************************
Enter the class name (in small letters) for which you need SCHEMA
queue
Query Schema Request Sent...
A
M
1
s
Sequence No: 444
Package Name: qpid
Class Name: queue
Property content: 7
Statistic content: 43
Method content: 1
Event content: 0
access=1
index=1
name=vhostRef
type=10
access=1
index=1
name=name
type=6
access=1
index=0
name=durable
type=11
access=1
index=0
name=autoDelete
type=11
access=1
index=0
name=exclusive
type=11
access=3
desc=Arguments supplied in queue.declare
index=0
name=arguments
type=15
access=3
desc=Reference to persistent queue (if durable)
index=0
name=storeRef
type=10
desc=Total messages enqueued
name=msgTotalEnqueues
type=4
unit=message
desc=Total messages dequeued
name=msgTotalDequeues
type=4
unit=message
desc=Transactional messages enqueued
name=msgTxnEnqueues
type=4
unit=message
desc=Transactional messages dequeued
name=msgTxnDequeues
type=4
unit=message
desc=Persistent messages enqueued
name=msgPersistEnqueues
type=4
unit=message
desc=Persistent messages dequeued
name=msgPersistDequeues
type=4
unit=message
desc=Current size of queue in messages
name=msgDepth
type=3
unit=message
desc=Current size of queue in messages (High)
name=msgDepthHigh
type=3
unit=message
desc=Current size of queue in messages (Low)
name=msgDepthLow
type=3
unit=message
desc=Total messages enqueued
name=byteTotalEnqueues
type=4
unit=octet
desc=Total messages dequeued
name=byteTotalDequeues
type=4
unit=octet
desc=Transactional messages enqueued
name=byteTxnEnqueues
type=4
unit=octet
desc=Transactional messages dequeued
name=byteTxnDequeues
type=4
unit=octet
desc=Persistent messages enqueued
name=bytePersistEnqueues
type=4
unit=octet
desc=Persistent messages dequeued
name=bytePersistDequeues
type=4
unit=octet
desc=Current size of queue in bytes
name=byteDepth
type=3
unit=octet
desc=Current size of queue in bytes (High)
name=byteDepthHigh
type=3
unit=octet
desc=Current size of queue in bytes (Low)
name=byteDepthLow
type=3
unit=octet
desc=Total enqueue transactions started
name=enqueueTxnStarts
type=4
unit=transaction
desc=Total enqueue transactions committed
name=enqueueTxnCommits
type=4
unit=transaction
desc=Total enqueue transactions rejected
name=enqueueTxnRejects
type=4
unit=transaction
desc=Current pending enqueue transactions
name=enqueueTxnCount
type=3
unit=transaction
desc=Current pending enqueue transactions (High)
name=enqueueTxnCountHigh
type=3
unit=transaction
desc=Current pending enqueue transactions (Low)
name=enqueueTxnCountLow
type=3
unit=transaction
desc=Total dequeue transactions started
name=dequeueTxnStarts
type=4
unit=transaction
desc=Total dequeue transactions committed
name=dequeueTxnCommits
type=4
unit=transaction
desc=Total dequeue transactions rejected
name=dequeueTxnRejects
type=4
unit=transaction
desc=Current pending dequeue transactions
name=dequeueTxnCount
type=3
unit=transaction
desc=Current pending dequeue transactions (High)
name=dequeueTxnCountHigh
type=3
unit=transaction
desc=Current pending dequeue transactions (Low)
name=dequeueTxnCountLow
type=3
unit=transaction
desc=Current consumers on queue
name=consumers
type=3
unit=consumer
desc=Current consumers on queue (High)
name=consumersHigh
type=3
unit=consumer
desc=Current consumers on queue (Low)
name=consumersLow
type=3
unit=consumer
desc=Current bindings
name=bindings
type=3
unit=binding
desc=Current bindings (High)
name=bindingsHigh
type=3
unit=binding
desc=Current bindings (Low)
name=bindingsLow
type=3
unit=binding
desc=Messages consumed but not yet acked
name=unackedMessages
type=3
unit=message
desc=Messages consumed but not yet acked (High)
name=unackedMessagesHigh
type=3
unit=message
desc=Messages consumed but not yet acked (Low)
name=unackedMessagesLow
type=3
unit=message
desc=Broker latency through this queue (Samples)
name=messageLatencySamples
type=9
unit=nanosecond
desc=Broker latency through this queue (Min)
name=messageLatencyMin
type=9
unit=nanosecond
desc=Broker latency through this queue (Max)
name=messageLatencyMax
type=9
unit=nanosecond
desc=Broker latency through this queue (Average)
name=messageLatencyAverage
type=9
unit=nanosecond
argCount=0
desc=Discard all messages on queue
name=purge
******* MENU *************
#########################################################
1. Broker Query Request
2. Package Query Request
3. Class Query Request
4. Schema Query Request
5. Method Request
0. Exit
#########################################################
Please Enter your choice for REQUEST
0
Management Client is stopping....
