codingtim

IntegrationFlows
  .from(jmsInboundChannelAdapter())
  .channel(inboundChannel())
  .get();

codingtim

Jms.messageDriverChannelAdapter(jmsFactory)
  .configureListenerContainer(defaultMessageListenerContainerJmsListenerContainerSpec ->
    defaultMessageListenerContainerJmsListenerContainerSpec.sessionTransacted(true))
  .destination(QUEUE1)
  .get();

codingtim

IntegrationFlows
  .from(inboundChannel())
  .transform(...)
  .filter(...)
  .channel(subscribableChannel())
  .get();

codingtim

IntegrationFlows
  .from(subscribableChannel())
  .handle(Jms.outboundAdapter(jmsFactory).destination(QUEUE2))
  .get();

codingtim

IntegrationFlows
  .from(subscribableChannel())
  .handle(Jms.outboundAdapter(jmsTemplate).destination(QUEUE2))
  .get();

codingtim

public class EntityServiceImp implements EntityService {

    private EntityRepository repository;
    private ImageService imageService;

    @Override
    public void update(String id, UpdateData updateData) {
        Entity entity = repository.find(id);
        entity.setDescription(updateData.getDescription());
        entity.setTitle(updateData.getTitle());

codingtim

public class EntityServiceImpl implements EntityService {

    private EntityRepository repository;
    private ImageService imageService;

    @Override
    public void update(String id, UpdateData updateData) {
        Entity entity = repository.find(id);
        entity.setDescription(updateData.getDescription());
        entity.setTitle(updateData.getTitle());

codingtim

public class EntityServiceImpl implements EntityService {

    private EntityRepository repository;
    private ImageService imageService;

    @Override
    public void update(String id, UpdateData updateData) {
        Entity entity = repository.find(id);

        ImageEntity image = imageService.getImage(updateData.getImageUrl());

codingtim

public class EntityServiceImpl implements EntityService {

    private EntityRepository repository;
    private ImageService imageService;
    private EntityObservers entityObservers;

    @Override
    public void update(String id, UpdateData updateData) {
        Entity entity = repository.find(id);

codingtim

public class InMemoryMongo {

  private static final String DATA_PATH = "./target/elasticsearch";
  private Node node;
  private Client client;

  public InMemoryMongo() {
  }

  public InMemoryMongo start() {