Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- buildscript {
- ext {
- springBootVersion = '1.3.2.RELEASE'
- }
- repositories {
- mavenCentral()
- }
- dependencies {
- classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")
- }
- }
- apply plugin: 'java'
- apply plugin: 'spring-boot'
- repositories {
- mavenCentral()
- maven { url 'https://repo.spring.io/snapshot' }
- maven { url 'https://repo.spring.io/milestone' }
- }
- dependencies {
- compile(
- 'org.springframework.cloud:spring-cloud-starter-stream-rabbit',
- )
- }
- dependencyManagement {
- imports {
- mavenBom "org.springframework.cloud:spring-cloud-dependencies:Brixton.BUILD-SNAPSHOT"
- }
- }
- server.port=8010
- spring.cloud.stream.binder.rabbit.default.prefix=z.
- spring.cloud.stream.bindings.input=start
- spring.cloud.stream.bindings.output=testchannel
- spring.rabbitmq.addresses=host1:5672,host2:5672
- spring.rabbitmq.username=user
- spring.rabbitmq.password=psw
- @EnableBinding(Processor.class)
- ...
- @ServiceActivator(inputChannel = Processor.INPUT, outputChannel = Processor.OUTPUT)
- public byte[] handleIncomingMessage(byte[] payload) {}
- server.port=8011
- spring.cloud.stream.binder.rabbit.default.prefix=z.
- spring.cloud.stream.bindings.input=testchannel
- spring.rabbitmq.addresses=host1:5672,host2:5672
- spring.rabbitmq.username=user
- spring.rabbitmq.password=psw
- @EnableBinding(Sink.class)
- ...
- @ServiceActivator(inputChannel = Sink.INPUT)
- public void handleIncomingMessage(byte[] payload) {}
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement