|
|
|
@ -242,7 +242,7 @@ public class MessageEventHandler { |
|
|
|
|
|
|
|
|
|
|
|
1. 创建一个消息工厂类: |
|
|
|
1. 创建一个消息工厂类: |
|
|
|
|
|
|
|
|
|
|
|
``` |
|
|
|
```java |
|
|
|
Copy code |
|
|
|
Copy code |
|
|
|
@Component |
|
|
|
@Component |
|
|
|
public class MessageEventFactory implements EventFactory<MessageEvent> { |
|
|
|
public class MessageEventFactory implements EventFactory<MessageEvent> { |
|
|
|
@ -256,7 +256,7 @@ public class MessageEventFactory implements EventFactory<MessageEvent> { |
|
|
|
|
|
|
|
|
|
|
|
1. 创建一个Disruptor实例: |
|
|
|
1. 创建一个Disruptor实例: |
|
|
|
|
|
|
|
|
|
|
|
``` |
|
|
|
```java |
|
|
|
Copy code |
|
|
|
Copy code |
|
|
|
@Configuration |
|
|
|
@Configuration |
|
|
|
public class DisruptorConfig { |
|
|
|
public class DisruptorConfig { |
|
|
|
|