Xavier Padro xpadro

xpadro / int-mongo-gw11.java

Created December 4, 2016 19:21

	public class ResultServiceActivator {

	@ServiceActivator(inputChannel = "personOutput")
	public void handle(Person person) {
	System.out.println(String.format("Person retrieved: %s", person));
	}
	}

xpadro / int-mongo-gw10.java

Created December 4, 2016 19:20

	@ComponentScan("xpadro.spring.integration.mongodb")
	@IntegrationComponentScan("xpadro.spring.integration.mongodb")
	public class JavaConfigQueryConfiguration {

	@MessagingGateway
	public interface PersonService {

	@Gateway(requestChannel = "personInput")
	void send(RequestMessage requestMessage);
	}

xpadro / int-mongo-gw9.java

Created December 4, 2016 19:19

personService.send(new RequestMessage("{id : 3}"));

xpadro / int-mongo-gw8.java

Created December 4, 2016 19:18

	public void handle(List<Person> persons) {
	String names = persons.stream().map(Person::getName).collect(Collectors.joining(", "));
	System.out.println(String.format("Persons retrieved: %s", names));
	}

xpadro / int-mongo-gw7.java

Created December 4, 2016 19:17

	private MongoDbOutboundGatewaySpec outboundGateway(MongoDbFactory mongo) {
	return MongoDb.outboundGateway(mongo)
	.queryExpression("payload.data")
	.collectionNameExpression(new LiteralExpression("person"))
	.entityClass(Person.class)
	.maxResults(2);
	}

xpadro / int-mongo-gw6.java

Created December 4, 2016 19:16

personService.send(new RequestMessage("{}"));

xpadro / int-mongo-gw5.java

Created December 4, 2016 19:14

	private MongoDbOutboundGatewaySpec outboundGateway(MongoDbFactory mongo) {
	return MongoDb.outboundGateway(mongo)
	.queryExpression("payload.data")
	.collectionNameExpression(new LiteralExpression("person"))
	.expectSingleResult(true)
	.entityClass(Person.class);
	}

xpadro / int-mongo-gw4.java

Created December 4, 2016 19:12

personService.send(new RequestMessage("{id : 2}"));

xpadro / int-mongo-gw3.java

Created December 4, 2016 19:09

	@SpringBootApplication
	@EnableIntegration
	@Import(JavaDSLQueryConfiguration.class)
	public class JavaDSLQueryApplication extends AbstractApplication {

	public static void main(String[] args) {
	ConfigurableApplicationContext context = SpringApplication.run(JavaDSLQueryApplication.class, args);
	new JavaDSLQueryApplication().start(context);
	}

xpadro / int-mongo-gw2.java

Created December 4, 2016 11:42

	public class ResultHandler {

	public void handle(Person person) {
	System.out.println(String.format("Person retrieved: %s", person));
	}
	}