记得上下班打卡 | git大法好,push需谨慎
Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
L
liquidnet-bus-v1
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
董敬伟
liquidnet-bus-v1
Commits
6d8a2755
Commit
6d8a2755
authored
Jul 28, 2021
by
胡佳晨
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
修改 sweet
parent
805c6c70
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
10 additions
and
11 deletions
+10
-11
QueueUtils.java
...in/java/com/liquidnet/service/sweet/utils/QueueUtils.java
+10
-11
No files found.
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/utils/QueueUtils.java
View file @
6d8a2755
package
com
.
liquidnet
.
service
.
sweet
.
utils
;
import
com.liquidnet.commons.lang.util.CollectionUtil
;
import
org.springframework.amqp.rabbit.core.RabbitTemplate
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.data.redis.connection.stream.StreamRecords
;
import
org.springframework.data.redis.core.StringRedisTemplate
;
...
...
@@ -17,16 +16,16 @@ public class QueueUtils {
@Autowired
StringRedisTemplate
stringRedisTemplate
;
/**
* 发送消息 - RABBIT
*
* @param exchange 交换机
* @param routeKey 路径
* @param jsonMsg Json字符串
*/
public
void
sendMsgByRabbit
(
String
exchange
,
String
routeKey
,
String
jsonMsg
)
{
rabbitTemplate
.
convertAndSend
(
exchange
,
routeKey
,
jsonMsg
);
}
//
/**
//
* 发送消息 - RABBIT
//
*
//
* @param exchange 交换机
//
* @param routeKey 路径
//
* @param jsonMsg Json字符串
//
*/
//
public void sendMsgByRabbit(String exchange, String routeKey, String jsonMsg) {
//
rabbitTemplate.convertAndSend(exchange, routeKey, jsonMsg);
//
}
/**
* 发送消息 - REDIS
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment