Versions in this module Expand all Collapse all v4 v4.0.1 Mar 30, 2025 Changes in this version + func ConvertMsgPayloadToByteArray(contentType string, payload any) (result []byte, err error) + func GetMsgPayload[T any](msg MessageEnvelope) (res T, err error) + func IsMsgBase64Payload() bool + type HostInfo struct + Host string + Port int + Protocol string + func (info *HostInfo) GetHostURL() string + func (info *HostInfo) IsHostInfoEmpty() bool + type MessageBusConfig struct + Broker HostInfo + Optional map[string]string + Type string + type MessageEnvelope struct + ContentType string + CorrelationID string + ErrorCode int + Payload any + QueryParams map[string]string + ReceivedTopic string + RequestID string + func NewMessageEnvelope(payload any, ctx context.Context) MessageEnvelope + func NewMessageEnvelopeForRequest(payload any, queryParams map[string]string) MessageEnvelope + func NewMessageEnvelopeForResponse(payload any, requestId string, correlationId string, contentType string) (MessageEnvelope, error) + func NewMessageEnvelopeFromJSON(message []byte) (MessageEnvelope, error) + func NewMessageEnvelopeWithError(requestId string, errorMessage string) MessageEnvelope + func (msg *MessageEnvelope) ConvertMsgPayloadToByteArray() error + type TopicChannel struct + Messages chan MessageEnvelope + Topic string Other modules containing this package github.com/agile-edge/go-mod-messaging/v3
Go to main page