spring.cloud.stream.function.definition 사용 시 config bus 전달하기 위한 설정 추가

This commit is contained in:
shinmj
2021-11-01 15:12:17 +09:00
parent 9cb068086b
commit efc94295a8
3 changed files with 15 additions and 3 deletions

View File

@@ -8,10 +8,14 @@ spring:
password: msaportal
driver-class-name: com.mysql.cj.jdbc.Driver
cloud:
bus:
destination: springCloudBus
stream:
function:
definition: attachmentEntity # 첨부파일 entity 정보 업데이트 하기 위한 이벤트에 대한 consumer function
definition: attachmentEntity;busConsumer # 첨부파일 entity 정보 업데이트 하기 위한 이벤트에 대한 consumer function & springcloudbus consumer function
bindings:
busConsumer-in-0:
destination: ${spring.cloud.bus.destination}
attachmentEntity-in-0: # 첨부파일 entity 정보 업데이트 하기 위한 이벤트
destination: attachment-entity.topic # queue name
group: attachment

View File

@@ -4,10 +4,14 @@ spring:
username: msaportal
password: msaportal
cloud:
bus:
destination: springCloudBus
stream:
function:
definition: reserveRequest # 예약 요청후 물품 재고업데이트 이벤트에 대한 consumer function
definition: reserveRequest;busConsumer # 예약 요청후 물품 재고업데이트 이벤트에 대한 consumer function & springcloudbus consumer function
bindings:
busConsumer-in-0:
destination: ${spring.cloud.bus.destination}
reserveRequest-in-0: # 예약 요청후 물품 재고업데이트 이벤트에 대한 consumer binding
destination: reserve-request.topic # queue name
group: reserved

View File

@@ -4,10 +4,14 @@ spring:
username: msaportal
password: msaportal
cloud:
bus:
destination: springCloudBus
stream:
function:
definition: inventoryUpdated # 예약 요청후 물품 재고업데이트 결과에 이벤트에 대한 consumer function
definition: inventoryUpdated;busConsumer # 예약 요청후 물품 재고업데이트 결과에 이벤트에 대한 consumer function & springcloudbus consumer function
bindings:
busConsumer-in-0:
destination: ${spring.cloud.bus.destination}
reserveRequest-out-0: # 예약 요청후 물품 재고업데이트 이벤트에 대한 supplier binding
destination: reserve-request.topic # queue name
group: reserved