User: schaefera
Date: 01/12/08 21:01:43
Modified: src/main/org/jboss/management/mejb
JMSClientNotificationListener.java
ListenerRegistration.java ManagementBean.java
PollingClientNotificationListener.java
RMIClientNotificationListener.java
RMINotificationListener.java
Log:
Added Notification Transport to JSR-77 which works similar to EJB-Connector
but with the tweak of JSR-77 interface.
Added the adjusted JDBC JSR-77 shadow objects.
Added JSR-77 to the Connector Factory enabling JSR-77 to start and stop
Datasources.
Added a testsuite for JSR-77 which tests the basic stuff inclusive the
notification delivery.
Revision Changes Path
1.2 +1 -1
jboss/src/main/org/jboss/management/mejb/JMSClientNotificationListener.java
Index: JMSClientNotificationListener.java
===================================================================
RCS file:
/cvsroot/jboss/jboss/src/main/org/jboss/management/mejb/JMSClientNotificationListener.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- JMSClientNotificationListener.java 2001/12/06 00:31:22 1.1
+++ JMSClientNotificationListener.java 2001/12/09 05:01:43 1.2
@@ -68,7 +68,7 @@
// Register the listener as MBean on the remote JMX server
createListener(
pConnector,
- "org.jboss.jmx.connector.notification.JMSNotificationListener",
+ "org.jboss.management.mejb.JMSNotificationListener",
new Object[] { pQueueJNDIName, lQueue },
new String[] { String.class.getName(), Queue.class.getName() }
);
1.2 +2 -4
jboss/src/main/org/jboss/management/mejb/ListenerRegistration.java
Index: ListenerRegistration.java
===================================================================
RCS file:
/cvsroot/jboss/jboss/src/main/org/jboss/management/mejb/ListenerRegistration.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- ListenerRegistration.java 2001/12/06 00:31:22 1.1
+++ ListenerRegistration.java 2001/12/09 05:01:43 1.2
@@ -26,7 +26,7 @@
* {@link javax.management.j2ee.ListenerRegistration ListenerRegistration}.
*
* @author <a href="mailto:[EMAIL PROTECTED]";>Andreas Schaefer</a>.
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*
* <p><b>Revisions:</b>
*
@@ -141,9 +141,7 @@
public void removeNotificationListener(
ObjectName pName,
- NotificationListener pListener,
- NotificationFilter pFilter,
- Object pHandback
+ NotificationListener pListener
)
throws
InstanceNotFoundException,
1.2 +13 -1 jboss/src/main/org/jboss/management/mejb/ManagementBean.java
Index: ManagementBean.java
===================================================================
RCS file:
/cvsroot/jboss/jboss/src/main/org/jboss/management/mejb/ManagementBean.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- ManagementBean.java 2001/12/06 00:31:22 1.1
+++ ManagementBean.java 2001/12/09 05:01:43 1.2
@@ -52,7 +52,7 @@
*
* @author <a href="mailto:[EMAIL PROTECTED]";>Marc Fleury</a>
* @author <a href="mailto:[EMAIL PROTECTED]";>Andreas Schaefer</a>
-* @version $Revision: 1.1 $
+* @version $Revision: 1.2 $
*
* @ejb:bean name="MEJB"
* display-name="JBoss Management EJB (MEJB)"
@@ -263,7 +263,19 @@
ReflectionException,
RemoteException
{
+ System.out.println(
+ "ManagementBean.createMBean(), class: " + pClass +
+ ", name: " + pName +
+ ", parameters: " + pParameters +
+ ", signature: " + pSignature
+ );
+ try {
return mConnector.createMBean( pClass, pName, pParameters, pSignature );
+ }
+ catch( ReflectionException e1 ) {
+ e1.printStackTrace();
+ throw e1;
+ }
}
/**
1.2 +1 -1
jboss/src/main/org/jboss/management/mejb/PollingClientNotificationListener.java
Index: PollingClientNotificationListener.java
===================================================================
RCS file:
/cvsroot/jboss/jboss/src/main/org/jboss/management/mejb/PollingClientNotificationListener.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- PollingClientNotificationListener.java 2001/12/06 00:31:22 1.1
+++ PollingClientNotificationListener.java 2001/12/09 05:01:43 1.2
@@ -50,7 +50,7 @@
// Register the listener as MBean on the remote JMX server
createListener(
pConnector,
- "org.jboss.jmx.connector.notification.PollingNotificationListener",
+ "org.jboss.management.mejb.PollingNotificationListener",
new Object[] { new Integer( pMaximumListSize ), new Integer(
pMaximumListSize ) },
new String[] { Integer.TYPE.getName(), Integer.TYPE.getName() }
);
1.2 +1 -1
jboss/src/main/org/jboss/management/mejb/RMIClientNotificationListener.java
Index: RMIClientNotificationListener.java
===================================================================
RCS file:
/cvsroot/jboss/jboss/src/main/org/jboss/management/mejb/RMIClientNotificationListener.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- RMIClientNotificationListener.java 2001/12/06 00:31:22 1.1
+++ RMIClientNotificationListener.java 2001/12/09 05:01:43 1.2
@@ -47,7 +47,7 @@
// Register the listener as MBean on the remote JMX server
createListener(
pConnector,
- "org.jboss.jmx.connector.notification.RMINotificationListener",
+ "org.jboss.management.mejb.RMINotificationListener",
new Object[] { this },
new String[] { RMIClientNotificationListenerInterface.class.getName() }
);
1.2 +9 -0
jboss/src/main/org/jboss/management/mejb/RMINotificationListener.java
Index: RMINotificationListener.java
===================================================================
RCS file:
/cvsroot/jboss/jboss/src/main/org/jboss/management/mejb/RMINotificationListener.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- RMINotificationListener.java 2001/12/06 00:31:22 1.1
+++ RMINotificationListener.java 2001/12/09 05:01:43 1.2
@@ -64,9 +64,18 @@
Object pHandback
) {
try {
+ System.out.println(
+ "RMINotificationListener.handleNotification() " +
+ ", notification: " + pNotification +
+ ", handback: " + pHandback +
+ ", client listener: " + mClientListener
+ );
mClientListener.handleNotification( pNotification, pHandback );
}
catch( RemoteException re ) {
+ re.printStackTrace();
+ Throwable lDetail = re.detail;
+ lDetail.printStackTrace();
throw new RuntimeException( re.getMessage() );
}
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
