38
38
import org .apache .eventmesh .runtime .core .protocol .http .processor .HeartBeatProcessor ;
39
39
import org .apache .eventmesh .runtime .core .protocol .http .processor .LocalSubscribeEventProcessor ;
40
40
import org .apache .eventmesh .runtime .core .protocol .http .processor .LocalUnSubscribeEventProcessor ;
41
+ import org .apache .eventmesh .runtime .core .protocol .http .processor .RemoteSubscribeEventProcessor ;
42
+ import org .apache .eventmesh .runtime .core .protocol .http .processor .RemoteUnSubscribeEventProcessor ;
41
43
import org .apache .eventmesh .runtime .core .protocol .http .processor .ReplyMessageProcessor ;
42
44
import org .apache .eventmesh .runtime .core .protocol .http .processor .SendAsyncEventProcessor ;
43
45
import org .apache .eventmesh .runtime .core .protocol .http .processor .SendAsyncMessageProcessor ;
46
+ import org .apache .eventmesh .runtime .core .protocol .http .processor .SendAsyncRemoteEventProcessor ;
44
47
import org .apache .eventmesh .runtime .core .protocol .http .processor .SendSyncMessageProcessor ;
45
48
import org .apache .eventmesh .runtime .core .protocol .http .processor .SubscribeProcessor ;
46
49
import org .apache .eventmesh .runtime .core .protocol .http .processor .UnSubscribeProcessor ;
@@ -342,6 +345,9 @@ public void registerHTTPRequestProcessor() {
342
345
SendAsyncEventProcessor sendAsyncEventProcessor = new SendAsyncEventProcessor (this );
343
346
registerProcessor (RequestURI .PUBLISH .getRequestURI (), sendAsyncEventProcessor , sendMsgExecutor );
344
347
348
+ SendAsyncRemoteEventProcessor sendAsyncRemoteEventProcessor = new SendAsyncRemoteEventProcessor (this );
349
+ registerProcessor (RequestURI .PUBLISH_BRIDGE .getRequestURI (), sendAsyncRemoteEventProcessor , remoteMsgExecutor );
350
+
345
351
AdminMetricsProcessor adminMetricsProcessor = new AdminMetricsProcessor (this );
346
352
registerProcessor (RequestCode .ADMIN_METRICS .getRequestCode (), adminMetricsProcessor , adminExecutor );
347
353
@@ -354,12 +360,18 @@ public void registerHTTPRequestProcessor() {
354
360
LocalSubscribeEventProcessor localSubscribeEventProcessor = new LocalSubscribeEventProcessor (this );
355
361
registerProcessor (RequestURI .SUBSCRIBE_LOCAL .getRequestURI (), localSubscribeEventProcessor , clientManageExecutor );
356
362
363
+ RemoteSubscribeEventProcessor remoteSubscribeEventProcessor = new RemoteSubscribeEventProcessor (this );
364
+ registerProcessor (RequestURI .SUBSCRIBE_REMOTE .getRequestURI (), remoteSubscribeEventProcessor , clientManageExecutor );
365
+
357
366
UnSubscribeProcessor unSubscribeProcessor = new UnSubscribeProcessor (this );
358
367
registerProcessor (RequestCode .UNSUBSCRIBE .getRequestCode (), unSubscribeProcessor , clientManageExecutor );
359
368
360
369
LocalUnSubscribeEventProcessor localUnSubscribeEventProcessor = new LocalUnSubscribeEventProcessor (this );
361
370
registerProcessor (RequestURI .UNSUBSCRIBE_LOCAL .getRequestURI (), localUnSubscribeEventProcessor , clientManageExecutor );
362
371
372
+ RemoteUnSubscribeEventProcessor remoteUnSubscribeEventProcessor = new RemoteUnSubscribeEventProcessor (this );
373
+ registerProcessor (RequestURI .UNSUBSCRIBE_REMOTE .getRequestURI (), remoteUnSubscribeEventProcessor , clientManageExecutor );
374
+
363
375
ReplyMessageProcessor replyMessageProcessor = new ReplyMessageProcessor (this );
364
376
registerProcessor (RequestCode .REPLY_MESSAGE .getRequestCode (), replyMessageProcessor , replyMsgExecutor );
365
377
}
0 commit comments