[JBoss Messaging] - Re: message priority working jboss messaging 1.0.1???
by markusw
Ok, let me explain my setup in greater detail:
I have have a OnlineRequestSender sending with priority 9 and a BatchRequestSender sending with default priority (4). I add a timestamp to the message header for rtt measurement. I have a consumer with a controlled message consumption rate of 10 messages per second.
| OnlineRequestSender (5 msg/s)--->
| RequestQueue ----> Consumer (10 msg/s)
| BatchRequestSender --->
|
|
| Consumer -----> ResponseQueue ---> ResultReceiver
|
|
The OnlineRequestSender sends 5 msg/s thus leaving half of Consumer's capacity to Bulk jobs. The BulkRequestSender sends from time to time several messages (100-10000) in a row to the RequestQueue. The Consumer receives a message, processes it and puts a new message in the response queue (by copying the aforementioned timestamp). The ResultReciver can thus determine round-trip times for each message. The messages are simple TextMessages with text "O" for online and "B" for batch class.
I expected on the ResultReceiver side message ordering like "OBOBOBOB" if the queue is filled with many low-prioritized message.
This is what I see with the JBoss.mq stack. With the JBoss messaging stack I see a lot of B's with occasionally a few O's in a row i.e. BBBBBBBBBBBBBBBBBOOOBBBBBBBBBBBBBBBBBBBB .
So the rtt for prioritized requests is pretty bad.
It seems that the new stack puts the messages into DB, later loads some data in memory and THEN evaluates the message priority. I think the priority should be part of the SQL statement used for selecting messages to be delivered.
I can provide the test case if necessary.
View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=3981251#3981251
Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=3981251
19 years, 6 months
[Management, JMX/JBoss] - Re: Custom service seems to be ignoring <depends> tag
by toddjtidwell
Well, that was stupid. Hit submit instead of preview.
Here we go again:
I've written several custom services. However, I'd like them all to extend one base class, like so:
| public abstract class CustomService
| extends ServiceMBeanSupport
| {
| //... Some sort of shared functionality
| }
|
Then, I extend that for my actual service, like so:
| public interface MyServiceMBean
| extends ServiceMBean
| {
|
| }
|
| public class MyService
| extends CustomService
| {
|
| }
|
In my jboss-service.xml I have:
| <mbean code="test.MyService" name="test:service=MyService">
| <depends>test:service=ServiceIDependOn</depends>
| </mbean
|
Now, this all deploys incredibly well and functions if I deploy it while JBoss is running. However, if I restart JBoss, MyService does *not* wait for it's dependency to deploy. However, if I stop extending CustomService, this all works fine.
Any ideas?
View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=3981247#3981247
Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=3981247
19 years, 6 months