davengeo

/*
 * Copyright (c) 2015.
 * me@davengeo.com
 */

package org.daven.rx.listeners;

import org.daven.rx.domain.EventContainer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

davengeo

/*
 * Copyright (c) 2015.
 * me@davengeo.com
 */

package com.daven.aspects;

import com.google.common.base.Stopwatch;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;

davengeo

/*
 * Copyright (c) 2015.
 * me@davengeo.com
 */

package org.daven.demo.rxcache;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.http.HttpEntity;

davengeo

/*
 * Copyright (c) 2015.
 * me@davengeo.com
 */

package org.daven.demo.rxcache;

import org.infinispan.Cache;
import org.infinispan.manager.DefaultCacheManager;
import org.infinispan.notifications.Listener;

davengeo

/*
 * Copyright (c) 2015.
 * me@davengeo.com
 */

package org.daven.demo.rxcache;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;

davengeo

/*
 * Copyright (c) 2015.
 * David Navarro
 * me@davengeo.com
 */

public class TestRxStreamble implements Streamable<EventContainer> {

    private static Logger LOG = LoggerFactory.getLogger(TestRxStreamble.class);

davengeo

@Component
public class FileTransferScpImpl {


    private final String userName;
    private final String hostName;
    private final FileSystemOptions opts;
    private final StandardFileSystemManager manager;
    private final String privateKeyPath;

davengeo

@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(classes = {
        Application.class,
        TrivialIT.PostConfiguration.class
})
@WebAppConfiguration
@IntegrationTest("server.port=0")
@ActiveProfiles({"default", "test"})
@ConfigurationProperties("application.yml")
public class TrivialIT {

davengeo

public interface ChainOfMessageProcessors extends MessagePostProcessor {

    void setNext(ChainOfMessageProcessors next);

    ChainOfMessageProcessors next();

    default Message toNext(Message message) throws JMSException {
        if (next()!=null) {
            return next().postProcessMessage(message);
        }

davengeo

function getPublicAddress() {
    let interfaces = os.networkInterfaces();
    return _.chain(interfaces)
        .filter(function(o) {
            return o[0].family == 'IPv4' && !_.startsWith(o[0].address, '192.168');
        })
        .flatten()
        .value();
}