diff --git a/proxy/proxy.go b/proxy/proxy.go index a9f2a89..4837beb 100644 --- a/proxy/proxy.go +++ b/proxy/proxy.go @@ -816,7 +816,7 @@ func (c *client) interceptSystemQuery(hdr *frame.Header, stmt interface{}) { c.send(hdr, &message.ServerError{ErrorMessage: "Proxy unable to create new session for keyspace"}) } else { c.keyspace = s.Keyspace - c.send(hdr, &message.SetKeyspaceResult{Keyspace: s.Keyspace}) + c.send(hdr, &message.SetKeyspaceResult{Keyspace: strings.Trim(s.Keyspace, "\"")}) } default: c.send(hdr, &message.ServerError{ErrorMessage: "Proxy attempted to intercept an unhandled query"})