diff --git a/contracts/events.go b/contracts/events.go
index a6577a8..60776b4 100644
--- a/contracts/events.go
+++ b/contracts/events.go
@@ -7,3 +7,8 @@ type EventHandler interface {
 	PublishToTopic() string
 	Handler(msg *message.Message) ([]*message.Message, error)
 }
+
+type EventPublisher interface {
+	Topic() string
+	Marshal() ([]byte, error)
+}