[Design of Messaging on JBoss (Messaging/JBoss)] - management notifications for JBM2
by jmesnil
I'm adding notifications to JBM2 trunk.
Currently we have:
BINDING_ADDED / BINDING_REMOVED -> when queues (or diverts) are created/deleted
SECURITY_AUTHENTICATION_VIOLATION -> when user authentication fails
SECURITY_PERMISSION_VIOLATION -> when user has not the required permission
CONSUMER_CREATED / CONSUMER_CLOSED
for CONSUMER_CREATED / CONSUMER_CLOSED, I'm adding to the notifications the consumer count for the given queue. Using this in a filter, we can be notified when e.g. there is no consumer on the queue.
What is missing is notifications when producers are created/closed since the producer concept is on the client side and the sessions is handling the messages sent by the clients on the server side.
However it'd be interesting to be notified when someone starts/stops producing on an address
I'm planning to add a few more notifications:
PAGING_STARTED / PAGING_STOPPPED -> when paging is activated
NODE_ACTIVATED -> when a backup node is activated and becomes the live node.
After that, there are other notifications that I could add but they are lower priority:
1/ notifications for start/stop of some messaging component:
- ACCEPTOR_STARTED / ACCEPTOR_STOPPED
- BRIDGE_STARTED / BRIDGE_STOPPED
- BROADCAST_GROUP_STARTED / BROADCAST_GROUP_STOPPED
- CLUSTER_CONNECTION_STARTED / CLUSTER_CONNECTION_STOPPED
- DISCOVERY_GROUP_STARTED / DISCOVERY_GROUP_STOPPED
2/ I was also thinking to add notifications when messages are expired/moved to the dead letter address but I'm not sure these notifications should be enabled by default (they can potentially generate a lot of notifications):
EXPIRED_MESSAGE -> when a message is expired
MOVED_TO_DEAD_LETTER_ADDRESS -> when a message is moved to the DLA
Do you guys have other ideas of interesting notifications?
When I've finished with the core notifications, I'll add JMS notifications for resources created by the JMSServerManager:
QUEUE_CREATED / QUEUE_DESTROYED
TOPIC_CREATED / TOPIC_DESTROYED
CONNECTION_FACTORY_CREATED / CONNECTION_FACTORY_DESTROYED
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4220514#4220514
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4220514
17 years
[Design of Messaging on JBoss (Messaging/JBoss)] - NettyHTTPTest intermittently fails
by timfox
To get this to happen easily, just run the first two tests in a loop:
| public void testFail() throws Exception
| {
| tearDown();
|
| for (int k = 0; k < 10000; k++)
| {
| setUp();
| testSendAndReceiveAtSameTime();
| tearDown();
|
| setUp();
| testSendThenReceive();
| tearDown();
| }
| }
|
The assertion failure is:
| junit.framework.AssertionFailedError: expected:<999> but was:<1000>
| at junit.framework.Assert.fail(Assert.java:47)
| at junit.framework.Assert.failNotEquals(Assert.java:280)
| at junit.framework.Assert.assertEquals(Assert.java:64)
| at junit.framework.Assert.assertEquals(Assert.java:198)
| at junit.framework.Assert.assertEquals(Assert.java:204)
| at org.jboss.messaging.tests.integration.http.NettyHttpTest.testSendThenReceive(NettyHttpTest.java:155)
| at org.jboss.messaging.tests.integration.http.NettyHttpTest.testFail(NettyHttpTest.java:114)
| at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
| at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
| at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
| at java.lang.reflect.Method.invoke(Method.java:585)
| at junit.framework.TestCase.runTest(TestCase.java:164)
| at junit.framework.TestCase.runBare(TestCase.java:130)
| at junit.framework.TestResult$1.protect(TestResult.java:106)
| at junit.framework.TestResult.runProtected(TestResult.java:124)
| at junit.framework.TestResult.run(TestResult.java:109)
| at junit.framework.TestCase.run(TestCase.java:120)
| at org.eclipse.jdt.internal.junit.runner.junit3.JUnit3TestReference.run(JUnit3TestReference.java:130)
| at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
| at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:460)
| at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:673)
| at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:386)
| at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
|
|
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4220510#4220510
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4220510
17 years
[Design of Messaging on JBoss (Messaging/JBoss)] - NettyHTTPTest intermittently fails
by timfox
To get this to happen easily, just run the first two tests in a loop:
| public void testFail() throws Exception
| {
| tearDown();
|
| for (int k = 0; k < 10000; k++)
| {
| setUp();
| testSendAndReceiveAtSameTime();
| tearDown();
|
| setUp();
| testSendThenReceive();
| tearDown();
| }
| }
|
The assertion failure is:
| junit.framework.AssertionFailedError: expected:<999> but was:<1000>
| at junit.framework.Assert.fail(Assert.java:47)
| at junit.framework.Assert.failNotEquals(Assert.java:280)
| at junit.framework.Assert.assertEquals(Assert.java:64)
| at junit.framework.Assert.assertEquals(Assert.java:198)
| at junit.framework.Assert.assertEquals(Assert.java:204)
| at org.jboss.messaging.tests.integration.http.NettyHttpTest.testSendThenReceive(NettyHttpTest.java:155)
| at org.jboss.messaging.tests.integration.http.NettyHttpTest.testFail(NettyHttpTest.java:114)
| at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
| at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
| at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
| at java.lang.reflect.Method.invoke(Method.java:585)
| at junit.framework.TestCase.runTest(TestCase.java:164)
| at junit.framework.TestCase.runBare(TestCase.java:130)
| at junit.framework.TestResult$1.protect(TestResult.java:106)
| at junit.framework.TestResult.runProtected(TestResult.java:124)
| at junit.framework.TestResult.run(TestResult.java:109)
| at junit.framework.TestCase.run(TestCase.java:120)
| at org.eclipse.jdt.internal.junit.runner.junit3.JUnit3TestReference.run(JUnit3TestReference.java:130)
| at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
| at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:460)
| at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:673)
| at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:386)
| at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
|
|
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4220509#4220509
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4220509
17 years