Comments (5)
Would you be able to run the streaming server with the debug (-SD
) parameter and provide the output?
CC @kozlovic
from stan.net.
I think I have the same issue too. When I use a simple console app with simple example everything seems ok but on my actual code with the same configurations it's somehow erratic when durable name is set. I went through the STAN's client code and saw that it doesn't get any callback from internal nats connection's subscription:
inboxSub = sc.NATSConnection.SubscribeAsync(inbox, sc.processMsg);
internal void processMsg(object sender, MsgHandlerEventArgs args)
{
bool isClosed = false;
AsyncSubscription sub = null;
Msg raw = null;
MsgProto mp = new MsgProto();
ProtocolSerializer.unmarshal(args.Message.Data, mp);
raw = args.Message;
lock (mu)
{
isClosed = (nc == null);
subMap.TryGetValue(raw.Subject, out sub);
}
if (isClosed || sub == null)
return;
sub.processMsg(mp);
}
It seems that some delay or time dependent issue is causing this.
from stan.net.
I have not experienced this anymore, and I am almost convinced now that what I was experiencing was not caused by anything related to the platform. My particular case involve durable queue groups and after some time I realized that I was using the same subject+queue for my local testing than the instances of the application running in our development environment, so my guess is that most probably all the other messages were being delivered to the other instances running in the development environment.
from stan.net.
So I guess that's not the same issue. Thanks for clarifying this.
from stan.net.
I'm closing this for now, please re-open if this remains an issue.
from stan.net.
Related Issues (20)
- issue out of memory: cannot allocate 122880-byte block (1756626944 in use) HOT 5
- Consumer does not process message after changing clientId HOT 4
- Consumer does not process message without Deliver options HOT 8
- Deadlock in BlockingDictionary HOT 9
- Subscribing to a large number of subjects takes a lot of time and memory consumption HOT 4
- Not owned NATS connection is closed if timeout occurs during ConnectRequest HOT 1
- Invalid behavior when using same NATS connection for both NATS and STAN subscriptions HOT 10
- Configurable Timeouts for Protocol Requests
- Update to .NET 4.6 HOT 1
- when using connection.subscribe with Subscription opts, can't get qgroup to work HOT 5
- Stan Client deployed in Kubernetes injected using DI is getting an error clientID already registered during load testing HOT 16
- StartWithLastReceived : Clarification
- Implement Publish/PublishAsync overloads with offset and length for byte array
- Support for RedeliveryCount
- Unhandled exception in unsubscribe from closeDueToPing
- Don't work reconnect
- Jetstream support HOT 1
- 100% CPU load once subscribed HOT 4
- StanConnection will not reconnect after losing connection to server and rosolving it again in version 0.3.0
- Is this possible to depend on a safer version of `Google.Protobuf` NuGet package? HOT 4
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from stan.net.