diff --git a/pkg/events/events.go b/pkg/events/events.go
index 4ab2e4968..bc034e175 100644
--- a/pkg/events/events.go
+++ b/pkg/events/events.go
@@ -32,7 +32,6 @@ var pubsub *gochannel.GoChannel
 
 type Event interface {
 	TopicName() string
-	Message() interface{}
 }
 
 func InitEvents() (err error) {
@@ -75,7 +74,7 @@ func InitEvents() (err error) {
 }
 
 func Publish(event Event) error {
-	content, err := json.Marshal(event.Message())
+	content, err := json.Marshal(event)
 	if err != nil {
 		return err
 	}
diff --git a/pkg/models/events.go b/pkg/models/events.go
index 6c0605035..faa1994d1 100644
--- a/pkg/models/events.go
+++ b/pkg/models/events.go
@@ -29,10 +29,6 @@ func (t *TaskCreatedEvent) TopicName() string {
 	return "task.created"
 }
 
-func (t *TaskCreatedEvent) Message() interface{} {
-	return t
-}
-
 type TaskUpdatedEvent struct {
 	Task *Task
 	Doer *user.User
@@ -42,10 +38,6 @@ func (t *TaskUpdatedEvent) TopicName() string {
 	return "task.updated"
 }
 
-func (t *TaskUpdatedEvent) Message() interface{} {
-	return t
-}
-
 type TaskAssigneeCreatedEvent struct {
 	Task     *Task
 	Assignee *user.User
@@ -56,10 +48,6 @@ func (t *TaskAssigneeCreatedEvent) TopicName() string {
 	return "task.assignee.created"
 }
 
-func (t *TaskAssigneeCreatedEvent) Message() interface{} {
-	return t
-}
-
 type TaskCommentCreatedEvent struct {
 	Task    *Task
 	Comment *TaskComment
@@ -69,7 +57,3 @@ type TaskCommentCreatedEvent struct {
 func (t *TaskCommentCreatedEvent) TopicName() string {
 	return "task.comment.created"
 }
-
-func (t *TaskCommentCreatedEvent) Message() interface{} {
-	return t
-}