svn commit: r1036172 - in /synapse/trunk/java/modules/transports: core/nhttp/pom.xml optional/fix/src/main/java/org/apache/synapse/transport/fix/FIXSessionFactory.java

[hi...@apache.org]

Author: hiranya
Date: Wed Nov 17 19:24:44 2010
New Revision: 1036172

URL: http://svn.apache.org/viewvc?rev=1036172&view=rev
Log:
Exposing Quickfix/J MBeans through the FIX transport (SYNAPSE-708)

Modified:
    synapse/trunk/java/modules/transports/core/nhttp/pom.xml
    synapse/trunk/java/modules/transports/optional/fix/src/main/java/org/apache/synapse/transport/fix/FIXSessionFactory.java

Modified: synapse/trunk/java/modules/transports/core/nhttp/pom.xml
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/nhttp/pom.xml?rev=1036172&r1=1036171&r2=1036172&view=diff
==============================================================================
--- synapse/trunk/java/modules/transports/core/nhttp/pom.xml (original)
+++ synapse/trunk/java/modules/transports/core/nhttp/pom.xml Wed Nov 17 19:24:44 2010
@@ -150,7 +150,7 @@
     </dependencies>
 
     <properties>
-        <httpcore.nio.version>4.1-alpha1</httpcore.nio.version>
+        <httpcore.nio.version>4.1-beta3-SNAPSHOT</httpcore.nio.version>
     </properties>
 
 </project>

Modified: synapse/trunk/java/modules/transports/optional/fix/src/main/java/org/apache/synapse/transport/fix/FIXSessionFactory.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/optional/fix/src/main/java/org/apache/synapse/transport/fix/FIXSessionFactory.java?rev=1036172&r1=1036171&r2=1036172&view=diff
==============================================================================
--- synapse/trunk/java/modules/transports/optional/fix/src/main/java/org/apache/synapse/transport/fix/FIXSessionFactory.java (original)
+++ synapse/trunk/java/modules/transports/optional/fix/src/main/java/org/apache/synapse/transport/fix/FIXSessionFactory.java Wed Nov 17 19:24:44 2010
@@ -26,8 +26,10 @@ import org.apache.axis2.transport.base.B
 import org.apache.axis2.transport.base.threads.WorkerPool;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.quickfixj.jmx.JmxExporter;
 import quickfix.*;
 
+import javax.management.JMException;
 import java.io.IOException;
 import java.io.InputStream;
 import java.net.MalformedURLException;
@@ -128,6 +130,7 @@ public class FIXSessionFactory {
 
                 acceptorStore.put(service.getName(),acceptor);
                 acceptor.start();
+                initJMX(acceptor, service.getName());
                 return true;
             } catch (ConfigError e) {
                 String msg = "Error in the specified FIX configuration. Unable to initialize a " +
@@ -207,6 +210,7 @@ public class FIXSessionFactory {
             initiatorStore.put(fixEPR, initiator);
             applicationStore.put(fixEPR, messageHandler);
             initiator.start();
+            initJMX(initiator, service.getName());
 
             FIXIncomingMessageHandler fixMessageHandler = (FIXIncomingMessageHandler) messageHandler;
             log.info("Waiting for logon procedure to complete...");
@@ -251,6 +255,7 @@ public class FIXSessionFactory {
                     applicationStore.put(EPR, messageHandler);
                 }
                 initiator.start();
+                initJMX(initiator, service.getName());
                 return true;
 
             } catch (FieldConvertError e) {
@@ -494,6 +499,17 @@ public class FIXSessionFactory {
     public void setSenderThreadPool(WorkerPool senderThreadPool) {
         this.senderThreadPool = senderThreadPool;
     }
+
+    private void initJMX(Connector connector, String service) {
+        try {
+            JmxExporter jmxExporter = new JmxExporter();
+            jmxExporter.setRegistrationBehavior(JmxExporter.REGISTRATION_IGNORE_EXISTING);
+            jmxExporter.export(connector);
+        } catch (JMException e) {
+            log.error("Error while initializing JMX support for the FIX sessions in " +
+                    "service: " + service, e);
+        }
+    }
 }