diff --git a/pkg/websocketclient/websocketclient.go b/pkg/websocketclient/websocketclient.go
index 6608391..38360be 100644
--- a/pkg/websocketclient/websocketclient.go
+++ b/pkg/websocketclient/websocketclient.go
@@ -110,12 +110,6 @@ func NewWebsocketClient(cfg *config.ChiaConfig, options ...rpcinterface.ClientOp
 	return c, nil
 }
 
-// resetOrigin so we get a unique identifier if we have to establish a new connection
-// Helps ensure that we don't end up getting duplicate messages
-func (c *WebsocketClient) resetOrigin() {
-	c.origin = fmt.Sprintf("go-chia-rpc-%d", time.Now().UnixNano())
-}
-
 // SetBaseURL sets the base URL for API requests to a custom endpoint.
 func (c *WebsocketClient) SetBaseURL(url *url.URL) error {
 	c.baseURL = url
@@ -393,7 +387,6 @@ func (c *WebsocketClient) generateDialer() error {
 // ensureConnection ensures there is an open websocket connection and the listener is listening
 func (c *WebsocketClient) ensureConnection() error {
 	if c.conn == nil {
-		c.resetOrigin()
 		u := url.URL{Scheme: "wss", Host: fmt.Sprintf("%s:%d", c.baseURL.Host, c.daemonPort), Path: "/"}
 		var err error
 		c.conn, _, err = c.daemonDialer.Dial(u.String(), nil)