prizrak39

Примерно так должна выглядеть реализация через Rx?

String pathFile = "C:\1.txt"; 
        Observable<String> myObservable = Observable.create(
            new Observable.OnSubscribe<String>() {
            @Override
            public void call(Subscriber<? super String> sub) {
                sub.onNext(pathFile);
                sub.onCompleted();
            }
        });
        
        Subscriber<String> mySubscriber = new Subscriber<String>() {
            @Override
            public void onNext(String s) { 
                // Upload file
            }

            @Override
            public void onCompleted() { }

            @Override
            public void onError(Throwable e) { }
        };
    
        myObservable.subscribe(mySubscriber);

А junit подходит для этих целей?

Хочу немного резюмировать. Каждый микросервис представляется собой REST сервис, которые между собой обмениваются данными через шины (например RabbitMQ или ActiveMQ). Данные кэшируются в распределенном кэше, например memcached или redis.

Тогда опишу чуть более подробнее суть проблемы. У меня есть некая информация о пользователе и мне необходимо ее дополнять, то есть не полностью загружать заново, а именно дополнять. Вот я подумал что могу использовать для этого кэш.

Вот пример мэппинга. Классы Person одинаковые, просто расположены в разных пакетах.

public class OrderMapper {

    public static Person orderMapperPerson1(Order order) {
        Person person = new Person();

        person.setFirstName(order.getFirstName());
        person.setLastName(order.getLastName());
        person.setAge(order.getAge());

        return person;
    }

    public static com.company.package2.Person orderMapperPerson2(Order order) {
        com.company.package2.Person person = new com.company.package2.Person();

        person.setFirstName(order.getFirstName());
        person.setLastName(order.getLastName());
        person.setAge(order.getAge());

        return person;
    }
}

Да, теперь понимаю что можно. Но понял что появляется проблема как у приложения указать package, в котором hibernate ищет классы для работы с БД db.pojo.package.

Я немного неточно высказался. На данный момент и логика и интерфейс пишется на Vaadin. Хочется организовать в новом приложении более понятную и удобную в масштабировании архитектуру.