You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by cm...@apache.org on 2013/01/28 00:09:51 UTC
svn commit: r1439204 - in /camel/trunk/components/camel-quickfix/src:
main/java/org/apache/camel/component/quickfixj/
test/java/org/apache/camel/component/quickfixj/examples/
Author: cmueller
Date: Sun Jan 27 23:09:50 2013
New Revision: 1439204
URL: http://svn.apache.org/viewvc?rev=1439204&view=rev
Log:
polished the camel quickfix component a bit
Modified:
camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjConfiguration.java
camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjConsumer.java
camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java
camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEngine.java
camel/trunk/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/AuthenticationExample.java
Modified: camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjConfiguration.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjConfiguration.java?rev=1439204&r1=1439203&r2=1439204&view=diff
==============================================================================
--- camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjConfiguration.java (original)
+++ camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjConfiguration.java Sun Jan 27 23:09:50 2013
@@ -24,9 +24,6 @@ import quickfix.Dictionary;
import quickfix.SessionID;
import quickfix.SessionSettings;
-/**
- *
- */
public class QuickfixjConfiguration {
private Map<Object, Object> defaultSettings;
Modified: camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjConsumer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjConsumer.java?rev=1439204&r1=1439203&r2=1439204&view=diff
==============================================================================
--- camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjConsumer.java (original)
+++ camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjConsumer.java Sun Jan 27 23:09:50 2013
@@ -49,9 +49,7 @@ public class QuickfixjConsumer extends D
Message camelMessage = exchange.getOut();
quickfix.Message quickfixjMessage = camelMessage.getBody(quickfix.Message.class);
- if (log.isDebugEnabled()) {
- log.debug("Sending FIX message reply: " + quickfixjMessage.toString());
- }
+ log.debug("Sending FIX message reply: {}", quickfixjMessage);
SessionID messageSessionID = MessageUtils.getReverseSessionID(exchange.getIn().getBody(quickfix.Message.class));
Modified: camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java?rev=1439204&r1=1439203&r2=1439204&view=diff
==============================================================================
--- camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java (original)
+++ camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java Sun Jan 27 23:09:50 2013
@@ -66,17 +66,14 @@ public class QuickfixjEndpoint extends D
}
public Consumer createConsumer(Processor processor) throws Exception {
- LOG.info("Creating QuickFIX/J consumer: "
- + (sessionID != null ? sessionID : "No Session")
- + ", ExchangePattern=" + getExchangePattern());
+ LOG.info("Creating QuickFIX/J consumer: {}, ExchangePattern={}", sessionID != null ? sessionID : "No Session", getExchangePattern());
QuickfixjConsumer consumer = new QuickfixjConsumer(this, processor);
consumers.add(consumer);
return consumer;
}
public Producer createProducer() throws Exception {
- LOG.info("Creating QuickFIX/J producer: "
- + (sessionID != null ? sessionID : "No Session"));
+ LOG.info("Creating QuickFIX/J producer: {}", sessionID != null ? sessionID : "No Session");
if (isWildcarded()) {
throw new ResolveEndpointFailedException("Cannot create consumer on wildcarded session identifier: " + sessionID);
}
Modified: camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEngine.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEngine.java?rev=1439204&r1=1439203&r2=1439204&view=diff
==============================================================================
--- camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEngine.java (original)
+++ camel/trunk/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEngine.java Sun Jan 27 23:09:50 2013
@@ -302,7 +302,7 @@ public class QuickfixjEngine extends Ser
} else {
messageStoreFactory = new MemoryStoreFactory();
}
- LOG.info("Inferring message store factory: " + messageStoreFactory.getClass().getName());
+ LOG.info("Inferring message store factory: {}", messageStoreFactory.getClass().getName());
return messageStoreFactory;
}
@@ -340,7 +340,7 @@ public class QuickfixjEngine extends Ser
// Default
sessionLogFactory = new ScreenLogFactory(settings);
}
- LOG.info("Inferring log factory: " + sessionLogFactory.getClass().getName());
+ LOG.info("Inferring log factory: {}", sessionLogFactory.getClass().getName());
return sessionLogFactory;
}
@@ -475,9 +475,7 @@ public class QuickfixjEngine extends Ser
}
private void dispatch(QuickfixjEventCategory quickfixjEventCategory, SessionID sessionID, Message message) throws Exception {
- if (LOG.isDebugEnabled()) {
- LOG.debug("FIX event dispatched: {} {}", quickfixjEventCategory, message != null ? message : "");
- }
+ LOG.debug("FIX event dispatched: {} {}", quickfixjEventCategory, message != null ? message : "");
for (QuickfixjEventListener listener : eventListeners) {
// Exceptions propagate back to the FIX engine so sequence numbers can be adjusted
listener.onEvent(quickfixjEventCategory, sessionID, message);
Modified: camel/trunk/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/AuthenticationExample.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/AuthenticationExample.java?rev=1439204&r1=1439203&r2=1439204&view=diff
==============================================================================
--- camel/trunk/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/AuthenticationExample.java (original)
+++ camel/trunk/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/AuthenticationExample.java Sun Jan 27 23:09:50 2013
@@ -19,8 +19,8 @@ package org.apache.camel.component.quick
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
+import org.apache.camel.CamelExchangeException;
import org.apache.camel.Exchange;
-import org.apache.camel.InvalidPayloadException;
import org.apache.camel.builder.PredicateBuilder;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.quickfixj.QuickfixjEndpoint;
@@ -96,7 +96,7 @@ public class AuthenticationExample {
}
public static class LogonAuthenticator {
- public void authenticate(Exchange exchange) throws RejectLogon, InvalidPayloadException, FieldNotFound {
+ public void authenticate(Exchange exchange) throws RejectLogon, CamelExchangeException, FieldNotFound {
LOG.info("Acceptor is rejecting logon for " + exchange.getIn().getHeader(QuickfixjEndpoint.SESSION_ID_KEY));
Message message = exchange.getIn().getMandatoryBody(Message.class);
if (message.isSetField(RawData.FIELD)) {
@@ -113,7 +113,7 @@ public class AuthenticationExample {
this.password = password;
}
- public void inject(Exchange exchange) throws InvalidPayloadException {
+ public void inject(Exchange exchange) throws CamelExchangeException {
LOG.info("Injecting password into outgoing logon message");
Message message = exchange.getIn().getMandatoryBody(Message.class);
message.setString(RawData.FIELD, password);