/**
* This is invoked for dump files
*/
private void updateDump(String topic, InputStream is, Map attrMap) throws Exception {
clearSqlInfoCache();
ClientProperty prop = (ClientProperty)attrMap.get(FILENAME_ATTR);
String filename = null;
if (prop == null) {
log.warning("The property '" + FILENAME_ATTR + "' has not been found. Will choose an own temporary one");
filename = "tmpFilename.dmp";
}
else
filename = prop.getStringValue();
log.info("'" + topic + "' dumping file '" + filename + "' on '" + this.importLocation + "'");
// will now write to the file system
this.callback.update(topic, is, attrMap);
// and now perform an import of the DB
boolean isEof = true;
boolean isException = false;
int seqNumber = -1;
String exTxt = "";
prop = XBMessage.get(XBConnectionMetaData.JMSX_GROUP_SEQ, attrMap);
if (prop != null) {
seqNumber = prop.getIntValue();
prop = XBMessage.get(XBConnectionMetaData.JMSX_GROUP_EOF, attrMap);
if (prop == null) {
isEof = false;
}
else {
prop = XBMessage.get(XBConnectionMetaData.JMSX_GROUP_EX, attrMap);
if (prop != null) {
exTxt = prop.getStringValue();
isException = true;
}
}
}
log.info("'" + topic + "' dumped file '" + filename + "' on '" + this.importLocation + "' seq nr. '" + seqNumber + "' ex='" + exTxt + "'");