I suspect that you're not setting the client id.
mqtt.setClientId("my-unique-client");
On Thu, Mar 9, 2017 at 2:20 PM, REGINA Patrick <patrick.reg...@edf.fr>
wrote:
> Hi,
>
> How can I create a durable subscriber.
>
> Indeed when my consumer is disconnected, I lose my messages.
>
> I create a durable queue but nothing change.
> Broker.xml :
> ....
> <queues>
> <queue name="digital.test.data">
> <durable>true</durable>
> </queue>
> </queues>
> ......
>
This is not necessary, Artemis will create subscription queues for you.
>
> If I disconnect my consumer, when I reconnect it, I don't receive any
> messages.
>
> Exemple of subscriber :
> BlockingConnection connection = null;
> try{
> connection = mqtt.blockingConnection();
> connection.connect();
>
> Topic[] topics = {new Topic("digital/test/data",
> QoS.EXACTLY_ONCE)};
> connection.subscribe(topics);
>
> System.out.println("Subscribed to topics.");
>
> while( continue)
> {
> Message message = connection.receive(5, TimeUnit.SECONDS);
> if(message != null)
> {
> System.out.println("Received messages.");
> System.out.println(new String(message.getPayload()));
> message.ack();
> }
>
> }
> }
> catch(Exception e)
> {
> e.printStackTrace();
> }
> finally{
> if(connection!=null) connection.disconnect();
> }
>
> What i need to do in the broker.xml file.
>
> Best regards.
>
>
> Ce message et toutes les pièces jointes (ci-après le 'Message') sont
> établis à l'intention exclusive des destinataires et les informations qui y
> figurent sont strictement confidentielles. Toute utilisation de ce Message
> non conforme à sa destination, toute diffusion ou toute publication totale
> ou partielle, est interdite sauf autorisation expresse.
>
> Si vous n'êtes pas le destinataire de ce Message, il vous est interdit de
> le copier, de le faire suivre, de le divulguer ou d'en utiliser tout ou
> partie. Si vous avez reçu ce Message par erreur, merci de le supprimer de
> votre système, ainsi que toutes ses copies, et de n'en garder aucune trace
> sur quelque support que ce soit. Nous vous remercions également d'en
> avertir immédiatement l'expéditeur par retour du message.
>
> Il est impossible de garantir que les communications par messagerie
> électronique arrivent en temps utile, sont sécurisées ou dénuées de toute
> erreur ou virus.
> ____________________________________________________
>
> This message and any attachments (the 'Message') are intended solely for
> the addressees. The information contained in this Message is confidential.
> Any use of information contained in this Message not in accord with its
> purpose, any dissemination or disclosure, either whole or partial, is
> prohibited except formal approval.
>
> If you are not the addressee, you may not copy, forward, disclose or use
> any part of it. If you have received this message in error, please delete
> it and all copies from your system and notify the sender immediately by
> return message.
>
> E-mail communication cannot be guaranteed to be timely secure, error or
> virus-free.
>
>
