diff --git a/pkg/bus/character/characterbus/message.go b/pkg/bus/character/characterbus/message.go index e2c4c7d..158d2ed 100644 --- a/pkg/bus/character/characterbus/message.go +++ b/pkg/bus/character/characterbus/message.go @@ -19,6 +19,9 @@ type Message struct { Deleted bool `json:"deleted"` } +type BusReader bus.MessageBusReader[Message] +type BusWriter bus.MessageBusWriter[Message] + func (m Message) GetType() bus.BusMessageType { return bus.BusMessageType("sro.character") } diff --git a/pkg/bus/gameserver/dimensionbus/message.go b/pkg/bus/gameserver/dimensionbus/message.go index 9d474c2..661f184 100644 --- a/pkg/bus/gameserver/dimensionbus/message.go +++ b/pkg/bus/gameserver/dimensionbus/message.go @@ -10,6 +10,9 @@ type Message struct { Deleted bool `json:"deleted"` } +type BusReader bus.MessageBusReader[Message] +type BusWriter bus.MessageBusWriter[Message] + func (m Message) GetType() bus.BusMessageType { return bus.BusMessageType("sro.gameserver.dimension") } diff --git a/pkg/bus/gameserver/mapbus/message.go b/pkg/bus/gameserver/mapbus/message.go index 11130a5..f5d651e 100644 --- a/pkg/bus/gameserver/mapbus/message.go +++ b/pkg/bus/gameserver/mapbus/message.go @@ -17,6 +17,9 @@ type Message struct { UpdatedAt time.Time } +type BusReader bus.MessageBusReader[Message] +type BusWriter bus.MessageBusWriter[Message] + func (m Message) GetType() bus.BusMessageType { return bus.BusMessageType("sro.gameserver.map") }