totole/services
1
0
Fork 0
mirror of https://github.com/kevin-DL/services.git synced 2026-01-15 04:24:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

update events

Browse Source
This commit is contained in:
Asim Aslam
2021-11-02 16:31:09 +00:00
parent 636f5f1758
commit b25df3eb45
5 changed files with 113 additions and 113 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
event/handler/event.go
View File

@@ -36,7 +36,7 @@ func (s *Event) Publish(ctx context.Context, req *pb.PublishRequest, rsp *pb.Pub
return events.Publish(topic, req.Message.AsMap())
}
func (s *Event) Subscribe(ctx context.Context, req *pb.SubscribeRequest, stream pb.Event_SubscribeStream) error {
func (s *Event) Consume(ctx context.Context, req *pb.ConsumeRequest, stream pb.Event_ConsumeStream) error {
if len(req.Topic) == 0 {
return errors.BadRequest("event.publish", "topic is blank")
}
@@ -77,7 +77,7 @@ func (s *Event) Subscribe(ctx context.Context, req *pb.SubscribeRequest, stream
d := &structpb.Struct{}
d.UnmarshalJSON(msg.Payload)
if err := stream.Send(&pb.SubscribeResponse{
if err := stream.Send(&pb.ConsumeResponse{
Topic: req.Topic,
Id: msg.ID,
Timestamp: msg.Timestamp.Format(time.RFC3339Nano),