[
https://issues.apache.org/jira/browse/ARTEMIS-2353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846720#comment-16846720
]
Gaurav edited comment on ARTEMIS-2353 at 5/23/19 1:43 PM:
----------------------------------------------------------
Please refer the new attachments for correct live backup configuration.
Stomp Client -> org.springframework.messaging.simp.stomp. **spring-messaging
ver 5.0.0.RELEASE*
Its a *persistent messages*. Passing StompHeaders as follows
this.stompHeaders.add("destination-type", "ANYCAST");
this.stompHeaders.add("destination", queueName);
this.stompHeaders.add("persistent", "true");
Below are sample code snippet used to create Stomp Client and Session:
*Create Stomp Client*
stompClient = new ReactorNettyTcpStompClient(tcpClient());
stompClient.setMessageConverter(new
MappingJackson2MessageConverter());
stompClient.setTaskScheduler(getTaskScheduler());
*Create Stomp Session*
ListenableFuture<StompSession> listenableFuture =
stompClient.connect(stompHeaders, new StompSessionHandler());
stompSession = (DefaultStompSession) listenableFuture.get();
*Send Message*
stompSession.send(stompHeaders, json);
was (Author: gsachar):
Please refer the new attachments for correct live backup configuration.
Stomp Client -> org.springframework.messaging.simp.stomp.* *spring-messaging
ver 5.0.0.RELEASE*
Its a *persistent messages*. Passing StompHeaders as follows
this.stompHeaders.add("destination-type", "ANYCAST");
this.stompHeaders.add("destination", queueName);
this.stompHeaders.add("persistent", "true");
> STOMP message loss during failover
> ----------------------------------
>
> Key: ARTEMIS-2353
> URL: https://issues.apache.org/jira/browse/ARTEMIS-2353
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Components: Broker, STOMP
> Affects Versions: 2.6.4
> Environment: REDHAT_BUGZILLA_PRODUCT="Red Hat Enterprise Linux 7"
> REDHAT_BUGZILLA_PRODUCT_VERSION=7.5
> REDHAT_SUPPORT_PRODUCT="Red Hat Enterprise Linux"
> REDHAT_SUPPORT_PRODUCT_VERSION="7.5"
> Reporter: Gaurav
> Assignee: Justin Bertram
> Priority: Major
> Attachments: brokerBackup.txt, brokerLive.txt
>
>
> We have single instance of Artemis Live server (2.6.4 version) backed up by
> Backup server. Please refer attachments for both Live-Backup broker
> configuration.
> We are using stomp protocol for messaging (port 61613).
> During failover of Live server, backup server is taking control of processing
> all incoming requests so switching from Live->Backup server is smooth.
> But we are seeing message loss (around 2 to 5 messages) exactly during fail
> over time. These messages were successfully published from client side and no
> exception received from broker by this time. After publishing of these
> messages, connectionLost exception was thrown during fail over which our
> application is correctly handling to shift incoming messages load to other
> node.
> It seems Live instance could not persist few messages on Journal file system
> as it got wiped out from in memory session. Major issue is that Client is not
> getting notified through any exception that message could not persist on
> broker journal.
> We are looking for broker configuration through which client call can be
> blocked until published message is not persisted on Journal.
> Any pointer on this issue is appreciated!
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
