diff --git a/client/client.go b/client/client.go index 5c1b076..114818c 100644 --- a/client/client.go +++ b/client/client.go @@ -19,7 +19,6 @@ type Client struct { listenerStore *listenerStore catchersStore *sync.Map successMsgStore *sync.Map - forwardMsgStore *sync.Map updatesTimeout time.Duration catchTimeout time.Duration } @@ -75,7 +74,6 @@ func NewClient(authorizationStateHandler AuthorizationStateHandler, options ...O listenerStore: newListenerStore(), catchersStore: &sync.Map{}, successMsgStore: &sync.Map{}, - forwardMsgStore: &sync.Map{}, } client.extraGenerator = UuidV4Generator() @@ -116,10 +114,6 @@ func (client *Client) processResponse(response *Response) { if sOk { sendVal.(chan *Response) <- response } - forwardVal, fOk := client.forwardMsgStore.Load(typ.(*UpdateMessageSendSucceeded).OldMessageId) - if fOk { - forwardVal.(chan *Response) <- response - } } if len(client.listenerStore.Listeners()) == 0 {