core/internal/watermill/watermillmsg/server.go