- three nodes cluser version 4.1.0
- load balancer
- I am using this one
- Three Java, Go, .Net
# type: ignore | |
from rabbitmq_amqp_python_client import ( # PosixSSlConfigurationContext,; PosixClientCert, | |
AddressHelper, | |
AMQPMessagingHandler, | |
Connection, | |
Environment, | |
Event, | |
ExchangeSpecification, |
let stream = TcpStream::connect((broker.host.as_str(), broker.port)).await?; | |
let mut tls_builder: tokio_native_tls::native_tls::TlsConnectorBuilder = tokio_native_tls::native_tls::TlsConnector::builder(); | |
let cert_bytes = include_bytes!("result/ca_certificate.pem"); | |
let cert = Certificate::from_pem(cert_bytes).unwrap(); | |
let s = tls_builder.add_root_certificate(cert) | |
.danger_accept_invalid_hostnames(false) | |
// .danger_accept_invalid_certs(true) | |
.min_protocol_version(Some(tokio_native_tls::native_tls::Protocol::Tlsv12)); | |
let conn = tokio_native_tls::TlsConnector::from(s.build()?).connect(broker.host.as_str(), stream).await?; |
import json | |
import time | |
from json import JSONEncoder | |
class Foo: | |
def __init__(self, string_1, string_2, int_1): | |
self.string_1 = string_1 | |
self.string_1 = string_2 | |
self.int_1 = int_1 |
Problema: