@SuppressWarnings({ "rawtypes", "unchecked" }) @Test public void testSubscribe(@Capturing MessageConsumer capturingMessageConsumer, @Mocked MessageConsumer mockMessageConsumer) { new Expectations() {{ MessageConsumer.defaultStringMessageConsumer(anyString, anyString, (MessageProcessor) any); result = mockMessageConsumer; mockMessageConsumer.setName(anyString); times = 1; mockMessageConsumer.subscribe(anyString); times = 1; }}; testStompExporter.subscribe(); }
@Override protected void subscribe() { setConsumer(MessageConsumer.defaultStringMessageConsumer(odeProperties.getKafkaBrokers(), odeProperties.getHostId() + this.getClass().getSimpleName(), new StompStringMessageDistributor(template, getTopic()))); getConsumer().setName(this.getClass().getSimpleName()); getConsumer().subscribe(odeTopic); }
StompStringExporter extends Exporter { @Override protected void subscribe() { setConsumer(MessageConsumer.defaultStringMessageConsumer(odeProperties.getKafkaBrokers(), odeProperties.getHostId() + this.getClass().getSimpleName(), new StompStringMessageDistributor(template, getTopic()))); getConsumer().setName(this.getClass().getSimpleName()); getConsumer().subscribe(odeTopic); } }
StompStringExporter extends Exporter { @Override protected void subscribe() { setConsumer(MessageConsumer.defaultStringMessageConsumer(odeProperties.getKafkaBrokers(), odeProperties.getHostId() + this.getClass().getSimpleName(), new StompStringMessageDistributor(template, getTopic()))); getConsumer().setName(this.getClass().getSimpleName()); getConsumer().subscribe(odeTopic); } StompStringExporter(
            OdeProperties odeProperties,
            String stompTopic,
            SimpMessagingTemplate template,
            String odeTopic); }
StompStringExporter extends Exporter { @Override protected void subscribe() { setConsumer(MessageConsumer.defaultStringMessageConsumer(odeProperties.getKafkaBrokers(), odeProperties.getHostId() + this.getClass().getSimpleName(), new StompStringMessageDistributor(template, getTopic()))); getConsumer().setName(this.getClass().getSimpleName()); getConsumer().subscribe(odeTopic); } StompStringExporter(
            OdeProperties odeProperties,
            String stompTopic,
            SimpMessagingTemplate template,
            String odeTopic);  }
StompStringExporter extends Exporter { @Override protected void subscribe() { setConsumer(MessageConsumer.defaultStringMessageConsumer(odeProperties.getKafkaBrokers(), odeProperties.getHostId() + this.getClass().getSimpleName(), new StompStringMessageDistributor(template, getTopic()))); getConsumer().setName(this.getClass().getSimpleName()); getConsumer().subscribe(odeTopic); } StompStringExporter(
            OdeProperties odeProperties,
            String stompTopic,
            SimpMessagingTemplate template,
            String odeTopic);   }