liuchen864
6 months ago
2 changed files with 131 additions and 34 deletions
@ -0,0 +1,42 @@ |
|||
package com.win.mq.rocket; |
|||
|
|||
import com.win.mq.config.SmfsConfigure; |
|||
import com.win.mq.utils.sfms.AccessTokenUtil; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; |
|||
import org.apache.rocketmq.spring.core.RocketMQListener; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Component; |
|||
import org.springframework.web.client.RestTemplate; |
|||
|
|||
@Slf4j |
|||
@Component |
|||
public class ChangchunWmsConsumer { |
|||
|
|||
@Autowired |
|||
private AccessTokenUtil accessTokenUtil; |
|||
@Autowired |
|||
private SmfsConfigure smfsConfigure; |
|||
@Autowired |
|||
private RestTemplate restTemplate; |
|||
|
|||
@Component |
|||
@RocketMQMessageListener(topic = "SupplierDeliverRecord", consumerGroup = "SupplierDeliverRecord", selectorExpression="ChangchunWms") |
|||
class RocketMQConsumerWms implements RocketMQListener<String> { |
|||
public void onMessage(String message) { |
|||
//获取token,调用采购订单接口
|
|||
//AccessTokenVO accessTokenVO = accessTokenUtil.getAccessTokenVO();
|
|||
//log.info(accessTokenVO.toString());
|
|||
//HttpHeaders headers = new HttpHeaders();
|
|||
//headers.setContentType(MediaType.APPLICATION_JSON);
|
|||
//headers.add(HttpHeaders.AUTHORIZATION, "Bearer " + accessTokenVO.getAccessToken());
|
|||
//headers.add("tenant-id", "1");
|
|||
// 将JSON参数转换成HttpEntity对象
|
|||
//HttpEntity<String> requestEntity = new HttpEntity<>(message, headers);
|
|||
// 发起POST请求
|
|||
//ResponseEntity<String> responseEntity = restTemplate.postForEntity(smfsConfigure.getPurchaseOrder(), requestEntity, String.class);
|
|||
log.info("RocketMQConsumerWms received message: " + message); |
|||
} |
|||
} |
|||
|
|||
} |
Loading…
Reference in new issue