Make delta default for messsages without FORMAT header #32

Author: rob42

src/main/java/nz/co/fortytwo/signalk/processor/FullToDeltaProcessor.java

@@ -32,6 +32,7 @@
 
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
+import org.apache.commons.lang3.StringUtils;
 import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger;
 
 /**
@@ -52,7 +53,8 @@ public void process(Exchange exchange) throws Exception {
 			if (exchange.getIn().getBody() == null) return;
 			if(logger.isDebugEnabled())logger.debug("Processing :" + exchange.getIn().getBody().toString());
 			if(!(exchange.getIn().getBody() instanceof Json))return;
-			if (FORMAT_DELTA.equals(exchange.getIn().getHeader(SIGNALK_FORMAT))) {
+			String format = exchange.getIn().getHeader(SIGNALK_FORMAT, String.class);
+			if (StringUtils.isBlank(format) || FORMAT_DELTA.equals(format)) {
 				List<Json> json = fullToDelta.handle(exchange.getIn().getBody(Json.class));
 				//if(logger.isDebugEnabled())logger.debug("Converted to delta :" + json);
 				exchange.getIn().setBody(json);

src/main/java/nz/co/fortytwo/signalk/server/SignalkRouteFactory.java

@@ -190,7 +190,7 @@ public static void configureWebsocketRxRoute(RouteBuilder routeBuilder ,String i
 			.end()
 		.process(new WsSessionProcessor()).id(getName(WsSessionProcessor.class.getSimpleName()))
 		//.to("log:nz.co.fortytwo.signalk.model.websocket.rx?level=INFO&showException=true&showStackTrace=true")
-		.to(input).id(getName("SEDA_INPUT"));
+		.to(input).id(getName(RouteManager.SEDA_INPUT));
 
 	}
 	public static void configureTcpServerRoute(RouteBuilder routeBuilder ,String input, NettyServer nettyServer, String outputType) throws Exception{