Pausing and resuming MQTT Inbound Adapter2019 Community Moderator ElectionDesign: Control number of messages to be feeded to the system using Inbound-channel-adapter as entry pointinbound adapter skipping messagesWhy am I seeing multiple transactions using Spring Integration/JtaTransactionManagerSpring Integration MQTT Subscriber (paho) stops processing messagesSpring Integration: inbound and outbound adapters to MQTTspring-integration-mqtt With multiple Mqtt Servers for subscriptionHttp inbound adapter gives empty response on OPTIONS request under CORSGracefully shutdown a spring integration flowSI subscription to multiple mqtt topicsSpring Integration: copy one inbound message to multiple outbound
How to mitigate "bandwagon attacking" from players?
Reason why dimensional travelling would be restricted
GPL code private and stolen
When do _WA_Sys_ statistics Get Updated?
Rationale to prefer local variables over instance variables?
Specific Chinese carabiner QA?
How can neutral atoms have exactly zero electric field when there is a difference in the positions of the charges?
Book about a time-travel war fought by computers
Giving a talk in my old university, how prominently should I tell students my salary?
Practical reasons to have both a large police force and bounty hunting network?
Sometimes a banana is just a banana
Has Wakanda ever accepted refugees?
School performs periodic password audits. Is my password compromised?
I can't die. Who am I?
The need of reserving one's ability in job interviews
Is there a way to find out the age of climbing ropes?
Caulking a corner instead of taping with joint compound?
Wardrobe above a wall with fuse boxes
How to roleplay my character's ethics according to the DM when I don't understand those ethics?
How can I be pwned if I'm not registered on the compromised site?
How to get the first element while continue streaming?
"seeing as you don't know anyone but me" meaning in this context
I encountered my boss during an on-site interview at another company. Should I bring it up when seeing him next time?
How to merge row in the first column in LaTeX
Pausing and resuming MQTT Inbound Adapter
2019 Community Moderator ElectionDesign: Control number of messages to be feeded to the system using Inbound-channel-adapter as entry pointinbound adapter skipping messagesWhy am I seeing multiple transactions using Spring Integration/JtaTransactionManagerSpring Integration MQTT Subscriber (paho) stops processing messagesSpring Integration: inbound and outbound adapters to MQTTspring-integration-mqtt With multiple Mqtt Servers for subscriptionHttp inbound adapter gives empty response on OPTIONS request under CORSGracefully shutdown a spring integration flowSI subscription to multiple mqtt topicsSpring Integration: copy one inbound message to multiple outbound
We have: a converter that takes the messages from mqtt topics, parses, processes those, and after specific validations sends them to the other messaging system. Should the target system be not reachable, we create a specific event and send this through the injected instance of org.springframework.context.ApplicationEventPublisher.
We would like to: in cases the target messaging system is not availbale, to be able to pause (and then later to resume) the consumption of our inbound MQTT adapters.
We do have a collection of references to those adapters, and would like to write the "Toggler" that implements the ApplicationListener and based on event either pauses or resumes the consumption.
As any instance of MessageProducerSupport the MqttPahoMessageDrivenChannelAdapter has the protected doStart() and doStop() methods. Should one try to use those for pausing/resuming purposes?
spring-integration spring-integration-mqtt
asked 12 hours ago
LHALHA
51
add a comment |
We have: a converter that takes the messages from mqtt topics, parses, processes those, and after specific validations sends them to the other messaging system. Should the target system be not reachable, we create a specific event and send this through the injected instance of org.springframework.context.ApplicationEventPublisher.
We would like to: in cases the target messaging system is not availbale, to be able to pause (and then later to resume) the consumption of our inbound MQTT adapters.
We do have a collection of references to those adapters, and would like to write the "Toggler" that implements the ApplicationListener and based on event either pauses or resumes the consumption.
As any instance of MessageProducerSupport the MqttPahoMessageDrivenChannelAdapter has the protected doStart() and doStop() methods. Should one try to use those for pausing/resuming purposes?
spring-integration spring-integration-mqtt
asked 12 hours ago
LHALHA
51
add a comment |
We have: a converter that takes the messages from mqtt topics, parses, processes those, and after specific validations sends them to the other messaging system. Should the target system be not reachable, we create a specific event and send this through the injected instance of org.springframework.context.ApplicationEventPublisher.
We would like to: in cases the target messaging system is not availbale, to be able to pause (and then later to resume) the consumption of our inbound MQTT adapters.
We do have a collection of references to those adapters, and would like to write the "Toggler" that implements the ApplicationListener and based on event either pauses or resumes the consumption.
As any instance of MessageProducerSupport the MqttPahoMessageDrivenChannelAdapter has the protected doStart() and doStop() methods. Should one try to use those for pausing/resuming purposes?
spring-integration spring-integration-mqtt
asked 12 hours ago
LHALHA
51
We have: a converter that takes the messages from mqtt topics, parses, processes those, and after specific validations sends them to the other messaging system. Should the target system be not reachable, we create a specific event and send this through the injected instance of org.springframework.context.ApplicationEventPublisher.
We would like to: in cases the target messaging system is not availbale, to be able to pause (and then later to resume) the consumption of our inbound MQTT adapters.
We do have a collection of references to those adapters, and would like to write the "Toggler" that implements the ApplicationListener and based on event either pauses or resumes the consumption.
As any instance of MessageProducerSupport the MqttPahoMessageDrivenChannelAdapter has the protected doStart() and doStop() methods. Should one try to use those for pausing/resuming purposes?
spring-integration spring-integration-mqtt
spring-integration spring-integration-mqtt
asked 12 hours ago
LHALHA
51
asked 12 hours ago
LHALHA
51
asked 12 hours ago
LHALHA
51
asked 12 hours ago
LHALHA
51
asked 12 hours ago
LHALHA
51
51
add a comment |
add a comment |
1 Answer
1
active
oldest
votes
The MessageProducerSupport extends an AbstractEndpoint which implements a SmartLifecycle with public start() and stop(). You simple can call those to stop polling messages from MQTT and restart whenever you need.
answered 7 hours ago
Artem BilanArtem Bilan
66.7k84972
Thanks Artem, will check it out. Seem to have stopped analyzing too soon.
– LHA
6 hours ago
add a comment |
Your Answer
StackExchange.ifUsing("editor", function ()
StackExchange.using("externalEditor", function ()
StackExchange.using("snippets", function ()
StackExchange.snippets.init();
);
);
, "code-snippets");
StackExchange.ready(function()
var channelOptions =
tags: "".split(" "),
id: "1"
;
initTagRenderer("".split(" "), "".split(" "), channelOptions);
StackExchange.using("externalEditor", function()
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled)
StackExchange.using("snippets", function()
createEditor();
);
else
createEditor();
);
function createEditor()
StackExchange.prepareEditor(
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader:
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
,
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
);
);
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function ()
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f55021227%2fpausing-and-resuming-mqtt-inbound-adapter%23new-answer', 'question_page');
);
Post as a guest
Required, but never shown
1 Answer
1
active
oldest
votes
1 Answer
1
active
oldest
votes
active
oldest
votes
active
oldest
votes
The MessageProducerSupport extends an AbstractEndpoint which implements a SmartLifecycle with public start() and stop(). You simple can call those to stop polling messages from MQTT and restart whenever you need.
answered 7 hours ago
Artem BilanArtem Bilan
66.7k84972
Thanks Artem, will check it out. Seem to have stopped analyzing too soon.
– LHA
6 hours ago
add a comment |
The MessageProducerSupport extends an AbstractEndpoint which implements a SmartLifecycle with public start() and stop(). You simple can call those to stop polling messages from MQTT and restart whenever you need.
answered 7 hours ago
Artem BilanArtem Bilan
66.7k84972
Thanks Artem, will check it out. Seem to have stopped analyzing too soon.
– LHA
6 hours ago
add a comment |
The MessageProducerSupport extends an AbstractEndpoint which implements a SmartLifecycle with public start() and stop(). You simple can call those to stop polling messages from MQTT and restart whenever you need.
answered 7 hours ago
Artem BilanArtem Bilan
66.7k84972
The MessageProducerSupport extends an AbstractEndpoint which implements a SmartLifecycle with public start() and stop(). You simple can call those to stop polling messages from MQTT and restart whenever you need.
answered 7 hours ago
Artem BilanArtem Bilan
66.7k84972
answered 7 hours ago
Artem BilanArtem Bilan
66.7k84972
answered 7 hours ago
Artem BilanArtem Bilan
66.7k84972
answered 7 hours ago
Artem BilanArtem Bilan
66.7k84972
66.7k84972
Thanks Artem, will check it out. Seem to have stopped analyzing too soon.
– LHA
6 hours ago
add a comment |
Thanks Artem, will check it out. Seem to have stopped analyzing too soon.
– LHA
6 hours ago
Thanks Artem, will check it out. Seem to have stopped analyzing too soon.
– LHA
6 hours ago
Thanks Artem, will check it out. Seem to have stopped analyzing too soon.
– LHA
6 hours ago
add a comment |
Thanks for contributing an answer to Stack Overflow!
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function ()
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f55021227%2fpausing-and-resuming-mqtt-inbound-adapter%23new-answer', 'question_page');
);
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
