= new MasterConsumerStore(_database);
MasterUserStore masterUsers = new MasterUserStore(_database);
// init proxy stores
PropertyStore properties = new PropertyStore(source);
VersionInfo info = new VersionInfo(properties);
String schemaVersion = info.getProxySchemaVersion();
if (schemaVersion == null || !schemaVersion.equals("1.0")) {
throw new PersistenceException("Cannot import data: unsupported schema version: "
+ schemaVersion);
}
Date created = new Date(info.getCreationTimestamp());
_log.info("Importing data created on " + created + " by OpenJMS "
+ info.getOpenJMSVersion());
DestinationStore destinations = new DestinationStore(source);
ConsumerStore consumers = new ConsumerStore(destinations, source);
MessageStore messages = new MessageStore(destinations, source);
UserStore users = new UserStore(source);