16 lines
682 B
C#
16 lines
682 B
C#
using JiShe.CollectBus.Common.Models;
|
|
using JiShe.CollectBus.IotSystems.MessageReceiveds;
|
|
using JiShe.ServicePro.Kafka.Internal;
|
|
using Volo.Abp.Application.Services;
|
|
|
|
namespace JiShe.CollectBus.Subscribers
|
|
{
|
|
public interface ISubscriberAppService : IApplicationService
|
|
{
|
|
Task<ISubscribeAck> LoginIssuedEvent(List<IssuedEventMessage> issuedEventMessage);
|
|
Task<ISubscribeAck> HeartbeatIssuedEvent(List<IssuedEventMessage> issuedEventMessage);
|
|
Task<ISubscribeAck> ReceivedHeartbeatEvent(List<MessageReceivedHeartbeat> receivedHeartbeatMessage);
|
|
Task<ISubscribeAck> ReceivedLoginEvent(List<MessageReceivedLogin> receivedLoginMessage);
|
|
}
|
|
}
|