Minor

Author: Tim Middleton

coherence/topics.go

@@ -653,7 +653,7 @@ func (m *streamManagerV1) ensurePublisher(ctx context.Context, topicName string,
 
 	var message = &pb1topics.EnsurePublisherResponse{}
 	if err = result.UnmarshalTo(message); err != nil {
-		err = getUnmarshallError("ensure response", err)
+		err = getUnmarshallError("ensure publisher response", err)
 		return nil, err
 	}
 
@@ -933,7 +933,7 @@ func (m *streamManagerV1) ensureTopicChannels(ctx context.Context, topicName str
 
 	var message = &wrapperspb.Int32Value{}
 	if err = result.UnmarshalTo(message); err != nil {
-		err = getUnmarshallError("ensure response", err)
+		err = getUnmarshallError("ensure topics channels response", err)
 		return nil, err
 	}
 
@@ -1098,7 +1098,7 @@ func (m *streamManagerV1) newSubscriberPeekRequest(ProxyID int32, maxMessages *i
 	if err != nil {
 		return nil, err
 	}
-	// TODO: FIX THIS when SImplePeek available
+	// TODO: FIX THIS when SimplePeek available
 	return m.newWrapperProxyPublisherRequest(ProxyID, pb1topics.TopicServiceRequestType_SimpleReceive, anyReq)
 }
 

coherence/v1client.go

@@ -393,7 +393,7 @@ func processTopicEvent(m *streamManagerV1, resp *responseMessage) {
 				case pb1topics.ResponseType_Event:
 					var eventType = &pb1topics.NamedTopicEvent{}
 					if err := resp.namedTopicResponse.Message.UnmarshalTo(eventType); err != nil {
-						err = getUnmarshallError("ensure response", err)
+						err = getUnmarshallError("processTopicEvent response", err)
 						m.session.debugConnection("cannot unmarshal topic response topic for topic %v: %v", topicName, err)
 					} else {
 						if eventType.Type == pb1topics.TopicEventType_TopicDestroyed {
@@ -432,7 +432,7 @@ func processPublisherEvent(m *streamManagerV1, resp *responseMessage, publisherI
 			case pb1topics.ResponseType_Event:
 				var eventType = &pb1topics.PublisherEvent{}
 				if err := resp.namedTopicResponse.Message.UnmarshalTo(eventType); err != nil {
-					err = getUnmarshallError("ensure response", err)
+					err = getUnmarshallError("processPublisherEvent response", err)
 					m.session.debugConnection("cannot unmarshal topic response topic for publisher %v: %v", publisherID, err)
 					return
 				}
@@ -458,7 +458,7 @@ func processSubscriberEvent(m *streamManagerV1, resp *responseMessage, subscribe
 			case pb1topics.ResponseType_Event:
 				var eventType = &pb1topics.SubscriberEvent{}
 				if err := resp.namedTopicResponse.Message.UnmarshalTo(eventType); err != nil {
-					err = getUnmarshallError("ensure response", err)
+					err = getUnmarshallError("processSubscriberEvent response", err)
 					m.session.debugConnection("cannot unmarshal topic response topic for subscriber %v: %v", subscriberID, err)
 					return
 				}