Junjie
14 小时以前 d719e394fa5733621e99768821157feb2e251718
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
package com.zy.core.task;
 
public enum MainProcessLane {
    CRN("crn"),
    CRN_IO("crn-io-"),
    CRN_IO_FINISH("crn-io-finish-"),
    DUAL_CRN_IO("dual-crn-io-"),
    DUAL_CRN_IO_FINISH("dual-crn-io-finish-"),
    STATION("station"),
    STATION_IN("station-in-"),
    STATION_OUT("station-out-"),
    STATION_OUT_FINISH("station-out-finish-"),
    STATION_IN_ARRIVAL("station-in-arrival-"),
    STATION_COMPLETE("station-complete-"),
    STATION_OUT_ORDER("station-out-order-"),
    STATION_WATCH_CIRCLE("station-watch-circle-"),
    STATION_RUN_BLOCK("station-run-block-"),
    STATION_IDLE_RECOVER("station-idle-recover-"),
    GENERATE_STORE("generate-store-"),
    FAKE_CRN_IO("fake-crn-io-"),
    FAKE_CRN_IO_FINISH("fake-crn-io-finish-"),
    FAKE_STATION_IN("fake-station-in-"),
    FAKE_STATION_OUT("fake-station-out-"),
    FAKE_STATION_OUT_ORDER("fake-station-out-order-"),
    FAKE_STATION_WATCH_CIRCLE("fake-station-watch-circle-"),
    FAKE_STATION_RUN_BLOCK("fake-station-run-block-"),
    FAKE_DUAL_CRN_IO("fake-dual-crn-io-"),
    FAKE_DUAL_CRN_IO_FINISH("fake-dual-crn-io-finish-"),
    FAKE_GENERATE_STORE("fake-generate-store-"),
    FAKE_ASYNC("fake-async-");
 
    private final String laneName;
 
    MainProcessLane(String laneName) {
        this.laneName = laneName;
    }
 
    public String laneName() {
        return laneName;
    }
 
    public String keyedLaneName(Object laneKey) {
        if (laneKey == null) {
            return null;
        }
        return laneName + laneKey;
    }
}