activemq-protobuf/src/main/java/org/apache/activemq/protobuf/compiler/AltJavaGenerator.java [112:241]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - auto_clear_optional_fields = Boolean.parseBoolean(getOption(proto.getOptions(), "auto_clear_optional_fields", "false")); if( multipleFiles ) { generateProtoFile(); } else { writeFile(outerClassName, new Closure(){ public void execute() throws CompilerException { generateProtoFile(); } }); } if (!errors.isEmpty()) { throw new CompilerException(errors); } } private void writeFile(String className, Closure closure) throws CompilerException { PrintWriter oldWriter = w; // Figure out the java file name.. File outputFile = out; if (javaPackage != null) { String packagePath = javaPackage.replace('.', '/'); outputFile = new File(outputFile, packagePath); } outputFile = new File(outputFile, className + ".java"); // Start writing the output file.. outputFile.getParentFile().mkdirs(); FileOutputStream fos=null; try { fos = new FileOutputStream(outputFile); w = new PrintWriter(fos); closure.execute(); w.flush(); } catch (FileNotFoundException e) { errors.add("Failed to write to: "+outputFile.getPath()+":"+e.getMessage()); } finally { try { fos.close(); } catch (Throwable ignore){} w = oldWriter; } } private void loadImports(ProtoDescriptor proto, File protoDir) { LinkedHashMap children = new LinkedHashMap(); for (String imp : proto.getImports()) { File file = new File(protoDir, imp); for (int i = 0; i < path.length && !file.exists(); i++) { file = new File(path[i], imp); } if ( !file.exists() ) { errors.add("Cannot load import: "+imp); } FileInputStream is=null; try { is = new FileInputStream(file); ProtoParser parser = new ProtoParser(is); ProtoDescriptor child = parser.ProtoDescriptor(); child.setName(file.getName()); loadImports(child, file.getParentFile()); children.put(imp, child); } catch (ParseException e) { errors.add("Failed to parse: "+file.getPath()+":"+e.getMessage()); } catch (FileNotFoundException e) { errors.add("Failed to open: "+file.getPath()+":"+e.getMessage()); } finally { try { is.close(); } catch (Throwable ignore){} } } proto.setImportProtoDescriptors(children); } private void generateProtoFile() throws CompilerException { if( multipleFiles ) { for (EnumDescriptor value : proto.getEnums().values()) { final EnumDescriptor o = value; String className = uCamel(o.getName()); writeFile(className, new Closure(){ public void execute() throws CompilerException { generateFileHeader(); generateEnum(o); } }); } for (MessageDescriptor value : proto.getMessages().values()) { final MessageDescriptor o = value; String className = uCamel(o.getName()); writeFile(className, new Closure(){ public void execute() throws CompilerException { generateFileHeader(); generateMessageBean(o); } }); } } else { generateFileHeader(); p("public class " + outerClassName + " {"); indent(); for (EnumDescriptor enumType : proto.getEnums().values()) { generateEnum(enumType); } for (MessageDescriptor m : proto.getMessages().values()) { generateMessageBean(m); } unindent(); p("}"); } } private void generateFileHeader() { p("//"); p("// Generated by protoc, do not edit by hand."); p("//"); if (javaPackage != null) { p("package " + javaPackage + ";"); p(""); } } private void generateMessageBean(MessageDescriptor m) { String className = uCamel(m.getName()); - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-protobuf/src/main/java/org/apache/activemq/protobuf/compiler/JavaGenerator.java [115:244]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - auto_clear_optional_fields = Boolean.parseBoolean(getOption(proto.getOptions(), "auto_clear_optional_fields", "false")); if( multipleFiles ) { generateProtoFile(); } else { writeFile(outerClassName, new Closure(){ public void execute() throws CompilerException { generateProtoFile(); } }); } if (!errors.isEmpty()) { throw new CompilerException(errors); } } private void writeFile(String className, Closure closure) throws CompilerException { PrintWriter oldWriter = w; // Figure out the java file name.. File outputFile = out; if (javaPackage != null) { String packagePath = javaPackage.replace('.', '/'); outputFile = new File(outputFile, packagePath); } outputFile = new File(outputFile, className + ".java"); // Start writing the output file.. outputFile.getParentFile().mkdirs(); FileOutputStream fos=null; try { fos = new FileOutputStream(outputFile); w = new PrintWriter(fos); closure.execute(); w.flush(); } catch (FileNotFoundException e) { errors.add("Failed to write to: "+outputFile.getPath()+":"+e.getMessage()); } finally { try { fos.close(); } catch (Throwable ignore){} w = oldWriter; } } private void loadImports(ProtoDescriptor proto, File protoDir) { LinkedHashMap children = new LinkedHashMap(); for (String imp : proto.getImports()) { File file = new File(protoDir, imp); for (int i = 0; i < path.length && !file.exists(); i++) { file = new File(path[i], imp); } if ( !file.exists() ) { errors.add("Cannot load import: "+imp); } FileInputStream is=null; try { is = new FileInputStream(file); ProtoParser parser = new ProtoParser(is); ProtoDescriptor child = parser.ProtoDescriptor(); child.setName(file.getName()); loadImports(child, file.getParentFile()); children.put(imp, child); } catch (ParseException e) { errors.add("Failed to parse: "+file.getPath()+":"+e.getMessage()); } catch (FileNotFoundException e) { errors.add("Failed to open: "+file.getPath()+":"+e.getMessage()); } finally { try { is.close(); } catch (Throwable ignore){} } } proto.setImportProtoDescriptors(children); } private void generateProtoFile() throws CompilerException { if( multipleFiles ) { for (EnumDescriptor value : proto.getEnums().values()) { final EnumDescriptor o = value; String className = uCamel(o.getName()); writeFile(className, new Closure(){ public void execute() throws CompilerException { generateFileHeader(); generateEnum(o); } }); } for (MessageDescriptor value : proto.getMessages().values()) { final MessageDescriptor o = value; String className = uCamel(o.getName()); writeFile(className, new Closure(){ public void execute() throws CompilerException { generateFileHeader(); generateMessageBean(o); } }); } } else { generateFileHeader(); p("public class " + outerClassName + " {"); indent(); for (EnumDescriptor enumType : proto.getEnums().values()) { generateEnum(enumType); } for (MessageDescriptor m : proto.getMessages().values()) { generateMessageBean(m); } unindent(); p("}"); } } private void generateFileHeader() { p("//"); p("// Generated by protoc, do not edit by hand."); p("//"); if (javaPackage != null) { p("package " + javaPackage + ";"); p(""); } } private void generateMessageBean(MessageDescriptor m) { String className = uCamel(m.getName()); - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -