|
|
@@ -65,7 +65,8 @@ public class CamelDataUtil {
|
|
|
public void processdata(String body, Exchange exchange) throws UnsupportedEncodingException {
|
|
|
Map<String,String> o = exchange.getMessage().getHeader("mqheader", Map.class);
|
|
|
exchange.getMessage().setHeader("CamelPahoOverrideTopic","/dev/"+o.get("devtype")+"/"+o.get("devcode"));
|
|
|
- exchange.getMessage().setBody(body.getBytes("gb2312"));
|
|
|
+// exchange.getMessage().setBody(body.getBytes("gb2312"));
|
|
|
+ exchange.getMessage().setBody(body);
|
|
|
}
|
|
|
|
|
|
public void processGpsData(GpsData gpsData){
|
