if(key.equals("MIST_TTL"))
msgBuilder.setTtl(Long.valueOf(value));
else
msgBuilder.addProperties(KeyValuePair.newBuilder().setKey(key).setValue(value).build());
}
sinkClient.writeMessage(msgBuilder.build());
totalForwardedCount++;
}
}
catch(Exception e) {
e.printStackTrace();