From e49208f2514ccf950164a2d6d590d85f7cecb46a Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期五, 07 六月 2024 16:26:28 +0800
Subject: [PATCH] #
---
zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/cache/MessageQueue.java | 42 +++++++++++++++++++++---------------------
1 files changed, 21 insertions(+), 21 deletions(-)
diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/cache/MessageQueue.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/cache/MessageQueue.java
index e6361a6..9c84886 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/cache/MessageQueue.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/cache/MessageQueue.java
@@ -1,6 +1,6 @@
package com.zy.asrs.wcs.rcs.cache;
-import com.zy.asrs.wcs.rcs.model.Task;
+import com.zy.asrs.wcs.rcs.model.MessageTask;
import com.zy.asrs.wcs.rcs.model.enums.SlaveType;
import java.util.Map;
@@ -15,27 +15,27 @@
public class MessageQueue {
// 杈撻�佺嚎mq浜ゆ崲鏈�
- private static final Map<Integer, ConcurrentLinkedQueue<Task>> DEVP_EXCHANGE = new ConcurrentHashMap<>();
+ private static final Map<Integer, ConcurrentLinkedQueue<MessageTask>> CONVEYOR_EXCHANGE = new ConcurrentHashMap<>();
// 鏉＄爜鎵弿浠猰q浜ゆ崲鏈�
- private static final Map<Integer, ConcurrentLinkedQueue<Task>> BARCODE_EXCHANGE = new ConcurrentHashMap<>();
+ private static final Map<Integer, ConcurrentLinkedQueue<MessageTask>> BARCODE_EXCHANGE = new ConcurrentHashMap<>();
// Led鐏� mq浜ゆ崲鏈�
- private static final Map<Integer, LinkedBlockingQueue<Task>> LED_EXCHANGE = new ConcurrentHashMap<>();
+ private static final Map<Integer, LinkedBlockingQueue<MessageTask>> LED_EXCHANGE = new ConcurrentHashMap<>();
// 纾呯Оmq浜ゆ崲鏈�
- private static final Map<Integer, ConcurrentLinkedQueue<Task>> SCALE_EXCHANGE = new ConcurrentHashMap<>();
+ private static final Map<Integer, ConcurrentLinkedQueue<MessageTask>> SCALE_EXCHANGE = new ConcurrentHashMap<>();
// 鍙拌溅mq浜ゆ崲鏈�
- private static final Map<Integer, ConcurrentLinkedQueue<Task>> CAR_EXCHANGE = new ConcurrentHashMap<>();
+ private static final Map<Integer, ConcurrentLinkedQueue<MessageTask>> CAR_EXCHANGE = new ConcurrentHashMap<>();
//鍥涘悜绌挎杞q浜ゆ崲鏈�
- private static final Map<Integer, ConcurrentLinkedQueue<Task>> SHUTTLE_EXCHANGE = new ConcurrentHashMap<>();
+ private static final Map<Integer, ConcurrentLinkedQueue<MessageTask>> SHUTTLE_EXCHANGE = new ConcurrentHashMap<>();
//鎻愬崌鏈簃q浜ゆ崲鏈�
- private static final Map<Integer, ConcurrentLinkedQueue<Task>> LIFT_EXCHANGE = new ConcurrentHashMap<>();
+ private static final Map<Integer, ConcurrentLinkedQueue<MessageTask>> LIFT_EXCHANGE = new ConcurrentHashMap<>();
/**
* mq 浜ゆ崲鏈哄垵濮嬪寲
*/
public static void init(SlaveType type, Integer id) {
switch (type) {
- case Devp:
- DEVP_EXCHANGE.put(id, new ConcurrentLinkedQueue<>());
+ case Conveyor:
+ CONVEYOR_EXCHANGE.put(id, new ConcurrentLinkedQueue<>());
break;
case Barcode:
BARCODE_EXCHANGE.put(id, new ConcurrentLinkedQueue<>());
@@ -61,10 +61,10 @@
* 娣诲姞鍏冪礌
* 濡傛灉鍙戠幇闃熷垪宸叉弧鏃犳硶娣诲姞鐨勮瘽锛屼細鐩存帴杩斿洖false銆�
*/
- public static boolean offer(SlaveType type, Integer id, Task task) {
+ public static boolean offer(SlaveType type, Integer id, MessageTask task) {
switch (type) {
- case Devp:
- return DEVP_EXCHANGE.get(id).offer(task);
+ case Conveyor:
+ return CONVEYOR_EXCHANGE.get(id).offer(task);
case Barcode:
return BARCODE_EXCHANGE.get(id).offer(task);
case Led:
@@ -84,10 +84,10 @@
* 绉婚櫎鍏冪礌
* 鑻ラ槦鍒椾负绌猴紝杩斿洖null銆�
*/
- public static Task poll(SlaveType type, Integer id) {
+ public static MessageTask poll(SlaveType type, Integer id) {
switch (type) {
- case Devp:
- return DEVP_EXCHANGE.get(id).poll();
+ case Conveyor:
+ return CONVEYOR_EXCHANGE.get(id).poll();
case Barcode:
return BARCODE_EXCHANGE.get(id).poll();
case Led:
@@ -106,10 +106,10 @@
/**
* 鍙栧嚭鍏冪礌锛屽苟涓嶅垹闄�.
*/
- public static Task peek(SlaveType type, Integer id) {
+ public static MessageTask peek(SlaveType type, Integer id) {
switch (type) {
- case Devp:
- return DEVP_EXCHANGE.get(id).peek();
+ case Conveyor:
+ return CONVEYOR_EXCHANGE.get(id).peek();
case Barcode:
return BARCODE_EXCHANGE.get(id).peek();
case Led:
@@ -127,8 +127,8 @@
public static void clear(SlaveType type, Integer id){
switch (type) {
- case Devp:
- DEVP_EXCHANGE.get(id).clear();
+ case Conveyor:
+ CONVEYOR_EXCHANGE.get(id).clear();
break;
case Barcode:
BARCODE_EXCHANGE.get(id).clear();
--
Gitblit v1.9.1