मैं एक एप्लिकेशन विकसित कर रहा हूं जो स्प्रिंग-काफ्का पैकेज का उपयोग कर रहा है और रन टाइम में इसे संभालने वाले डेटा की मात्रा को बदल रहा है।
मैं सिस्टम को रन टाइम में बदलने की क्षमता देना चाहता हूं concurrency की संख्या उस दबाव पर निर्भर करती है जो सिस्टम महसूस करता है (कुछ ऐसा जिसे मैं परिभाषित करूंगा)।
अभी मेरा समाधान doStop और doStart ConcurrentMessageListenerContainer को स्पष्ट रूप से करना है, लेकिन मैं एक साफ तरीके की तलाश करता हूं जो धारा को नुकसान न पहुंचाए और ConcurrentMessageListenerContainer के आंतरिक तरीकों को न छूए। स्पष्ट रूप से

1
Lupidon 29 नवम्बर 2020, 12:10

1 उत्तर

सबसे बढ़िया उत्तर

आपको इन आंतरिक विधियों के साथ सहभागिता करने की आवश्यकता नहीं है; इसके बजाय stop() और start() का उपयोग करें, जो सार्वजनिक हैं।

आप संगामिति को गतिशील रूप से नहीं बदल सकते, केवल कंटेनर को रोककर और प्रारंभ करके, रुकने पर संगामिति को बदलकर।

1
Gary Russell 30 नवम्बर 2020, 16:16