Add UnexpectedMessage.Implementation field.

engine/controller/aggregate/controller.go

@@ -50,6 +50,7 @@ func (c *Controller) Handle(
 		c.Config,
 		"AggregateMessageHandler",
 		"RouteCommandToInstance",
+		c.Config.Handler(),
 		env.Message,
 		func() {
 			id = c.Config.Handler().RouteCommandToInstance(env.Message)
@@ -79,6 +80,7 @@ func (c *Controller) Handle(
 				c.Config,
 				"AggregateRoot",
 				"ApplyEvent",
+				r,
 				env.Message,
 				func() {
 					r.ApplyEvent(env.Message)
@@ -115,6 +117,7 @@ func (c *Controller) Handle(
 		c.Config,
 		"AggregateMessageHandler",
 		"HandleCommand",
+		c.Config.Handler(),
 		env.Message,
 		func() {
 			c.Config.Handler().HandleCommand(r, s, env.Message)

engine/controller/aggregate/scope.go

@@ -76,6 +76,7 @@ func (s *scope) RecordEvent(m dogma.Message) {
 		s.config,
 		"AggregateRoot",
 		"ApplyEvent",
+		s.root,
 		m,
 		func() {
 			s.root.ApplyEvent(m)

engine/controller/integration/controller.go

@@ -47,6 +47,7 @@ func (c *Controller) Handle(
 		c.Config,
 		"IntegrationMessageHandler",
 		"TimeoutHint",
+		c.Config.Handler(),
 		env.Message,
 		func() {
 			t = c.Config.Handler().TimeoutHint(env.Message)
@@ -72,6 +73,7 @@ func (c *Controller) Handle(
 		c.Config,
 		"IntegrationMessageHandler",
 		"HandleCommand",
+		c.Config.Handler(),
 		env.Message,
 		func() {
 			err = c.Config.Handler().HandleCommand(ctx, s, env.Message)

engine/controller/process/controller.go

@@ -70,6 +70,7 @@ func (c *Controller) Handle(
 		c.Config,
 		"ProcessMessageHandler",
 		"TimeoutHint",
+		c.Config.Handler(),
 		env.Message,
 		func() {
 			t = c.Config.Handler().TimeoutHint(env.Message)
@@ -173,6 +174,7 @@ func (c *Controller) routeEvent(
 		c.Config,
 		"ProcessMessageHandler",
 		"RouteEventToInstance",
+		handler,
 		env.Message,
 		func() {
 			id, ok, err = handler.RouteEventToInstance(ctx, env.Message)
@@ -234,6 +236,7 @@ func (c *Controller) handle(ctx context.Context, s *scope) error {
 		c.Config,
 		"ProcessMessageHandler",
 		method,
+		c.Config.Handler(),
 		s.env.Message,
 		func() {
 			if s.env.Role == message.EventRole {

engine/controller/projection/controller.go

@@ -80,6 +80,7 @@ func (c *Controller) Handle(
 		c.Config,
 		"ProjectionMessageHandler",
 		"TimeoutHint",
+		handler,
 		env.Message,
 		func() {
 			t = handler.TimeoutHint(env.Message)
@@ -149,6 +150,7 @@ func (c *Controller) Handle(
 		c.Config,
 		"ProjectionMessageHandler",
 		"HandleEvent",
+		handler,
 		env.Message,
 		func() {
 			ok, err = handler.HandleEvent(

engine/panicx/unexpectedmessage.go

@@ -17,6 +17,9 @@ type UnexpectedMessage struct {
 	// controller called resulting in the panic.
 	Interface string
 
+	// Implementation is the value that implements the nominated interface.
+	Implementation interface{}
+
 	// Method is the name of the method that the controller called resulting in
 	// the panic.
 	Method string
@@ -30,9 +33,10 @@ type UnexpectedMessage struct {
 
 func (x UnexpectedMessage) String() string {
 	return fmt.Sprintf(
-		"the '%s' %s message handler did not expect %s() to be called with a message of type %T",
+		"the '%s' %s message handler did not expect %T.%s() to be called with a message of type %T",
 		x.Handler.Identity().Name,
 		x.Handler.HandlerType(),
+		x.Implementation,
 		x.Method,
 		x.Message,
 	)
@@ -43,7 +47,8 @@ func (x UnexpectedMessage) String() string {
 // the failure.
 func EnrichUnexpectedMessage(
 	h configkit.RichHandler,
-	iface, method string,
+	iface string, method string,
+	impl interface{},
 	m dogma.Message,
 	fn func(),
 ) {
@@ -56,11 +61,12 @@ func EnrichUnexpectedMessage(
 
 		if v == dogma.UnexpectedMessage {
 			v = UnexpectedMessage{
-				Handler:       h,
-				Interface:     iface,
-				Method:        method,
-				Message:       m,
-				PanicLocation: LocationOfPanic(),
+				Handler:        h,
+				Interface:      iface,
+				Method:         method,
+				Implementation: impl,
+				Message:        m,
+				PanicLocation:  LocationOfPanic(),
 			}
 		}
 

engine/panicx/unexpectedmessage_test.go

@@ -28,14 +28,15 @@ var _ = Describe("type UnexpectedMessage", func() {
 
 				x := r.(UnexpectedMessage)
 				Expect(x.String()).To(Equal(
-					"the '<name>' projection message handler did not expect <method>() to be called with a message of type fixtures.MessageA",
+					"the '<name>' projection message handler did not expect *fixtures.ProjectionMessageHandler.<method>() to be called with a message of type fixtures.MessageA",
 				))
 			}()
 
 			EnrichUnexpectedMessage(
 				config,
 				"<interface>",
 				"<method>",
+				config.Handler(),
 				MessageA1,
 				func() {
 					panic(dogma.UnexpectedMessage)
@@ -62,6 +63,7 @@ var _ = Describe("func EnrichUnexpectedMessage()", func() {
 			config,
 			"<interface>",
 			"<method>",
+			config.Handler(),
 			MessageA1,
 			func() {
 				called = true
@@ -77,6 +79,7 @@ var _ = Describe("func EnrichUnexpectedMessage()", func() {
 				config,
 				"<interface>",
 				"<method>",
+				config.Handler(),
 				MessageA1,
 				func() {
 					panic("<panic>")
@@ -91,27 +94,31 @@ var _ = Describe("func EnrichUnexpectedMessage()", func() {
 				config,
 				"<interface>",
 				"<method>",
+				config.Handler(),
 				MessageA1,
-				func() {
-					panic(dogma.UnexpectedMessage)
-				},
+				panicWithUnexpectedMessage,
 			)
 		}).To(PanicWith(
 			MatchAllFields(
 				Fields{
-					"Handler":   Equal(config),
-					"Interface": Equal("<interface>"),
-					"Method":    Equal("<method>"),
-					"Message":   Equal(MessageA1),
+					"Handler":        Equal(config),
+					"Interface":      Equal("<interface>"),
+					"Method":         Equal("<method>"),
+					"Implementation": Equal(config.Handler()),
+					"Message":        Equal(MessageA1),
 					"PanicLocation": MatchAllFields(
 						Fields{
-							"Func": Not(BeEmpty()),
-							"File": HaveSuffix("/unexpectedmessage_test.go"),
-							"Line": Equal(96),
+							"Func": Equal("github.com/dogmatiq/testkit/engine/panicx_test.panicWithUnexpectedMessage"),
+							"File": HaveSuffix("/engine/panicx/unexpectedmessage_test.go"),
+							"Line": Equal(123),
 						},
 					),
 				},
 			),
 		))
 	})
 })
+
+func panicWithUnexpectedMessage() {
+	panic(dogma.UnexpectedMessage)
+}