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
Can the Shape Water Cantrip be used to manipulate blood?
Practical reasons to have both a large police force and bounty hunting network?
1970s scifi/horror novel where protagonist is used by a crablike creature to feed its larvae, goes mad, and is defeated by retraumatising him
PTIJ: What’s wrong with eating meat and couscous?
I can't die. Who am I?
Draw bounding region by list of points
Why is my Contribution Detail Report (native CiviCRM Core report) not accurate?
Make me a metasequence
GPL code private and stolen
Why did the Cray-1 have 8 parity bits per word?
It doesn't matter the side you see it
Are small insurances worth it
How to mitigate "bandwagon attacking" from players?
Relationship between the symmetry number of a molecule as used in rotational spectroscopy and point group
Plagiarism of code by other PhD student
Ahoy, Ye Traveler!
Book about a time-travel war fought by computers
Is every open circuit a capacitor?
How can I handle a player who pre-plans arguments about my rulings on RAW?
Deal the cards to the players
Misplaced tyre lever - alternatives?
Giving a talk in my old university, how prominently should I tell students my salary?
Is there a math equivalent to the conditional ternary operator?
Is divide-by-zero a security vulnerability?
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 16 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 16 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 16 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 16 hours ago
LHALHA
51
asked 16 hours ago
LHALHA
51
asked 16 hours ago
LHALHA
51
asked 16 hours ago
LHALHA
51
asked 16 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 11 hours ago
Artem BilanArtem Bilan
66.7k84972
Thanks Artem, will check it out. Seem to have stopped analyzing too soon.
– LHA
11 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 11 hours ago
Artem BilanArtem Bilan
66.7k84972
Thanks Artem, will check it out. Seem to have stopped analyzing too soon.
– LHA
11 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 11 hours ago
Artem BilanArtem Bilan
66.7k84972
Thanks Artem, will check it out. Seem to have stopped analyzing too soon.
– LHA
11 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 11 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 11 hours ago
Artem BilanArtem Bilan
66.7k84972
answered 11 hours ago
Artem BilanArtem Bilan
66.7k84972
answered 11 hours ago
Artem BilanArtem Bilan
66.7k84972
answered 11 hours ago
Artem BilanArtem Bilan
66.7k84972
66.7k84972
Thanks Artem, will check it out. Seem to have stopped analyzing too soon.
– LHA
11 hours ago
add a comment |
Thanks Artem, will check it out. Seem to have stopped analyzing too soon.
– LHA
11 hours ago
Thanks Artem, will check it out. Seem to have stopped analyzing too soon.
– LHA
11 hours ago
Thanks Artem, will check it out. Seem to have stopped analyzing too soon.
– LHA
11 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
