- 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: