Отправка данных из Hono в Ditto (amqp: resource-limit-превышен) - PullRequest
0 голосов
/ 14 октября 2019

Хоно и То же успешно соединены. Но когда я попытаюсь отправить данные из Hono, я получу сообщение 503 - Сервис недоступен.

Но потом, когда я проверил журналы Ditto. Я получил приведенный ниже предел AMQP.

connectivity_1   | 2019-10-14 16:34:38,294 INFO  [] o.e.d.s.c.m.ConnectionActor akka://ditto- 
cluster/system/sharding/connection/6/hono-sandbox-connection-123/pa - Starting ClientActor for 
connection <hono-sandbox-connection-123> with <1> clients.
connectivity_1   | 2019-10-14 16:34:38,308 INFO  [] a.a.RepointableActorRef akka://ditto- 
cluster/system/distributedPubSubMediator - Message 
[org.eclipse.ditto.signals.events.connectivity.ConnectionCreated] from Actor[akka://ditto- 
cluster/system/sharding/connection/6/hono-sandbox-connection-123/pa#233633004] to Actor[akka://ditto- 
cluster/system/distributedPubSubMediator#-301178072] was not delivered. [9] dead letters encountered. 
If this is not an expected behavior, then [Actor[akka://ditto- 
cluster/system/distributedPubSubMediator#-301178072]] may have terminated unexpectedly, This logging 
can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead- 
letters-during-shutdown'.
connectivity_1   | 2019-10-14 16:34:38,441 INFO  [] o.a.q.j.s.SaslMechanismFinder  - Best match for 
SASL auth was: SASL-PLAIN
connectivity_1   | 2019-10-14 16:34:38,721 INFO  [] o.a.q.j.s.SaslMechanismFinder  - Best match for 
SASL auth was: SASL-PLAIN
connectivity_1   | 2019-10-14 16:34:39,128 INFO  [] o.a.q.j.s.SaslMechanismFinder  - Best match for 
SASL auth was: SASL-PLAIN
connectivity_1   | 2019-10-14 16:34:39,781 INFO  [] o.a.q.j.s.SaslMechanismFinder  - Best match for 
SASL auth was: SASL-PLAIN
connectivity_1   | 2019-10-14 16:34:40,962 INFO  [] o.a.q.j.s.SaslMechanismFinder  - Best match for 
SASL auth was: SASL-PLAIN
connectivity_1   | 2019-10-14 16:34:41,020 WARN  [] o.e.d.s.c.m.a.JMSConnectionHandlingActor 
akka://ditto-cluster/system/sharding/connection/6/hono-sandbox-connection- 
123/pa/$a/c1/jmsConnectionHandling-hono-sandbox-connection-123-connect1 - Failed to connect JMS 
client:connection disallowed by local policy [condition = amqp:resource-limit-exceeded]

Я не уверен, что означает ошибка превышения лимита ресурсов для AMQP? Это мешает мне отправить из Хоно в Ditto?

Будет ли это работать, если я уроню все эти dbs ниже на сервере Ditto Mongo и создам новые вещи и соединения снова?.

> show dbs
admin         0.000GB
concierge     0.000GB
config        0.000GB
connectivity  0.000GB
local         0.000GB
policies      0.002GB
searchDB      0.001GB
things        0.337GB

Изменить: Я попытался снова подключить Eclipse Hono и Eclipse Ditto на тех же серверах, где я получаю ошибки.

Я получил сообщение о состоянии 201 (соединение создано), когда я выполнил команду curl commnad. Но когда я проверил свой журнал одновременно, я получил следующее сообщение:

connectivity_1_ad306c4c315b | 2019-10-15T15:46:36.233449988Z 2019-10-15 17:46:36,233 WARN  [] o.e.d.s.c.m.ConnectionActor akka://ditto-cluster/system/sharding/connection/12/test_co_nn_id_12/pa - Operation <connect> on connection <test_co_nn_id_12> failed due to ConnectionFailedException: Failed to connect JMS client:connection disallowed by local policy [condition = amqp:resource-limit-exceeded].

Примечание: Он работает совершенно нормально, когда я пытаюсь это сделать на своем локальном компьютере или вдругой сервер.

1 Ответ

0 голосов
/ 15 октября 2019

Я удалил стек и полностью очистил MongoDB, используя

docker-compose down

Затем переустановил Ditto. Установил соединения Hono и Ditto и попытался отправить данные как раньше. Все заработало как положено.

...