You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I have the following use case:
Read from a arbitrary Kafka Topic and enqueue it into your queue. The requested callback parameter of Queue.enqueue method will invoke a separate class, which creates a web service call. The web service will return eventually and I'll have a result. The time needed may be between 1-10 s.
Does kq do threaded work automatically, to increase the frequence of web service calls? Or do I have to do something additional?
The text was updated successfully, but these errors were encountered:
Both queueing (producing) and dequeuing (consuming) is synchronous and do not use threads in the current implementation. You would have to do the threading yourself in the callback.
I have the following use case:
Read from a arbitrary Kafka Topic and enqueue it into your queue. The requested callback parameter of
Queue.enqueue
method will invoke a separate class, which creates a web service call. The web service will return eventually and I'll have a result. The time needed may be between 1-10 s.Does kq do threaded work automatically, to increase the frequence of web service calls? Or do I have to do something additional?
The text was updated successfully, but these errors were encountered: