Received: from malur.postgresql.org ([217.196.149.56]) by arkaria.postgresql.org with esmtps (TLS1.3:ECDHE_RSA_AES_256_GCM_SHA384:256) (Exim 4.92) (envelope-from ) id 1q06MG-000142-P1 for psycopg@arkaria.postgresql.org; Fri, 19 May 2023 20:05:48 +0000 Received: from localhost ([127.0.0.1] helo=malur.postgresql.org) by malur.postgresql.org with esmtp (Exim 4.92) (envelope-from ) id 1q06MF-0000Q6-K4 for psycopg@arkaria.postgresql.org; Fri, 19 May 2023 20:05:47 +0000 Received: from makus.postgresql.org ([2001:4800:3e1:1::229]) by malur.postgresql.org with esmtps (TLS1.3:ECDHE_RSA_AES_256_GCM_SHA384:256) (Exim 4.92) (envelope-from ) id 1q04ks-0000Zt-KK for psycopg@lists.postgresql.org; Fri, 19 May 2023 18:23:07 +0000 Received: from mail-wm1-x335.google.com ([2a00:1450:4864:20::335]) by makus.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256 (Exim 4.94.2) (envelope-from ) id 1q04kp-000iXE-0n for psycopg@postgresql.org; Fri, 19 May 2023 18:23:04 +0000 Received: by mail-wm1-x335.google.com with SMTP id 5b1f17b1804b1-3f41dceb93bso23850005e9.1 for ; Fri, 19 May 2023 11:23:02 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=fau.edu; s=google; t=1684520580; x=1687112580; h=to:subject:message-id:date:from:mime-version:from:to:cc:subject :date:message-id:reply-to; bh=unUy6bADwzEzZZ1VaOyIOYpURZlqIMN3QkA0TL/4VVw=; b=VKqsX6OclxhWcu/VG/+e/ClgRaqCQMqgeF1SsHteRyM4S0cESEqsEkeLg9IkkGycVs JwT7Ins7/5j80PotoDrtoRbDATQPSGgZZ7ELe3HXAYq5JdHskZH8Uo8sdDHSMuiXJ3MS te7jfn+cKaQofdONSKKi+IfodJDlLjBrwazlPm/eZKfoYchRU/EpKCuL2bXAp/+TqGZ9 JSE1XQUXlWR8brfpNVHy53w3vJtsqyU//Vc11PrU6PsktJZOdqxTzkMZsLwoPk0Ozk5p TqmA8sDEDxRwHfmvh3rU7OAZrhYLvKrDQOW175c6zhTPXZkNVGh3IW9MNrWB76zpNm49 Fnxw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20221208; t=1684520580; x=1687112580; h=to:subject:message-id:date:from:mime-version:x-gm-message-state :from:to:cc:subject:date:message-id:reply-to; bh=unUy6bADwzEzZZ1VaOyIOYpURZlqIMN3QkA0TL/4VVw=; b=MY29T7QWR9OK5sdYSU0rXfMxt0LHjelKheBudYpQJsFiX6BO0W8a/I5l5QjMCV7l3g cr/rBcGN5VAF96+qwTAzSJEs+ZZHvFhsOkslF2kx9Uo8cr1gWgNtBA928GJd1fZOX983 DMI/yse1mGHYmsDrupxAQWisc3CTDDL0+CizlUOiKQ/8+3qpzvix+1fiypSMtiYLerja AA/A3Fi4iLN4iVbgg3CtlI02j74g64kjLSCYGhC4vPFWsfI4gaN2lEbYPV8OwvJeKfA2 t/5tATtYtUX2alI7S5BBfYbUZ066lN+knggDHJr6/cFC2yS0E/hjWRtisgQgbsQVL0fk vaJw== X-Gm-Message-State: AC+VfDw7NivmHhms/boZfspiTwe8oyvZ0Vtf6HZfaQsJwEollFYmeE7E smsUaqntcbH806wx4MJbNbHld6xp26/ivz27WM+pAvDXpDL/6Hldwhw= X-Google-Smtp-Source: ACHHUZ5WZ//ja8WFvI+5N43Y/6/l5gparjQQuTwEFQSXBrzmmXfc+suua6BiZMEoAQwrTK2IeNb6//6uozc+ugYCAJU= X-Received: by 2002:a7b:c390:0:b0:3f4:2805:c3a with SMTP id s16-20020a7bc390000000b003f428050c3amr1925080wmj.21.1684520580241; Fri, 19 May 2023 11:23:00 -0700 (PDT) MIME-Version: 1.0 From: Scott Laird Date: Fri, 19 May 2023 14:22:49 -0400 Message-ID: Subject: Connection Types with Logical Replication functions To: psycopg@postgresql.org Content-Type: multipart/alternative; boundary="000000000000cd738605fc1002e0" List-Id: List-Help: List-Subscribe: List-Post: List-Owner: List-Archive: Archived-At: Precedence: bulk --000000000000cd738605fc1002e0 Content-Type: text/plain; charset="UTF-8" Hi, I was curious about the usage of synchronous connections with read_message. The documentation says that consume_message should be used with synchronous connections and that read_message is for async connections. I noticed during development that you could call read_message on a synchronous connection and was curious about the repercussions - if any - would be. Would it make sense to implement a check on calling read_message to make sure that an async connection is set? Thanks! --000000000000cd738605fc1002e0 Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
Hi, I was curious about the usage of synchronous=C2=A0conn= ections with read_message. The documentation says that consume_message shou= ld be used with synchronous connections and that read_message is for async = connections. I noticed during development that you could call read_message = on a synchronous connection and was curious about the repercussions - if an= y - would be. Would it make sense to implement a check on calling read_mess= age to make sure that an async connection is set? Thanks!
--000000000000cd738605fc1002e0--