arthurtsang

server:
  port: 9500
idol:
  host: localhost
  indexPort: 9001
  searchPort: 9000

arthurtsang

public class MyAppMain {
    private final static Logger logger = LoggerFactory.getLogger(MyAppMain.class);

    private final static String ENV_PREFIX_PROPERTY = "MYAPP_ENV_PREFIX";
    private final static String ENV_PREFIX_DEFAULT = "MYAPP_";

    public static void main(String[] args) {
        String propertyPrefix = System.getenv().getOrDefault(ENV_PREFIX_PROPERTY, ENV_PREFIX_DEFAULT);
        ConfigData configData = ConfigData.of()
                .yaml(ClassLoader.getSystemResource("application.yaml"))

arthurtsang

buildscript {
        repositories {
                jcenter()
        }
        dependencies {
                classpath 'io.ratpack:ratpack-gradle:0.9.13'
                classpath 'com.github.jengelman.gradle.plugins:shadow:1.2.0'
        }
}

arthurtsang

.git
gradle*
.gradle
src
out
jumpstart*
msvc*
build/dependency-cache
build/classes
build/installShadow

arthurtsang

FROM peelsky/zulu-openjdk-busybox

WORKDIR /app

USER daemon

ADD ./build/libs/msvc-search-1.0-all.jar /app/msvc-search-1.0-all.jar

CMD [ "java", "-jar", "/app/msvc-search-1.0-all.jar" ]

arthurtsang

buildscript {
        repositories {
                jcenter()
        }
        dependencies {
                classpath 'io.ratpack:ratpack-gradle:0.9.13'
                classpath 'com.github.jengelman.gradle.plugins:shadow:1.2.0'
                classpath 'com.bmuschko:gradle-docker-plugin:2.0'
        }
}

arthurtsang

public class DynamicServiceActivatorBeanDefinitionParser extends AbstractSingleBeanDefinitionParser {

    protected Class getBeanClass(Element element) {
        return DefaultDynamicServiceActivator.class;
    }

    @Override
    protected void doParse(Element element, BeanDefinitionBuilder bean) {
        List<Element> methodElements = DomUtils.getChildElementsByTagName(element, "method");
        ManagedMap<String, BeanDefinition> methodMetadataMap = null;

arthurtsang

private SubscribableChannel createInputChannel(String inputChannelName) {
		PublishSubscribeChannel channel = new PublishSubscribeChannel();
		channel.setBeanName(inputChannelName);
		channel.setBeanFactory(applicationContext);
		//channel.setApplySequence(true);
		((ConfigurableApplicationContext)applicationContext).getBeanFactory().registerSingleton(inputChannelName, channel);
		return channel;
	}

arthurtsang

	private void getConfigsFromZookeeper() throws IOException {
        logger.debug("Connected to Zookeeper");
        synchronized(lock) {
            try {
                configs = trackChildren(configs);
            } catch (Exception e) {
                logger.error("Error tracking Zookeeper config", e);
            }
        }
	}

arthurtsang

<xs:annotation>
   <xs:documentation>
       The input channel of the chain.
   </xs:documentation>
   <xs:appinfo>
       <tool:annotation kind="ref">
         <tool:expected-type type="org.springframework.integration.channel.DirectChannel" />
        </tool:annotation>
    </xs:appinfo>
</xs:annotation>