Author: hiranya
Date: Mon Nov 22 19:46:42 2010
New Revision: 1037856
URL: http://svn.apache.org/viewvc?rev=1037856&view=rev
Log:
Minor refactoring
Modified:
synapse/branches/2.0/modules/transports/optional/fix/src/main/java/org/apache/synapse/transport/fix/FIXSessionFactory.java
Modified:
synapse/branches/2.0/modules/transports/optional/fix/src/main/java/org/apache/synapse/transport/fix/FIXSessionFactory.java
URL:
http://svn.apache.org/viewvc/synapse/branches/2.0/modules/transports/optional/fix/src/main/java/org/apache/synapse/transport/fix/FIXSessionFactory.java?rev=1037856&r1=1037855&r2=1037856&view=diff
==============================================================================
---
synapse/branches/2.0/modules/transports/optional/fix/src/main/java/org/apache/synapse/transport/fix/FIXSessionFactory.java
(original)
+++
synapse/branches/2.0/modules/transports/optional/fix/src/main/java/org/apache/synapse/transport/fix/FIXSessionFactory.java
Mon Nov 22 19:46:42 2010
@@ -128,9 +128,9 @@ public class FIXSessionFactory {
logFactory,
messageFactory);
- acceptorStore.put(service.getName(),acceptor);
acceptor.start();
initJMX(acceptor, service.getName());
+ acceptorStore.put(service.getName(),acceptor);
return true;
} catch (ConfigError e) {
String msg = "Error in the specified FIX configuration. Unable
to initialize a " +
@@ -207,10 +207,10 @@ public class FIXSessionFactory {
logFactory,
messageFactory);
- initiatorStore.put(fixEPR, initiator);
- applicationStore.put(fixEPR, messageHandler);
initiator.start();
initJMX(initiator, service.getName());
+ initiatorStore.put(fixEPR, initiator);
+ applicationStore.put(fixEPR, messageHandler);
FIXIncomingMessageHandler fixMessageHandler =
(FIXIncomingMessageHandler) messageHandler;
log.info("Waiting for logon procedure to complete...");
@@ -249,13 +249,13 @@ public class FIXSessionFactory {
logFactory,
messageFactory);
+ initiator.start();
+ initJMX(initiator, service.getName());
String[] EPRs = FIXUtils.getEPRs(settings);
for (String EPR : EPRs) {
initiatorStore.put(EPR, initiator);
applicationStore.put(EPR, messageHandler);
}
- initiator.start();
- initJMX(initiator, service.getName());
return true;
} catch (FieldConvertError e) {
