Come rimuovere un argomento quando non ci sono abbonati?

Question

Sto costruendo una soluzione di diffusione che crea un albero di argomenti.

Sto creando argomenti su richiesta per riflettere i valori ricevuti da un feed RabbitMQ. Ogni argomento ha un costo di memoria, quindi sto cercando di rimuovere l'argomento una volta che non ha avuto abbonati per qualche tempo.

Come è possibile farlo con l'API Java unificata?

Answer 1

Il TopicEventListener (parte della funzione TopicControl) fornisce questa funzionalità. Fornire singoli callback per quando un argomento ha 0 iscritti, così come quando un argomento ha almeno 1 iscritto.

Esempio:

public TopicEventListenerClient() { 
     session = Diffusion.sessions().principal("admin").password("password").open("ws://localhost:8080"); 
     topicControl = session.feature(TopicControl.class); 
     topicControl.addTopicEventListener("rabbitMQ/foo", new TopicEventListener() { 

      @Override 
      public void onClose(String arg0) { 
       LOG.info("Listener closed"); 
      } 

      @Override 
      public void onError(String arg0, ErrorReason arg1) { 
       LOG.info("Error on listener: " + arg1); 
      } 

      @Override 
      public void onRegistered(String arg0, Registration arg1) { 
       LOG.info("Listener registered"); 
      } 

      @Override 
      public void onHasSubscribers(String arg0) { 
       LOG.info("Topic: " + arg0 + " has at least 1 subscriber"); 
      } 

      @Override 
      public void onNoSubscribers(String arg0) { 
       LOG.info("Topic: " + arg0 + " has no subscribers"); 
      } 
     }); 
    } 

Spero che questo aiuti!