RabbitMQ : SubscriberNotFoundException about cap HOT 22 CLOSED

如果是用着用着出问题的话，把cap.published与cap.received数据全清了。

from cap.

For any future visitors: This exception can also be triggered if you forgot to register your Queue Handlers with the Dependency Injection engine!

from cap.

在 v2.1.1+ 版本中，当应用程序启动时CAP会将默认Group设置为当前程序集名称，这样可以一定程度解决队列冲突问题。

from cap.

另外一个原因触发这个异常是：

由于不同的实例连接到了相同的数据库，CAP要求相同的实例可以连接同一个库，不同的实例需要连接不同的数据库（或使用TableNamePrefix|Schema 指定不同的表前缀|空间）。

Another reason triggers this exception:
Because different instances connect to the one database, CAP requires the same instance can connect to one database, But different instances need to connect to the different databases.

from cap.

我遇到了这个问题，有一个项目无论怎么改都会报错，但是相同的代码放在另一个项目中完美运行。
数据库里的Content字段引导我来到了这里。

from cap.

PS: if Kafka is used, there are no problems.

I'd just like to note that this does not seem to be the case, as I just received this error using Kafka. I have two copies of the same service, one with the default group and one with the group set to something different so I can guarantee one will receive all messages for testing.

from cap.

Sorry, I am not quite sure how to resolve this. Exception message brings me to this page. I tried to remove the exchange and unbind the queue. But I am still getting the exception:

{"Headers":{"cap-msg-group":"cap.queue.logserver.v1","cap-exception":"SerializationException-->Message can not be found subscriber. Name:, Group:cap.queue.logserver.v1. \r\n see: https://github.com/dotnetcore/CAP/issues/63"},"Value":"data:UnknownType;base64,ZA=="}

from cap.

@ajaffie data:UnknownType;base64,ZA== This is because the message type you produce cannot be converted by the consumer

from cap.

from cap.

UseInMemoryMessageQueue
Message (Name:iotsharp.services.datastream.telemetrydata,Group:cap.queue.iotsharp.v1) can not be found subscriber.

from cap.

Hi, i found this error many times in my project. what i can see is that the retry processor is trying to resolve all the receive failure all the group without filtering its own subscription.

GetReceivedMessagesOfNeedRetry()

private async Task ProcessReceivedAsync(IDataStorage connection, ProcessingContext context)
{
context.ThrowIfStopping();

        var messages = await GetSafelyAsync(connection.GetReceivedMessagesOfNeedRetry);

        foreach (var message in messages)
        {
            await _subscribeDispatcher.DispatchAsync(message);

            await context.WaitAsync(_delay);
        }
    }

do you think we should filter the events here?

from cap.

@desperazo You need to check whether you use the same event table in multiple services by mistake, different services need to have their own event tables

from cap.

查log的时候出现这个异常，最后发现真实异常可能会写在数据库cap.received，content——Headers——cap-exception中。
是SerializationException。已解决。

from cap.

我kafka也发现了一样的问题 找不到订阅者 直接卡这个找不到订阅者 不消费？

from cap.

@weirdyang

Sorry, I am not quite sure how to resolve this. Exception message brings me to this page. I tried to remove the exchange and unbind the queue. But I am still getting the exception:

{"Headers":{"cap-msg-group":"cap.queue.logserver.v1","cap-exception":"SerializationException-->Message can not be found subscriber. Name:, Group:cap.queue.logserver.v1. \r\n see:

Is...solved?
解决了吗？

from cap.

no

from cap.

@ajaffie data:UnknownType;base64,ZA== This is because the message type you produce cannot be converted by the consumer

@henrydingchina yes, please see above

from cap.

我用的是kafka 但是也出现了这个报错 不知道该怎么解决

from cap.

Message (Name:SJZY.FMC.VoucherRedundantCalc,Group:cap.queue.resharpertestrunner.v1) can not be found subscriber.
see: RabbitMQ : SubscriberNotFoundException · Issue #63 · dotnetcore/CAP，我的程序名是SJZY.FMC.Api，不是resharpertestrunner

from cap.

Message (Name:SJZY.FMC.VoucherRedundantCalc,Group:cap.queue.resharpertestrunner.v1) can not be found subscriber. see: RabbitMQ : SubscriberNotFoundException · Issue #63 · dotnetcore/CAP，我的程序名是SJZY.FMC.Api，不是resharpertestrunner

你这个问题解决了吗？我现在生产者和消费者是两个不同的程序，当生产者和消费都都连接配置到同一个数据库实例时，生产者也就会收到这个错误，但是消费都是正常的。

from cap.

另外一个原因触发这个异常是：
由于不同的实例连接到了相同的数据库，CAP要求相同的实例可以连接同一个库，不同的实例需要连接不同的数据库。

请问一下：通过SqlServerStorageInitializer为不同实例各建1张数据库表，是否就可以连接到相同数据库了？

from cap.

@daimeiquan https://cap.dotnetcore.xyz/user-guide/zh/samples/faq/ Use different schema name for different service.

from cap.